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/06/08 02:36:35 UTC
[flink] branch master updated (ee432b2 -> b162fbf)

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 ee432b2  [FLINK-22889][tests] Ignore JdbcExactlyOnceSinkE2eTest temporarily
     add b162fbf  [FLINK-21742][sql-client] Support REMOVE JAR statement in SQL Client

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/table/client/cli/CliClient.java   | 22 +++++++++-
 .../apache/flink/table/client/cli/CliStrings.java  |  3 ++
 .../flink/table/client/gateway/Executor.java       |  5 ++-
 .../client/gateway/context/SessionContext.java     | 24 +++++++++--
 .../table/client/gateway/local/LocalExecutor.java  |  6 +++
 .../flink/table/client/cli/CliClientTest.java      |  5 +++
 .../flink/table/client/cli/CliResultViewTest.java  |  5 +++
 .../flink/table/client/cli/TestingExecutor.java    |  5 +++
 .../client/gateway/context/SessionContextTest.java | 49 +++++++++++++++++++++-
 .../src/test/resources/sql/function.q              |  8 ++++
 .../src/main/codegen/data/Parser.tdd               |  4 ++
 .../src/main/codegen/includes/parserImpls.ftl      | 19 +++++++++
 .../parser/hive/FlinkHiveSqlParserImplTest.java    |  8 ++++
 .../src/main/codegen/data/Parser.tdd               |  6 ++-
 .../src/main/codegen/includes/parserImpls.ftl      | 19 +++++++++
 .../ddl/{SqlAddJar.java => SqlRemoveJar.java}      | 11 ++---
 .../flink/sql/parser/FlinkSqlParserImplTest.java   |  8 ++++
 ...ddJarOperation.java => RemoveJarOperation.java} |  8 ++--
 .../operations/SqlToOperationConverter.java        |  8 ++++
 .../operations/SqlToOperationConverterTest.java    | 42 +++++++++++++------
 20 files changed, 235 insertions(+), 30 deletions(-)
 copy flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/{SqlAddJar.java => SqlRemoveJar.java} (85%)
 copy flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/command/{AddJarOperation.java => RemoveJarOperation.java} (83%)