You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2021/02/04 15:11:01 UTC
[flink] branch master updated (05aacc4 -> 59c807e)
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 05aacc4 [FLINK-21277] Bump testcontainers version
add 59c807e [FLINK-21149][table-common] Remove deprecated CatalogBaseTable.getProperties()
No new revisions were added by this update.
Summary of changes:
.../flink/connectors/hive/HiveTableFactory.java | 6 ++--
.../flink/table/catalog/hive/HiveCatalog.java | 2 +-
.../table/catalog/hive/util/HiveTableUtil.java | 2 +-
flink-python/pyflink/table/catalog.py | 14 ---------
flink-python/pyflink/table/tests/test_catalog.py | 4 +--
.../gateway/utils/TestTableSinkFactoryBase.java | 3 +-
.../gateway/utils/TestTableSourceFactoryBase.java | 2 +-
.../src/main/codegen/data/Parser.tdd | 2 +-
.../sql/parser/hive/ddl/SqlAlterHiveTable.java | 4 +--
.../src/main/codegen/data/Parser.tdd | 2 +-
.../src/main/codegen/includes/parserImpls.ftl | 2 +-
...leProperties.java => SqlAlterTableOptions.java} | 6 ++--
.../table/api/internal/TableEnvironmentImpl.java | 8 ++---
.../flink/table/catalog/AbstractCatalogTable.java | 16 +++++-----
.../flink/table/catalog/AbstractCatalogView.java | 10 +++----
.../flink/table/catalog/CatalogTableImpl.java | 4 +--
.../flink/table/catalog/CatalogViewImpl.java | 2 +-
...ration.java => AlterTableOptionsOperation.java} | 7 ++---
.../flink/table/api/TableEnvironmentTest.java | 14 ++++-----
.../flink/table/catalog/CatalogBaseTable.java | 8 +----
.../apache/flink/table/catalog/CatalogTest.java | 2 +-
.../flink/table/catalog/CatalogTestUtil.java | 20 ++++++-------
.../flink/table/factories/FactoryUtilTest.java | 5 ----
.../operations/SqlToOperationConverter.java | 28 +++++++++---------
.../table/planner/delegation/PlannerBase.scala | 2 +-
.../batch/BatchPhysicalLegacySinkRule.scala | 2 +-
.../stream/StreamPhysicalLegacySinkRule.scala | 2 +-
.../plan/schema/LegacyCatalogSourceTable.scala | 2 +-
.../planner/catalog/JavaCatalogTableTest.java | 2 +-
.../operations/SqlToOperationConverterTest.java | 34 +++++++++++-----------
.../table/planner/utils/OperationMatchers.java | 2 +-
.../flink/table/api/TableEnvironmentTest.scala | 2 +-
.../table/planner/catalog/CatalogTableITCase.scala | 14 ++++-----
.../utils/TestCollectionTableFactory.scala | 2 +-
.../table/sqlexec/SqlToOperationConverter.java | 18 ++++++------
.../flink/table/api/internal/TableEnvImpl.scala | 2 +-
.../table/sqlexec/SqlToOperationConverterTest.java | 16 +++++-----
.../api/batch/BatchTableEnvironmentTest.scala | 2 +-
.../flink/table/catalog/CatalogTableITCase.scala | 2 +-
39 files changed, 123 insertions(+), 154 deletions(-)
rename flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/{SqlAlterTableProperties.java => SqlAlterTableOptions.java} (95%)
rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/{AlterTablePropertiesOperation.java => AlterTableOptionsOperation.java} (87%)