[flink] branch master updated (7cfcd33 -> 2160c32)

[ku...@apache.org]

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