You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/02/03 11:11:28 UTC
[flink] branch master updated (36a0e4c -> 183c8d1)
This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 36a0e4c [FLINK-15837] Add proper NOTICE file to flink-kubernetes
add 183c8d1 [FLINK-15840][table-planner-blink] Fix ClassCastException when use tEnv.from for temp/catalog table (#10989)
No new revisions were added by this update.
Summary of changes:
.../table/planner/calcite/FlinkToRelContext.java | 43 ----------
.../calcite/SqlExprToRexConverterFactory.java | 17 ++--
.../table/planner/delegation/PlannerContext.java | 27 ++++++-
.../flink/table/planner/calcite/FlinkContext.scala | 5 ++
.../table/planner/calcite/FlinkContextImpl.scala | 5 +-
.../table/planner/calcite/FlinkPlannerImpl.scala | 56 +++++++------
.../BatchCommonSubGraphBasedOptimizer.scala | 6 ++
.../StreamCommonSubGraphBasedOptimizer.scala | 6 ++
.../planner/plan/schema/CatalogSourceTable.scala | 58 ++++++++------
.../table/planner/plan/batch/sql/TableScanTest.xml | 64 +++++++++++----
.../codegen/WatermarkGeneratorCodeGenTest.scala | 12 ++-
.../planner/plan/batch/sql/TableScanTest.scala | 91 +++++++++++++++-------
.../metadata/AggCallSelectivityEstimatorTest.scala | 2 +-
.../plan/metadata/SelectivityEstimatorTest.scala | 3 +-
.../flink/table/planner/utils/TableTestBase.scala | 8 +-
15 files changed, 248 insertions(+), 155 deletions(-)
delete mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/FlinkToRelContext.java
copy flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/CompressWriters.java => flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/SqlExprToRexConverterFactory.java (73%)