- 31 3月, 2020 23 次提交
-
-
由 Arvid Heise 提交于
Because the classloader is now closed when the task fails the UDF only has access to the bootstrap classloader, which doesn't contain our own test classes.
-
由 Arvid Heise 提交于
-
由 Arvid Heise 提交于
Allows user classloader can be unloaded even if a reference on the context classloader outlives the user code.
-
由 Arvid Heise 提交于
The test is actually testing FlinkUserCodeClassLoaders.
-
由 Rui Li 提交于
This closes #11504
-
由 Jingsong Lee 提交于
This closes #11560
-
由 Hequn Cheng 提交于
-
由 HuangXingBo 提交于
-
由 yuzhao.cyz 提交于
* Some join order changes for blink-planner due to the rule fire sequence changes, see https://github.com/apache/calcite/commit/35caa059a762094c7df0b30e9b51358a19b48ac2, they are still correct * The Correlate row count estimation has been fixed from a always 1 to join like estimation, thus, if the inputs of Join is a Correlate, the join algorithm would very probably changes, i.e. batch.sql.SubplanReuseTest * Due to CALCITE-3729, the filter condition was pushed down for some Join cases: batch.sql.join.JoinReorderTest * Due to CALCITE-2450 RexNode normalization, the predicates sequence of some test changes: logical.subquery.FlinkRewriteSubQueryRuleTest * The Decimal modulus precision inference has been fixed: planner.expressions.DecimalTypeTest
-
由 yuzhao.cyz 提交于
* GROUP_ID translation was fixed
-
由 yuzhao.cyz 提交于
* CALCITE-3763 prunes useless fields of input project
-
由 yuzhao.cyz 提交于
[FLINK-14338][table-planner][table-planner-blink] Update files due to builtin TUMBLE operator name changes to $Tumble * This change was introduced in CALCITE-3382
-
由 yuzhao.cyz 提交于
[FLINK-14338][table-planner-blink] Plan verify changes from DIGEST to EXPLAIN: change plan for values node * The values node does not print row type anymore
-
由 yuzhao.cyz 提交于
[FLINK-14338][table-planner-blink] Plan verify changes from DIGEST to EXPLAIN: change plan for expand node * The explain node does not show each projects names anymore
-
由 yuzhao.cyz 提交于
* Because of CALCITE-3713, the project names was removed from plan DIGEST, thus, the DIGEST plan has less info that EXPLAIN, we switch to EXPLAIN for plan verification; * The CALC window fields name was also changes with CALCITE-3713, which is acceptable because the old name was also un-readable, the new name was based on field index, not bad.
-
由 yuzhao.cyz 提交于
[FLINK-14338][table-planner][table-planner-blink] Remove redundant code copy because the bugs are already fixed in Calcite * SqlValidatorImpl.java was removed because of CALCITE-2707 * ParameterScope.java was removed because of CALCITE-3476 * SqlFunction.java was removed because of CALCITE-3360
-
由 yuzhao.cyz 提交于
* Replace RelOptUtils.createCastRel with RelOptUtil.createCastRel * Implement RelOptTable#getKeys and Statistic#getKeys * Changes logical nodes constructor for hints * Implement RelShuttle.visit(LogicalTableModify)
-
由 yuzhao.cyz 提交于
[FLINK-14338][table-planner][table-planner-blink] Remove usage of TableScanRule and use new TableScanFactory extension * This change was introduced in CALCITE-3769
-
由 yuzhao.cyz 提交于
* This feature is introduced in CALCITE-3446
-
由 yuzhao.cyz 提交于
* Add Junit5 supports for tests * Move classes under package calcite.sql to flink.sql.parser.type * Remove ExtendedSqlBasicTypeNameSpec, use SqlAlienSystemTypeNameSpec instead * In Parser.tdd, re-organize the imports order to alphabetical order, remove the useless tailing commas, extends nonReservedKeywordsToAdd * Fix the JavaCC compile warnings
-
由 yuzhao.cyz 提交于
This closes #11340
-
由 Dian Fu 提交于
-
由 Dian Fu 提交于
-
- 30 3月, 2020 9 次提交
-
-
由 vthinkxie 提交于
This closes #11498.
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
-
由 qqibrow 提交于
This closes #11516.
-
由 Chesnay Schepler 提交于
-
由 Hequn Cheng 提交于
[FLINK-16672][python] Support Counter, Gauge, Meter, Distribution metric type for Python UDF (#11543)
-
由 Jark Wu 提交于
This closes #11550
-
由 godfrey he 提交于
This closes #11158
-
- 29 3月, 2020 1 次提交
-
-
由 Jiangjie (Becket) Qin 提交于
-
- 28 3月, 2020 6 次提交
-
-
由 guowei.mgw 提交于
[FLINK-16262][connectors/kafka] Set the context classloader for parallel stream in FlinkKafkaProducer This closes #11247
-
由 Jiangjie (Becket) Qin 提交于
-
由 Alexander Fedulov 提交于
-
由 Alexander Fedulov 提交于
-
由 Alexander Fedulov 提交于
-
由 Alexander Fedulov 提交于
-
- 27 3月, 2020 1 次提交
-
-
由 Alexander Fedulov 提交于
Introduce methods for better readibility.
-