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 fd4f918bbaa [FLINK-30474][runtime] Propagates leader information
change only if the leadership is still acquired
add 615fde6667a [FLINK-30827][sql-client] Improve the SQL Client code
structure (#21790)
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/table/client/SqlClient.java | 4 ++--
.../table/client/cli/CliChangelogResultView.java | 2 +-
.../flink/table/client/cli/CliTableResultView.java | 2 +-
.../table/client/cli/CliTableauResultView.java | 2 +-
.../gateway/{local => }/DefaultContextUtils.java | 2 +-
.../table/client/gateway/ResultDescriptor.java | 8 +++----
.../gateway/{local => }/SingleSessionManager.java | 2 +-
.../{local => }/result/ChangelogCollectResult.java | 2 +-
.../{local => }/result/ChangelogResult.java | 2 +-
.../{local => }/result/CollectResultBase.java | 2 +-
.../gateway/{local => }/result/DynamicResult.java | 2 +-
.../result/MaterializedCollectBatchResult.java | 2 +-
.../result/MaterializedCollectResultBase.java | 2 +-
.../result/MaterializedCollectStreamResult.java | 2 +-
.../{local => }/result/MaterializedResult.java | 2 +-
.../flink/table/client/cli/CliClientITCase.java | 2 +-
.../flink/table/client/cli/CliResultViewTest.java | 4 ++--
.../table/client/cli/CliTableauResultViewTest.java | 2 +-
.../gateway/{local => }/ExecutorImplITCase.java | 25 ++++++++--------------
.../result/BaseMaterializedResultTest.java | 2 +-
.../result/ChangelogCollectResultTest.java | 2 +-
.../result/MaterializedCollectBatchResultTest.java | 2 +-
.../MaterializedCollectStreamResultTest.java | 2 +-
23 files changed, 36 insertions(+), 43 deletions(-)
rename
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/{local
=> }/DefaultContextUtils.java (98%)
rename
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/{local
=> }/SingleSessionManager.java (99%)
rename
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/{local
=> }/result/ChangelogCollectResult.java (98%)
rename
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/{local
=> }/result/ChangelogResult.java (95%)
rename
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/{local
=> }/result/CollectResultBase.java (98%)
rename
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/{local
=> }/result/DynamicResult.java (94%)
rename
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/{local
=> }/result/MaterializedCollectBatchResult.java (97%)
rename
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/{local
=> }/result/MaterializedCollectResultBase.java (98%)
rename
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/{local
=> }/result/MaterializedCollectStreamResult.java (98%)
rename
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/{local
=> }/result/MaterializedResult.java (95%)
rename
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/{local
=> }/ExecutorImplITCase.java (97%)
rename
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/{local
=> }/result/BaseMaterializedResultTest.java (97%)
rename
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/{local
=> }/result/ChangelogCollectResultTest.java (98%)
rename
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/{local
=> }/result/MaterializedCollectBatchResultTest.java (99%)
rename
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/{local
=> }/result/MaterializedCollectStreamResultTest.java (99%)
