This is an automated email from the ASF dual-hosted git repository.
kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7cfcd33 [FLINK-17608][web] Add TM log and stdout page/tab back
add 2160c32 [FLINK-17252][table] Add Table#execute api and support SELECT
statement in TableEnvironment#executeSql
No new revisions were added by this update.
Summary of changes:
.../flink/connectors/hive/HiveTableSourceTest.java | 30 ++--
.../connectors/hive/TableEnvHiveConnectorTest.java | 47 +++---
.../table/catalog/hive/HiveCatalogITCase.java | 9 +-
.../catalog/hive/HiveCatalogUseBlinkITCase.java | 9 +-
.../flink/table/module/hive/HiveModuleTest.java | 23 ++-
.../io/jdbc/catalog/PostgresCatalogITCase.java | 27 ++--
flink-python/pyflink/table/table.py | 15 ++
flink-python/pyflink/table/table_environment.py | 1 +
flink-python/pyflink/table/tests/test_table_api.py | 52 +++++++
.../java/org/apache/flink/table/api/Table.java | 15 +-
.../apache/flink/table/api/TableEnvironment.java | 2 +-
.../flink/table/api/internal/SelectTableSink.java | 37 +++--
.../table/api/internal/TableEnvironmentImpl.java | 32 +++-
.../api/internal/TableEnvironmentInternal.java | 9 ++
.../apache/flink/table/api/internal/TableImpl.java | 5 +
.../flink/table/api/internal/TableResultImpl.java | 65 +++++---
.../org/apache/flink/table/delegation/Planner.java | 12 +-
.../org/apache/flink/table/utils/PlannerMock.java | 7 +
.../org/apache/flink/table/utils/PrintUtils.java | 34 ++++-
.../org/apache/flink/table/api/TableUtils.java | 165 ---------------------
.../table/planner/sinks/BatchSelectTableSink.java | 112 ++++++++++++++
.../sinks/SelectTableSinkSchemaConverter.java | 61 ++++++++
.../table/planner/sinks/StreamSelectTableSink.java | 94 ++++++++++++
.../table/planner/delegation/BatchPlanner.scala | 8 +-
.../table/planner/delegation/StreamPlanner.scala | 8 +-
.../flink/table/api/TableUtilsBatchITCase.java | 66 ---------
.../flink/table/api/TableUtilsStreamingITCase.java | 75 ----------
.../flink/table/api/TableEnvironmentITCase.scala | 81 +++++++++-
.../flink/table/api/TableEnvironmentTest.scala | 10 --
.../org/apache/flink/table/api/TableITCase.scala | 128 ++++++++++++++++
.../runtime/batch/sql/join/ScalarQueryITCase.scala | 4 +-
.../runtime/stream/FsStreamingSinkITCaseBase.scala | 6 +-
.../planner/runtime/utils/BatchTestBase.scala | 4 +-
.../flink/table/sinks/BatchSelectTableSink.java | 105 +++++++++++++
.../sinks/SelectTableSinkSchemaConverter.java | 56 +++++++
.../flink/table/sinks/StreamSelectTableSink.java | 86 +++++++++++
.../flink/table/api/internal/TableEnvImpl.scala | 32 +++-
.../apache/flink/table/planner/StreamPlanner.scala | 5 +
.../flink/table/api/TableEnvironmentITCase.scala | 77 +++++++++-
.../org/apache/flink/table/api/TableITCase.scala | 120 +++++++++++++++
.../api/batch/BatchTableEnvironmentTest.scala | 11 --
.../runtime/batch/sql/TableEnvironmentITCase.scala | 33 ++++-
.../table/runtime/batch/table/TableITCase.scala | 65 ++++++++
.../streaming/util/TestStreamEnvironment.java | 4 +
44 files changed, 1392 insertions(+), 455 deletions(-)
create mode 100644 flink-python/pyflink/table/tests/test_table_api.py
copy
flink-core/src/main/java/org/apache/flink/api/common/operators/UnaryOperatorInformation.java
=>
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/SelectTableSink.java
(53%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/api/TableUtils.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/BatchSelectTableSink.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/SelectTableSinkSchemaConverter.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/StreamSelectTableSink.java
delete mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/api/TableUtilsBatchITCase.java
delete mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/api/TableUtilsStreamingITCase.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableITCase.scala
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sinks/BatchSelectTableSink.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sinks/SelectTableSinkSchemaConverter.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sinks/StreamSelectTableSink.java
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableITCase.scala
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/runtime/batch/table/TableITCase.scala
