This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8405bef [hotfix][python] Change "flink-python-" to "flink-python" for
the change of artifact of flink-python module (#9270)
new c871c7c [hotfix][table-api-java] Improve documentation of
withBuiltinCatalogName & withBuiltinDatabaseName
new 33cc293 [hotfix][table] Unify default catalog & builtin catalog naming
new abb5dfa [FLINK-13350][table-api-java] Annotate useCatalog &
useDatabase with experimental annotation
new 1b27f16 [hotfix][table-common] Fix logging in the table source
validation procedure
new 9b1d781 [FLINK-13279][table-sql-client] Fully qualify sink name in
sql-client
new 19e7c5c [hotfix][sql-client] Add USE CATALOG/USE to CLI help
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/flink/annotation/Experimental.java | 2 +-
.../apache/flink/table/client/cli/CliClient.java | 2 +-
.../apache/flink/table/client/cli/CliStrings.java | 20 ++--
.../flink/table/client/cli/SqlCommandParser.java | 2 +-
.../client/gateway/local/ExecutionContext.java | 28 ++---
.../table/client/gateway/local/LocalExecutor.java | 7 +-
.../table/client/cli/SqlCommandParserTest.java | 2 +-
.../client/gateway/local/LocalExecutorITCase.java | 23 +++-
.../client/gateway/utils/SimpleCatalogFactory.java | 118 +++++++++++++++++++++
.../org.apache.flink.table.factories.TableFactory | 1 +
.../test/resources/test-sql-client-defaults.yaml | 3 +
.../flink/table/api/EnvironmentSettings.java | 29 ++++-
.../java/org/apache/flink/table/api/Table.java | 2 +-
.../apache/flink/table/api/TableEnvironment.java | 3 +
.../table/api/internal/TableEnvironmentImpl.java | 21 ++--
.../apache/flink/table/catalog/CatalogManager.java | 28 +++--
.../flink/table/catalog/FunctionCatalog.java | 13 ++-
.../table/api/scala/BatchTableEnvironment.scala | 4 +-
.../flink/table/sources/TableSourceValidation.java | 6 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 5 +-
.../flink/table/api/internal/TableEnvImpl.scala | 27 ++---
.../nodes/datastream/StreamTableSourceScan.scala | 2 +-
22 files changed, 266 insertions(+), 82 deletions(-)
create mode 100644
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/utils/SimpleCatalogFactory.java
