You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sh...@apache.org on 2023/01/29 13:37:34 UTC
[flink] branch master updated (6e445064f6a -> 95df4e726f3)
This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 6e445064f6a [FLINK-30799][runtime] Make SinkFunction support speculative execution through implementing SupportsConcurrentExecutionAttempts interface
add 0b783a54e8d [FLINK-30691][sql-client] Supports the gateway mode in the sql-client
add 95df4e726f3 [FLINK-30691][e2e] Add E2E test for the sql-client gateway mode
No new revisions were added by this update.
Summary of changes:
.../flink/tests/util/flink/FlinkDistribution.java | 96 ++++++-----
.../flink-sql-gateway-test/pom.xml | 6 +
.../flink/table/gateway/SqlGatewayE2ECase.java | 29 +++-
.../org/apache/flink/table/client/SqlClient.java | 133 ++++++++++------
.../apache/flink/table/client/cli/CliOptions.java | 82 +++++++---
.../flink/table/client/cli/CliOptionsParser.java | 159 ++++++++-----------
...lContextUtils.java => DefaultContextUtils.java} | 15 +-
.../apache/flink/table/client/SqlClientTest.java | 40 ++++-
.../src/test/resources/cli/all-mode-help.out | 175 +++++++++++++++++++++
.../src/test/resources/cli/embedded-mode-help.out | 136 ++++++++++++++++
.../src/test/resources/cli/gateway-mode-help.out | 36 +++++
.../apache/flink/test/util/SQLJobClientMode.java | 97 ++++++++++++
.../apache/flink/test/util/SQLJobSubmission.java | 19 +--
pom.xml | 2 +-
14 files changed, 785 insertions(+), 240 deletions(-)
rename flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/{LocalContextUtils.java => DefaultContextUtils.java} (86%)
create mode 100644 flink-table/flink-sql-client/src/test/resources/cli/all-mode-help.out
create mode 100644 flink-table/flink-sql-client/src/test/resources/cli/embedded-mode-help.out
create mode 100644 flink-table/flink-sql-client/src/test/resources/cli/gateway-mode-help.out
create mode 100644 flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/SQLJobClientMode.java