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 1d2f1e7 [FLINK-26500][runtime][test] Increases the deadline to wait
for parallelism
add 9e3e51d [FLINK-26421][table] Remove planner & executor string
identifiers
add 70e6f8b [hotfix][table-api] Remove deprecated create methods
add 57742b8 [FLINK-26421] Use only EnvironmentSettings to configure the
environment
add c16e4b4 [FLINK-26421][table-api-java] Improve JavaDocs of TableConfig
No new revisions were added by this update.
Summary of changes:
.../generated/table_config_configuration.html | 12 ++
.../flink/connectors/hive/HiveDialectITCase.java | 12 +-
.../table/catalog/hive/HiveCatalogITCase.java | 8 +-
flink-python/pyflink/java_gateway.py | 1 +
flink-python/pyflink/table/environment_settings.py | 23 ++++
.../table/tests/test_environment_settings.py | 4 +-
.../table/tests/test_table_config_completeness.py | 3 +-
.../client/gateway/context/ExecutionContext.java | 42 +++----
.../client/gateway/context/SessionContext.java | 3 +-
.../AbstractStreamTableEnvironmentImpl.java | 6 +-
.../api/bridge/java/StreamTableEnvironment.java | 43 +------
.../java/internal/StreamTableEnvironmentImpl.java | 22 ++--
.../flink/table/api/EnvironmentSettings.java | 137 +++++++--------------
.../org/apache/flink/table/api/TableConfig.java | 120 ++++++++++++++++--
.../flink/table/api/config/TableConfigOptions.java | 18 +++
.../table/api/internal/TableEnvironmentImpl.java | 27 ++--
.../flink/table/factories/PlannerFactoryUtil.java | 3 +-
.../flink/table/api/EnvironmentSettingsTest.java | 7 +-
.../flink/table/catalog/FunctionCatalogTest.java | 4 +-
.../flink/table/utils/CatalogManagerMocks.java | 8 +-
.../flink/table/utils/TableEnvironmentMock.java | 14 +--
.../api/bridge/scala/StreamTableEnvironment.scala | 44 +------
.../internal/StreamTableEnvironmentImpl.scala | 20 +--
.../planner/delegation/DefaultPlannerFactory.java | 9 +-
.../apache/flink/table/api/EnvironmentTest.java | 28 +++++
.../plan/nodes/exec/TransformationsTest.java | 2 +-
.../exec/serde/DynamicTableSinkSpecSerdeTest.java | 20 +--
.../serde/DynamicTableSourceSpecSerdeTest.java | 16 +--
.../expressions/utils/ExpressionTestBase.scala | 16 ++-
.../harness/GroupAggregateHarnessTest.scala | 3 +-
.../planner/runtime/harness/HarnessTestBase.scala | 21 +---
.../runtime/harness/OverAggregateHarnessTest.scala | 18 +--
.../planner/runtime/harness/RankHarnessTest.scala | 3 +-
.../harness/TableAggregateHarnessTest.scala | 3 +-
.../stream/sql/StreamTableEnvironmentITCase.scala | 25 ++++
.../flink/table/planner/utils/TableTestBase.scala | 25 ++--
36 files changed, 409 insertions(+), 361 deletions(-)
