You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2019/11/14 03:56:31 UTC
[flink] branch master updated (4ba7b4d -> 8466134)
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 4ba7b4d [FLINK-14706] Remove legacy KvStateMessage
add 26faddd [FLINK-14723][table-planner-blink] Add tests for partial qualified UDF calls as computed columns
add 827477c [FLINK-14723][table-planner-blink] Remove result assertion in test CatalogTableITCase#testInsertSinkTableWithUnmatchedFields
add 095c4d4 [FLINK-14723][table-planner-blink] Java(Scala)DataStreamQueryOperation should remember the registered object path
add 8466134 [FLINK-14723][table-planner-blink] Use ObjectIdentifier in DataStreamQueryOperations
No new revisions were added by this update.
Summary of changes:
.../java/internal/StreamTableEnvironmentImpl.java | 17 +++++++++
.../operations/JavaDataStreamQueryOperation.java | 32 +++++++++++++++-
.../table/api/internal/TableEnvironmentImpl.java | 15 +++++++-
.../operations/ScalaDataStreamQueryOperation.java | 31 +++++++++++++++-
.../internal/StreamTableEnvironmentImpl.scala | 20 ++++++++--
.../flink/table/catalog/ObjectIdentifier.java | 7 ++++
.../planner/catalog/DatabaseCalciteSchema.java | 19 ++--------
.../operations/DataStreamQueryOperation.java | 33 ++++++-----------
.../operations/RichTableSourceQueryOperation.java | 14 +++----
.../planner/plan/QueryOperationConverter.java | 43 +++++++++++++++++-----
.../operations/SqlToOperationConverterTest.java | 29 ++++++++++++---
.../table/planner/catalog/CatalogTableITCase.scala | 10 +----
.../planner/plan/utils/FlinkRelOptUtilTest.scala | 22 +++++------
.../flink/table/planner/utils/TableTestBase.scala | 12 +++++-
14 files changed, 214 insertions(+), 90 deletions(-)