This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 9bc156b7faf [FLINK-39909][state] Fix heap state backend savepoint NPE
with null map state values
new d2ddbe0f18b [FLINK-39817][table] Upgrade Calcite to 1.39.0
new 0e852ba33e1 [FLINK-39817][table] Do not use deprecated
`SqlPrettyWriter` constructor
new 160aba5fd4a [FLINK-39817][table] Replace deprecated
`LogicalProject.create`
new 316d926c34e [FLINK-39817][table] Replace deprecated `JavaConversions`
in `TemporalJoinUtil`
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-table/flink-sql-parser/pom.xml | 8 +-
.../src/main/codegen/data/Parser.tdd | 4 +
.../src/main/codegen/templates/Parser.jj | 109 +-
.../org/apache/calcite/sql/type/SqlTypeFamily.java | 292 --
.../org/apache/calcite/sql/type/SqlTypeName.java | 1078 -----
.../sql/parser/validate/FlinkSqlConformance.java | 15 +
.../sql/parser/ExtendedSqlRowTypeNameSpecTest.java | 17 +-
.../flink/sql/parser/FlinkDDLDataTypeTest.java | 6 +-
flink-table/flink-table-calcite-bridge/pom.xml | 8 +-
.../apache/calcite/jdbc/SimpleCalciteSchema.java | 56 +-
.../java/org/apache/calcite/plan/RelOptUtil.java | 4596 --------------------
.../calcite/rel/rules/SubQueryRemoveRule.java | 115 +-
.../calcite/rel/type/RelDataTypeFactoryImpl.java | 18 +-
.../java/org/apache/calcite/rex/RexBuilder.java | 47 +-
.../java/org/apache/calcite/rex/RexChecker.java | 203 -
.../org/apache/calcite/rex/RexFieldAccess.java | 141 -
.../java/org/apache/calcite/rex/RexProgram.java | 984 -----
.../java/org/apache/calcite/rex/RexShuttle.java | 284 --
.../main/java/org/apache/calcite/rex/RexUtil.java | 18 +-
.../org/apache/calcite/runtime/SqlFunctions.java | 384 +-
.../apache/calcite/sql/SqlIntervalQualifier.java | 56 +-
.../main/java/org/apache/calcite/sql/SqlUtil.java | 8 +-
.../calcite/sql/fun/SqlStdOperatorTable.java | 127 +-
.../org/apache/calcite/sql/type/BasicSqlType.java | 2 +-
.../calcite/sql/type/SqlTypeAssignmentRule.java | 4 +-
.../calcite/sql/type/SqlTypeFactoryImpl.java | 70 +-
.../org/apache/calcite/sql/type/SqlTypeUtil.java | 86 +-
.../calcite/sql/validate/SqlValidatorImpl.java | 438 +-
.../org/apache/calcite/sql2rel/AggConverter.java | 4 +-
.../apache/calcite/sql2rel/RelDecorrelator.java | 492 ++-
.../apache/calcite/sql2rel/SqlToRelConverter.java | 520 ++-
.../planner/calcite/FlinkCalciteSqlValidator.java | 8 +
.../plan/rules/logical/WindowGroupReorderRule.java | 5 +-
.../src/main/resources/META-INF/NOTICE | 6 +-
.../planner/plan/utils/TemporalJoinUtil.scala | 18 +-
.../table/planner/plan/batch/sql/CalcTest.xml | 2 +-
.../planner/plan/batch/sql/DeadlockBreakupTest.xml | 2 +-
.../plan/batch/sql/DynamicFunctionPlanTest.xml | 9 +-
.../planner/plan/batch/sql/SetOperatorsTest.xml | 4 +-
.../ReplaceIntersectWithSemiJoinRuleTest.xml | 2 +-
.../logical/ReplaceMinusWithAntiJoinRuleTest.xml | 2 +-
.../rules/logical/WindowGroupReorderRuleTest.xml | 2 +-
.../logical/subquery/SubQueryAntiJoinTest.xml | 180 +
.../logical/subquery/SubQuerySemiJoinTest.xml | 109 +
.../PushCalcPastChangelogNormalizeRuleTest.xml | 18 +-
.../table/planner/plan/stream/sql/CalcTest.xml | 2 +-
.../planner/plan/stream/sql/SetOperatorsTest.xml | 4 +-
.../table/planner/plan/stream/table/ValuesTest.xml | 2 +-
.../planner/expressions/SqlExpressionTest.scala | 1 +
.../logical/subquery/SubQueryAntiJoinTest.scala | 16 +-
.../logical/subquery/SubQuerySemiJoinTest.scala | 12 +-
flink-table/pom.xml | 2 +-
52 files changed, 2088 insertions(+), 8508 deletions(-)
delete mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql/type/SqlTypeFamily.java
delete mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql/type/SqlTypeName.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/calcite/plan/RelOptUtil.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/calcite/rex/RexChecker.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/calcite/rex/RexFieldAccess.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/calcite/rex/RexProgram.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/calcite/rex/RexShuttle.java
