This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 41ee1d2 [FLINK-26536][python] Fix
RemoteKeyedStateBackend#merge_namespaces to handle properly for the timerservice
new 0ba337c [hotfix][connector-hive] Avoid serializing TableConfig
new 5bd6aef [FLINK-26709][table] Replace
TableConfig.getConfiguration.set()
new a6daa22 [FLINK-26709][table] Replace
TableConfig.getConfiguration.get/getOptional()
new 885d4bb [FLINK-26709][table] Replace TableConfig.getConfiguration
new b7fb464 [FLINK-26777][table-planner] Remove `PlannerConfig` from
`PlannerBase`
new 607c3a7 [hotfix][table-planner][tests] Use EnvironmentSettings to
pass configuration
new 30ce8e7 [hotfix][table-planner] Remove ExecNodeConfig#getLocalTimeZone
new 65a3b08 [hotfix][table-planner] Remove
ExecNodeConfig#getMaxIdleStateRetentionTime()
The 8 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:
.../table/ElasticsearchDynamicSinkBaseITCase.java | 6 +-
.../hive/ContinuousHiveSplitEnumerator.java | 13 +-
.../connectors/hive/HiveLookupTableSource.java | 2 +-
.../apache/flink/connectors/hive/HiveSource.java | 11 +-
.../flink/connectors/hive/HiveSourceBuilder.java | 18 ++-
.../connectors/hive/HiveSourceFileEnumerator.java | 29 ++--
.../flink/connectors/hive/HiveTableSink.java | 33 +++-
.../flink/connectors/hive/HiveTableSource.java | 4 +-
.../hive/read/HiveInputFormatPartitionReader.java | 9 +-
.../connectors/hive/read/HiveTableInputFormat.java | 20 +--
.../hive/HiveDynamicTableFactoryTest.java | 4 +-
.../connectors/hive/HiveLookupJoinITCase.java | 2 +-
.../flink/connectors/hive/HiveRunnerITCase.java | 4 +-
.../connectors/hive/HiveSinkCompactionITCase.java | 4 +-
.../flink/connectors/hive/HiveTableSinkITCase.java | 8 +-
.../connectors/hive/HiveTableSourceITCase.java | 31 +---
.../connectors/hive/PartitionMonitorTest.java | 3 +-
.../hive/TableEnvHiveConnectorITCase.java | 8 +-
.../read/HiveInputFormatPartitionReaderITCase.java | 4 +-
.../table/catalog/hive/HiveCatalogITCase.java | 14 +-
.../flink/table/catalog/hive/HiveTestUtils.java | 8 +-
.../connector/jdbc/catalog/MySqlCatalogITCase.java | 4 +-
.../jdbc/catalog/PostgresCatalogITCase.java | 4 +-
.../kafka/table/KafkaChangelogTableITCase.java | 37 +++--
.../connectors/kafka/table/KafkaTableITCase.java | 11 +-
.../flink/python/tests/BatchPythonUdfSqlJob.java | 2 +-
.../apache/flink/table/tpcds/TpcdsTestProgram.java | 12 +-
.../flink/client/python/PythonFunctionFactory.java | 7 +-
.../flink/table/runtime/arrow/ArrowUtils.java | 2 +-
.../client/python/PythonFunctionFactoryTest.java | 5 +-
.../PythonScalarFunctionOperatorTestBase.java | 5 +-
.../flink/table/client/cli/CliResultViewTest.java | 4 +-
.../flink/table/client/cli/TestingExecutor.java | 3 +-
.../client/gateway/context/SessionContextTest.java | 39 +++--
.../AbstractStreamTableEnvironmentImpl.java | 3 +-
.../org/apache/flink/table/api/TableResult.java | 4 +-
.../flink/table/api/internal/CompiledPlanImpl.java | 5 +-
.../table/api/internal/TableEnvironmentImpl.java | 15 +-
.../flink/table/catalog/FunctionCatalog.java | 6 -
.../expressions/resolver/ExpressionResolver.java | 2 +-
.../flink/table/utils/TableEnvironmentMock.java | 3 +-
.../internal/StreamTableEnvironmentImpl.scala | 2 +-
.../planner/connectors/DynamicSourceUtils.java | 4 +-
.../table/planner/delegation/PlannerConfig.java | 56 -------
.../planner/plan/QueryOperationConverter.java | 4 +-
.../abilities/source/WatermarkPushDownSpec.java | 5 +-
.../planner/plan/nodes/exec/ExecNodeBase.java | 4 +-
.../planner/plan/nodes/exec/ExecNodeConfig.java | 59 ++------
.../exec/common/CommonExecWindowTableFunction.java | 4 +-
.../exec/processor/DeadlockBreakupProcessor.java | 2 +-
.../MultipleInputNodeCreationProcessor.java | 2 +-
.../plan/nodes/exec/serde/SerdeContext.java | 6 +-
.../plan/nodes/exec/spec/DynamicTableSinkSpec.java | 2 +-
.../nodes/exec/spec/DynamicTableSourceSpec.java | 2 +-
.../plan/nodes/exec/spec/DynamicTableSpecBase.java | 5 +-
.../stream/StreamExecGlobalWindowAggregate.java | 4 +-
.../stream/StreamExecGroupWindowAggregate.java | 3 +-
.../stream/StreamExecLocalWindowAggregate.java | 4 +-
.../nodes/exec/stream/StreamExecOverAggregate.java | 11 +-
.../stream/StreamExecPythonGroupAggregate.java | 3 +-
.../StreamExecPythonGroupTableAggregate.java | 3 +-
.../StreamExecPythonGroupWindowAggregate.java | 3 +-
.../exec/stream/StreamExecPythonOverAggregate.java | 3 +-
.../nodes/exec/stream/StreamExecTemporalJoin.java | 3 +-
.../exec/stream/StreamExecWindowAggregate.java | 4 +-
.../exec/stream/StreamExecWindowDeduplicate.java | 4 +-
.../nodes/exec/stream/StreamExecWindowJoin.java | 4 +-
.../nodes/exec/stream/StreamExecWindowRank.java | 4 +-
.../logical/PushFilterIntoSourceScanRuleBase.java | 6 +-
.../PushWatermarkIntoTableSourceScanRuleBase.java | 4 +-
.../batch/PushLocalAggIntoScanRuleBase.java | 6 +-
.../planner/plan/schema/CatalogSourceTable.java | 9 +-
.../utils/DummyStreamExecutionEnvironment.java | 6 +
.../flink/table/planner/utils/ShortcutUtils.java | 2 +-
.../table/planner/utils/TableConfigUtils.java | 49 +++++-
.../table/planner/delegation/BatchPlanner.scala | 5 +-
.../table/planner/delegation/PlannerBase.scala | 35 ++---
.../table/planner/delegation/StreamPlanner.scala | 3 +-
.../plan/metadata/FlinkRelMdColumnNullCount.scala | 3 +-
.../plan/metadata/FlinkRelMdDistinctRowCount.scala | 3 +-
.../plan/metadata/FlinkRelMdDistribution.scala | 3 +-
.../planner/plan/metadata/FlinkRelMdRowCount.scala | 3 +-
.../plan/metadata/SelectivityEstimator.scala | 3 +-
.../plan/nodes/logical/FlinkLogicalSort.scala | 4 +-
.../batch/BatchPhysicalHashAggregate.scala | 2 +-
.../batch/BatchPhysicalOverAggregateBase.scala | 2 +-
.../batch/BatchPhysicalPythonGroupAggregate.scala | 2 +-
.../nodes/physical/batch/BatchPhysicalRank.scala | 2 +-
.../batch/BatchPhysicalSortAggregate.scala | 2 +-
.../BatchCommonSubGraphBasedOptimizer.scala | 4 +-
.../StreamCommonSubGraphBasedOptimizer.scala | 10 +-
.../plan/optimize/program/FlinkBatchProgram.scala | 6 +-
.../FlinkChangelogModeInferenceProgram.scala | 2 +-
.../plan/optimize/program/FlinkStreamProgram.scala | 6 +-
.../table/planner/plan/reuse/SubplanReuser.scala | 5 +-
.../rules/logical/JoinDeriveNullFilterRule.scala | 2 +-
.../PushFilterIntoLegacyTableSourceScanRule.scala | 2 +-
.../plan/rules/logical/SplitAggregateRule.scala | 4 +-
.../physical/batch/BatchPhysicalHashJoinRule.scala | 4 +-
.../physical/batch/BatchPhysicalJoinRuleBase.scala | 2 +-
.../batch/BatchPhysicalSortMergeJoinRule.scala | 4 +-
.../physical/batch/BatchPhysicalSortRule.scala | 2 +-
.../physical/stream/IncrementalAggregateRule.scala | 2 +-
.../stream/MiniBatchIntervalInferRule.scala | 3 +-
.../stream/TwoStageOptimizedAggregateRule.scala | 3 +-
.../plan/schema/LegacyCatalogSourceTable.scala | 4 +-
.../table/planner/plan/utils/FlinkRelOptUtil.scala | 3 +-
.../planner/plan/utils/IntervalJoinUtil.scala | 3 +-
.../table/planner/plan/utils/PartitionPruner.scala | 7 +-
.../flink/table/planner/plan/utils/RankUtil.scala | 3 +-
.../table/planner/plan/utils/WindowUtil.scala | 5 +-
.../BuiltInAggregateFunctionTestBase.java | 4 +-
.../nodes/exec/serde/LogicalTypeJsonSerdeTest.java | 16 +-
.../plan/nodes/exec/serde/LookupKeySerdeTest.java | 2 +-
.../PushLocalAggIntoTableSourceScanRuleTest.java | 3 +-
.../flink/table/api/TableEnvironmentTest.scala | 11 +-
.../planner/calcite/CalciteConfigBuilderTest.scala | 4 +-
.../plan/batch/sql/DeadlockBreakupTest.scala | 110 +++++++-------
.../planner/plan/batch/sql/LegacySinkTest.scala | 5 +-
.../plan/batch/sql/MultipleInputCreationTest.scala | 56 +++----
.../plan/batch/sql/RemoveCollationTest.scala | 40 ++---
.../planner/plan/batch/sql/RemoveShuffleTest.scala | 168 ++++++++++-----------
.../planner/plan/batch/sql/SetOperatorsTest.scala | 2 +-
.../planner/plan/batch/sql/SortLimitTest.scala | 24 +--
.../table/planner/plan/batch/sql/SortTest.scala | 34 ++---
.../planner/plan/batch/sql/SubplanReuseTest.scala | 68 ++++-----
.../planner/plan/batch/sql/TableSinkTest.scala | 5 +-
.../planner/plan/batch/sql/TableSourceTest.scala | 5 +-
.../plan/batch/sql/agg/GroupWindowTest.scala | 2 +-
.../plan/batch/sql/agg/HashAggregateTest.scala | 4 +-
.../plan/batch/sql/agg/SortAggregateTest.scala | 4 +-
.../batch/sql/join/BroadcastHashJoinTest.scala | 7 +-
.../sql/join/BroadcastHashSemiAntiJoinTest.scala | 6 +-
.../plan/batch/sql/join/LookupJoinTest.scala | 8 +-
.../plan/batch/sql/join/NestedLoopJoinTest.scala | 2 +-
.../sql/join/NestedLoopSemiAntiJoinTest.scala | 2 +-
.../plan/batch/sql/join/ShuffledHashJoinTest.scala | 2 +-
.../sql/join/ShuffledHashSemiAntiJoinTest.scala | 2 +-
.../plan/batch/sql/join/SortMergeJoinTest.scala | 2 +-
.../batch/sql/join/SortMergeSemiAntiJoinTest.scala | 2 +-
.../planner/plan/common/JoinReorderTestBase.scala | 8 +-
.../planner/plan/common/TableFactoryTest.scala | 2 +-
.../table/planner/plan/hint/OptionsHintTest.scala | 4 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 6 +-
.../logical/JoinDeriveNullFilterRuleTest.scala | 4 +-
.../rules/logical/SplitAggregateRuleTest.scala | 16 +-
.../batch/EnforceLocalHashAggRuleTest.scala | 6 +-
.../batch/EnforceLocalSortAggRuleTest.scala | 6 +-
.../RemoveRedundantLocalHashAggRuleTest.scala | 18 +--
.../stream/ChangelogModeInferenceTest.scala | 8 +-
...xpandWindowTableFunctionTransposeRuleTest.scala | 4 +-
.../plan/stream/sql/DagOptimizationTest.scala | 55 +++----
.../planner/plan/stream/sql/DeduplicateTest.scala | 14 +-
.../stream/sql/MiniBatchIntervalInferTest.scala | 42 +++---
.../plan/stream/sql/ModifiedMonotonicityTest.scala | 18 +--
.../table/planner/plan/stream/sql/RankTest.scala | 5 +-
.../planner/plan/stream/sql/SubplanReuseTest.scala | 34 ++---
.../planner/plan/stream/sql/TableScanTest.scala | 12 +-
.../planner/plan/stream/sql/TableSinkTest.scala | 23 ++-
.../plan/stream/sql/agg/AggregateTest.scala | 24 +--
.../stream/sql/agg/DistinctAggregateTest.scala | 11 +-
.../plan/stream/sql/agg/GroupWindowTest.scala | 16 +-
.../stream/sql/agg/IncrementalAggregateTest.scala | 4 +-
.../stream/sql/agg/TwoStageAggregateTest.scala | 2 +-
.../plan/stream/sql/agg/WindowAggregateTest.scala | 38 ++---
.../sql/agg/AggregateJoinTransposeITCase.scala | 2 +-
.../runtime/stream/sql/GroupWindowITCase.scala | 5 +-
.../utils/StreamingWithMiniBatchTestBase.scala | 6 +-
.../flink/table/planner/utils/TableTestBase.scala | 11 +-
.../GeneratedWatermarkGeneratorSupplier.java | 9 +-
170 files changed, 881 insertions(+), 990 deletions(-)
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/delegation/PlannerConfig.java
