This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from fa46073 [FLINK-17765] Remove uncheckedSupplier from
Dispatcher.createJobManagerRunner
add 8a8d8a9 [FLINK-17753] [table-planner-blink] Fix watermark defined in
ddl does not work in Table api
add d27c888 [FLINK-18061] [table] TableResult#collect method should
return a closeable iterator to avoid resource leak
add 3057927 [FLINK-18195] Remove references to
Expressions.interval(Duration) from (java)docs
add bed750f [FLINK-18208] Fix flink ES connector typos
No new revisions were added by this update.
Summary of changes:
docs/dev/table/streaming/time_attributes.md | 8 +-
docs/dev/table/streaming/time_attributes.zh.md | 8 +-
docs/dev/table/tableApi.md | 34 +++---
docs/dev/table/tableApi.zh.md | 34 +++---
.../table/Elasticsearch6DynamicSink.java | 4 +-
.../table/Elasticsearch7DynamicSinkFactory.java | 14 +--
.../table/catalog/hive/HiveCatalogITCase.java | 32 +++++-
flink-python/pyflink/table/table_result.py | 49 +++++++++
.../operators/collect/CollectResultIterator.java | 4 +-
.../table/client/gateway/local/LocalExecutor.java | 6 ++
.../org/apache/flink/table/api/Expressions.java | 5 +-
.../org/apache/flink/table/api/TableResult.java | 76 ++++++++++++-
.../api/internal/CatalogTableSchemaResolver.java | 118 +++++++++++++++++++++
.../table/api/internal/SelectResultProvider.java | 5 +-
.../table/api/internal/TableEnvironmentImpl.java | 7 +-
.../flink/table/api/internal/TableResultImpl.java | 13 +--
.../apache/flink/table/catalog/CatalogManager.java | 34 +++++-
.../flink/table/catalog/CatalogTableImpl.java | 8 ++
.../org/apache/flink/table/delegation/Parser.java | 12 +++
.../org/apache/flink/table/utils/ParserMock.java | 7 ++
.../planner/catalog/CatalogCalciteSchema.java | 9 +-
.../catalog/CatalogManagerCalciteSchema.java | 8 +-
.../table/planner/catalog/CatalogSchemaTable.java | 11 +-
.../planner/catalog/DatabaseCalciteSchema.java | 7 --
.../flink/table/planner/delegation/ParserImpl.java | 22 +++-
.../table/planner/sinks/SelectTableSinkBase.java | 6 +-
.../table/planner/delegation/PlannerBase.scala | 28 ++---
.../table/planner/sources/TableSourceUtil.scala | 99 ++++++-----------
.../operations/SqlToOperationConverterTest.java | 26 +++--
.../plan/FlinkCalciteCatalogReaderTest.java | 17 +--
.../flink/table/planner/utils/PlannerMocks.java | 38 ++++---
.../planner/plan/stream/sql/TableSourceTest.xml | 104 +++++++++---------
.../plan/stream/table/LegacyTableSourceTest.xml | 72 ++++++++++---
.../planner/plan/stream/table/TableSourceTest.xml | 118 ++++++++++++++-------
.../flink/table/api/TableEnvironmentTest.scala | 2 +-
.../org/apache/flink/table/api/TableITCase.scala | 22 +++-
.../codegen/WatermarkGeneratorCodeGenTest.scala | 30 +++++-
.../planner/plan/stream/sql/TableSourceTest.scala | 48 ++-------
.../plan/stream/table/LegacyTableSourceTest.scala | 3 +
.../plan/stream/table/TableSourceTest.scala | 47 +++-----
.../org/apache/flink/table/planner/ParserImpl.java | 7 ++
.../flink/table/sinks/BatchSelectTableSink.java | 8 +-
.../flink/table/sinks/StreamSelectTableSink.java | 6 +-
.../flink/table/api/internal/TableEnvImpl.scala | 2 +
.../flink/table/catalog/CatalogManagerTest.java | 3 +
.../table/catalog/DatabaseCalciteSchemaTest.java | 11 +-
.../table/sqlexec/SqlToOperationConverterTest.java | 3 +
47 files changed, 817 insertions(+), 418 deletions(-)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/CatalogTableSchemaResolver.java
