This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 47ac28b [hotfix][table-planner-blink] Fix unstable itcase in
OverAggregateITCase#testRowNumberOnOver
add fb13a27 [FLINK-22378][table] Derive type of SOURCE_WATERMARK() from
time attribute
No new revisions were added by this update.
Summary of changes:
.../table/planner/delegation/hive/HiveParser.java | 6 +-
.../planner/delegation/hive/HiveParserFactory.java | 6 --
.../table/api/internal/TableEnvironmentImpl.java | 6 +-
.../flink/table/catalog/DefaultSchemaResolver.java | 25 +++++---
.../org/apache/flink/table/delegation/Parser.java | 11 +++-
.../expressions/resolver/ExpressionResolver.java | 18 ++++++
.../resolver/SqlExpressionResolver.java | 8 ++-
.../resolver/rules/ResolveSqlCallRule.java | 45 +++++++++++---
.../expressions/resolver/rules/ResolverRule.java | 4 ++
.../catalog/CatalogBaseTableResolutionTest.java | 6 +-
.../flink/table/catalog/SchemaResolutionTest.java | 30 +++++----
.../resolver/ExpressionResolverTest.java | 2 +-
.../utils/ValuesOperationTreeBuilderTest.java | 2 +-
.../flink/table/utils/ExpressionResolverMocks.java | 2 +-
.../org/apache/flink/table/utils/ParserMock.java | 8 ++-
.../table/connector/sink/DynamicTableSink.java | 7 +--
.../functions/BuiltInFunctionDefinitions.java | 2 +-
.../table/types/inference/TypeStrategies.java | 16 +++++
.../planner/calcite/FlinkCalciteSqlValidator.java | 17 ++++++
.../planner/calcite/SqlExprToRexConverter.java | 3 +
.../calcite/SqlExprToRexConverterFactory.java | 19 +++++-
.../planner/calcite/SqlExprToRexConverterImpl.java | 19 ++++--
.../planner/delegation/DefaultParserFactory.java | 7 +--
.../flink/table/planner/delegation/ParserImpl.java | 17 +++---
.../table/planner/delegation/PlannerContext.java | 55 +++++++++++++----
.../expressions/CallExpressionResolver.java | 2 +-
.../inference/TypeInferenceReturnInference.java | 20 +++++-
.../plan/abilities/source/FilterPushDownSpec.java | 2 +-
.../table/planner/calcite/FlinkPlannerImpl.scala | 38 +++++++-----
.../table/planner/delegation/PlannerBase.scala | 7 +--
.../plan/schema/LegacyCatalogSourceTable.scala | 4 +-
.../table/planner/delegation/ParserImplTest.java | 4 +-
.../operations/SqlToOperationConverterTest.java | 18 +++---
.../runtime/stream/sql/DataStreamJavaITCase.java | 71 ++++++++++++++++++++--
.../flink/table/planner/utils/PlannerMocks.java | 4 +-
.../codegen/WatermarkGeneratorCodeGenTest.scala | 26 +-------
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 2 +-
.../org/apache/flink/table/planner/ParserImpl.java | 8 ++-
.../flink/table/api/internal/TableEnvImpl.scala | 6 +-
.../operators/sink/OutputConversionOperator.java | 2 +
40 files changed, 390 insertions(+), 165 deletions(-)
