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 29ca0ad8e33 [FLINK-28851][hive] Allow to GetTypeInfo in the
HiveServer2 Endpoint
add c5c66af680e [FLINK-27790][table] Port ADD JAR & SHOW JARS syntax
implementation from SqlClient to TableEnvironment side
add 823611b1d4d [FLINK-27790][table] Revert changes to AddJarOperation
add d19a0a7b650 [FLINK-27790][table] Fix test failure in set.q and
function.q of SQL Client
add fe9c726ac1a [FLINK-27790][table] Fix NoClassDefFoundError of guava in
UsingRemoteJarITCase
No new revisions were added by this update.
Summary of changes:
.../flink/tests/util/flink/FlinkDistribution.java | 1 +
.../flink-end-to-end-tests-sql/pom.xml | 118 ++++++++++++-
.../table/sql/codegen/PlannerScalaFreeITCase.java | 195 +++------------------
...nnerScalaFreeITCase.java => SqlITCaseBase.java} | 129 ++++++--------
.../table/sql/codegen/UsingRemoteJarITCase.java | 162 +++++++++++++++++
.../{scala_free_e2e.sql => remote_jar_e2e.sql} | 5 +-
.../apache/flink/table/client/cli/CliClient.java | 24 ---
.../apache/flink/table/client/cli/CliStrings.java | 3 -
.../flink/table/client/gateway/Executor.java | 6 -
.../client/gateway/context/SessionContext.java | 60 +------
.../table/client/gateway/local/LocalExecutor.java | 12 --
.../client/resource/ClientResourceManager.java | 13 +-
.../flink/table/client/cli/CliClientITCase.java | 9 +-
.../flink/table/client/cli/CliClientTest.java | 10 --
.../flink/table/client/cli/CliResultViewTest.java | 10 --
.../flink/table/client/cli/TestingExecutor.java | 10 --
.../client/gateway/context/SessionContextTest.java | 64 ++-----
.../src/test/resources/sql/function.q | 16 +-
.../flink-sql-client/src/test/resources/sql/set.q | 25 ++-
.../table/api/internal/TableEnvironmentImpl.java | 28 +++
.../flink/table/resource/ResourceManager.java | 49 +++---
.../flink/table/resource/ResourceManagerTest.java | 5 +-
.../planner/runtime/batch/sql/FunctionITCase.java | 18 ++
.../planner/runtime/stream/sql/FunctionITCase.java | 19 ++
.../flink/table/api/TableEnvironmentTest.scala | 54 +++++-
.../apache/flink/test/util/SQLJobSubmission.java | 23 ++-
26 files changed, 600 insertions(+), 468 deletions(-)
copy
flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/{PlannerScalaFreeITCase.java
=> SqlITCaseBase.java} (53%)
create mode 100644
flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/UsingRemoteJarITCase.java
copy
flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/resources/{scala_free_e2e.sql
=> remote_jar_e2e.sql} (91%)
