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