You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2021/07/26 12:04:53 UTC
[flink] branch master updated (684d56e -> 19a1a1a)
This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 684d56e [FLINK-23474] Extract internal version of InputStatus
add 19a1a1a [FLINK-22540][sql-client] Remove Yaml environment file in SQL Client (#16563)
No new revisions were added by this update.
Summary of changes:
flink-table/flink-sql-client/pom.xml | 22 -
.../apache/flink/table/client/cli/CliClient.java | 44 +-
.../apache/flink/table/client/cli/CliOptions.java | 14 -
.../flink/table/client/cli/CliOptionsParser.java | 32 --
.../flink/table/client/config/ConfigUtil.java | 112 -----
.../flink/table/client/config/Environment.java | 366 ---------------
.../flink/table/client/config/YamlConfigUtils.java | 297 ------------
.../table/client/config/entries/CatalogEntry.java | 73 ---
.../table/client/config/entries/ConfigEntry.java | 74 ---
.../client/config/entries/ConfigurationEntry.java | 88 ----
.../client/config/entries/DeploymentEntry.java | 166 -------
.../client/config/entries/ExecutionEntry.java | 318 -------------
.../table/client/config/entries/FunctionEntry.java | 84 ----
.../table/client/config/entries/ModuleEntry.java | 72 ---
.../client/config/entries/SinkTableEntry.java | 40 --
.../config/entries/SourceSinkTableEntry.java | 40 --
.../client/config/entries/SourceTableEntry.java | 40 --
.../table/client/config/entries/TableEntry.java | 110 -----
.../client/config/entries/TemporalTableEntry.java | 76 ---
.../table/client/config/entries/ViewEntry.java | 56 ---
.../client/gateway/context/DefaultContext.java | 29 +-
.../context/LegacyTableEnvironmentInitializer.java | 323 -------------
.../client/gateway/context/SessionContext.java | 17 +-
.../client/gateway/local/LocalContextUtils.java | 94 +---
.../src/test/assembly/test-table-factories.xml | 36 --
.../flink/table/client/cli/CliClientITCase.java | 2 -
.../flink/table/client/cli/CliClientTest.java | 2 -
.../table/client/config/YamlConfigUtilsTest.java | 148 ------
.../gateway/context/ExecutionContextTest.java | 512 ---------------------
.../client/gateway/context/SessionContextTest.java | 71 +--
.../table/client/gateway/local/DependencyTest.java | 78 ++--
.../client/gateway/local/EnvironmentTest.java | 145 ------
.../client/gateway/local/LocalExecutorITCase.java | 331 ++++++-------
.../gateway/utils/DummyTableSinkFactory.java | 31 --
.../gateway/utils/DummyTableSourceFactory.java | 31 --
.../client/gateway/utils/EnvironmentFileUtil.java | 55 ---
.../gateway/utils/TestTableSinkFactoryBase.java | 148 ------
.../gateway/utils/TestTableSourceFactoryBase.java | 175 -------
.../client/gateway/utils/UserDefinedFunctions.java | 22 +-
.../org.apache.flink.table.factories.Factory | 2 +-
.../org.apache.flink.table.factories.TableFactory | 2 -
.../flink-sql-client/src/test/resources/sql/set.q | 55 ---
.../src/test/resources/test-factory-services-file | 21 -
.../test/resources/test-sql-client-catalogs.yaml | 155 -------
.../resources/test-sql-client-configuration.yaml | 32 --
.../test/resources/test-sql-client-defaults.yaml | 155 -------
.../test/resources/test-sql-client-dialect.yaml | 29 --
.../test/resources/test-sql-client-execution.yaml | 34 --
.../test/resources/test-sql-client-factory.yaml | 56 ---
.../test/resources/test-sql-client-modules.yaml | 53 ---
.../test-sql-client-python-functions.yaml | 31 --
.../test/resources/test-sql-client-streaming.yaml | 88 ----
52 files changed, 226 insertions(+), 4861 deletions(-)
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/ConfigUtil.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/YamlConfigUtils.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/CatalogEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigurationEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/DeploymentEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ExecutionEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/FunctionEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ModuleEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/SinkTableEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/SourceSinkTableEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/SourceTableEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/TableEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/TemporalTableEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ViewEntry.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/LegacyTableEnvironmentInitializer.java
delete mode 100644 flink-table/flink-sql-client/src/test/assembly/test-table-factories.xml
delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/config/YamlConfigUtilsTest.java
delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/context/ExecutionContextTest.java
delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/EnvironmentTest.java
delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/utils/DummyTableSinkFactory.java
delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/utils/DummyTableSourceFactory.java
delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/utils/EnvironmentFileUtil.java
delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/utils/TestTableSinkFactoryBase.java
delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/utils/TestTableSourceFactoryBase.java
delete mode 100644 flink-table/flink-sql-client/src/test/resources/test-factory-services-file
delete mode 100644 flink-table/flink-sql-client/src/test/resources/test-sql-client-catalogs.yaml
delete mode 100644 flink-table/flink-sql-client/src/test/resources/test-sql-client-configuration.yaml
delete mode 100644 flink-table/flink-sql-client/src/test/resources/test-sql-client-defaults.yaml
delete mode 100644 flink-table/flink-sql-client/src/test/resources/test-sql-client-dialect.yaml
delete mode 100644 flink-table/flink-sql-client/src/test/resources/test-sql-client-execution.yaml
delete mode 100644 flink-table/flink-sql-client/src/test/resources/test-sql-client-factory.yaml
delete mode 100644 flink-table/flink-sql-client/src/test/resources/test-sql-client-modules.yaml
delete mode 100644 flink-table/flink-sql-client/src/test/resources/test-sql-client-python-functions.yaml
delete mode 100644 flink-table/flink-sql-client/src/test/resources/test-sql-client-streaming.yaml