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