This is an automated email from the ASF dual-hosted git repository.
lincoln pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 09750220e78 [FLINK-37082][table-planner] Disable adaptive join
optimization when enable batch job progress recovery.
add c13815fe141 [FLINK-36171][table] Remove apis about ManagedTable
add de40a756e2e [FLINK-36481][table] Remove deprecated method
TableDescriptor#forManaged
No new revisions were added by this update.
Summary of changes:
.../flink/table/catalog/hive/HiveCatalog.java | 24 +-
.../table/catalog/hive/util/HiveTableUtil.java | 14 +-
.../table/catalog/hive/HiveCatalogITCase.java | 58 ---
.../flink/table/catalog/hive/HiveCatalogTest.java | 184 +-------
.../table/tests/test_catalog_completeness.py | 3 +-
.../src/main/codegen/data/Parser.tdd | 3 -
.../src/main/codegen/includes/parserImpls.ftl | 12 -
.../flink/sql/parser/ddl/SqlAlterTableCompact.java | 60 ---
.../flink/sql/parser/FlinkSqlParserImplTest.java | 17 -
.../apache/flink/table/api/TableDescriptor.java | 10 -
.../apache/flink/table/catalog/CatalogManager.java | 61 +--
.../table/catalog/GenericInMemoryCatalog.java | 5 -
.../flink/table/catalog/ManagedTableListener.java | 178 --------
.../table/operations/SourceQueryOperation.java | 35 +-
.../flink/table/api/TableEnvironmentTest.java | 101 -----
.../org/apache/flink/table/catalog/Catalog.java | 10 -
.../apache/flink/table/factories/FactoryUtil.java | 42 +-
.../flink/table/factories/ManagedTableFactory.java | 68 ---
.../connector/sink/TestManagedCommittable.java | 79 ----
.../table/connector/sink/TestManagedSink.java | 79 ----
.../sink/TestManagedSinkCommittableSerializer.java | 151 -------
.../connector/sink/TestManagedSinkCommitter.java | 151 -------
.../connector/sink/TestManagedSinkWriter.java | 79 ----
.../table/connector/sink/TestManagedTableSink.java | 83 ----
.../table/connector/source/CompactPartition.java | 166 -------
.../table/connector/source/CompactPartitions.java | 150 -------
.../source/TestManagedFileSourceReader.java | 35 --
.../TestManagedFileSourceSplitEnumerator.java | 73 ---
.../TestManagedFileSourceSplitSerializer.java | 61 ---
.../source/TestManagedIterableSourceSplit.java | 100 -----
.../table/connector/source/TestManagedSource.java | 94 ----
.../connector/source/TestManagedTableSource.java | 80 ----
.../flink/table/factories/FactoryUtilTest.java | 10 +-
.../table/factories/TestManagedTableFactory.java | 257 -----------
.../org.apache.flink.table.factories.Factory | 1 -
.../table/planner/calcite/FlinkRelBuilder.java | 17 -
.../operations/SqlNodeToOperationConversion.java | 62 ---
.../planner/plan/QueryOperationConverter.java | 7 -
.../table/planner/delegation/PlannerBase.scala | 11 -
.../stream/StreamPhysicalChangelogNormalize.scala | 13 +-
.../FlinkChangelogModeInferenceProgram.scala | 24 -
.../stream/StreamPhysicalTableSourceScanRule.scala | 3 +-
.../operations/DeletePushDownUtilsTest.java | 3 +-
.../operations/SqlCTASNodeToOperationTest.java | 21 +-
.../operations/SqlDdlToOperationConverterTest.java | 200 +++------
.../plan/rules/logical/AsyncCalcSplitRuleTest.java | 4 +
.../batch/sql/CompactManagedTableITCase.java | 488 ---------------------
.../flink/table/planner/utils/PlannerMocks.java | 7 +-
.../plan/batch/sql/CompactManagedTableTest.xml | 104 -----
.../table/planner/plan/batch/sql/TableSinkTest.xml | 18 -
.../physical/stream/ChangelogModeInferenceTest.xml | 82 ----
.../planner/plan/stream/sql/TableSinkTest.xml | 9 -
.../flink/table/api/TableEnvironmentTest.scala | 38 --
.../plan/batch/sql/CompactManagedTableTest.scala | 99 -----
.../planner/plan/batch/sql/TableSinkTest.scala | 33 --
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 7 +-
.../stream/ChangelogModeInferenceTest.scala | 78 ----
.../planner/plan/stream/sql/TableSinkTest.scala | 39 --
.../runtime/batch/sql/TableSinkITCase.scala | 4 +-
.../runtime/stream/sql/TableSinkITCase.scala | 9 +-
.../flink/table/planner/utils/TableTestBase.scala | 8 +-
61 files changed, 127 insertions(+), 3795 deletions(-)
delete mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterTableCompact.java
delete mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/ManagedTableListener.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/ManagedTableFactory.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedCommittable.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedSink.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedSinkCommittableSerializer.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedSinkCommitter.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedSinkWriter.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedTableSink.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/CompactPartition.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/CompactPartitions.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedFileSourceReader.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedFileSourceSplitEnumerator.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedFileSourceSplitSerializer.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedIterableSourceSplit.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedSource.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedTableSource.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/factories/TestManagedTableFactory.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/CompactManagedTableITCase.java
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/CompactManagedTableTest.xml
delete mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/CompactManagedTableTest.scala
