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 63a6aba [FLINK-21523][hive] Fix ArrayIndexOutOfBoundsException when
running hive partitioned source with projection push down
add c998ba4 [FLINK-21485][sql-client] Simplify the ExecutionContext
(#15006)
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/table/client/SqlClient.java | 70 +-
.../client/config/entries/ExecutionEntry.java | 2 +-
.../flink/table/client/gateway/Executor.java | 10 +-
.../flink/table/client/gateway/SessionContext.java | 66 --
.../client/gateway/context/DefaultContext.java | 277 ++++++
.../client/gateway/context/ExecutionContext.java | 220 +++++
.../context/LegacyTableEnvironmentInitializer.java | 392 ++++++++
.../client/gateway/context/SessionContext.java | 237 +++++
.../client/gateway/local/ExecutionContext.java | 1015 --------------------
.../client/gateway/local/LocalContextUtils.java | 223 +++++
.../table/client/gateway/local/LocalExecutor.java | 284 +-----
.../client/gateway/local/ProgramDeployer.java | 89 --
.../flink/table/client/cli/CliClientITCase.java | 14 +-
.../flink/table/client/cli/CliClientTest.java | 38 +-
.../flink/table/client/cli/CliResultViewTest.java | 13 +-
.../flink/table/client/cli/TestingExecutor.java | 7 +-
.../{local => context}/ExecutionContextTest.java | 86 +-
.../client/gateway/context/SessionContextTest.java | 181 ++++
.../table/client/gateway/local/DependencyTest.java | 29 +-
.../client/gateway/local/LocalExecutorITCase.java | 168 ++--
.../org.apache.flink.table.factories.TableFactory | 2 +-
.../src/test/resources/sql/function.q | 12 +-
.../flink/table/catalog/FunctionCatalog.java | 7 +-
23 files changed, 1782 insertions(+), 1660 deletions(-)
delete mode 100644
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/SessionContext.java
create mode 100644
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/DefaultContext.java
create mode 100644
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/ExecutionContext.java
create mode 100644
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/LegacyTableEnvironmentInitializer.java
create mode 100644
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/SessionContext.java
delete mode 100644
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
create mode 100644
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalContextUtils.java
delete mode 100644
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ProgramDeployer.java
rename
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/{local
=> context}/ExecutionContextTest.java (88%)
create mode 100644
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/context/SessionContextTest.java
