[flink] branch master updated (da16f9e -> 32b79d1)

[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 da16f9e  [FLINK-16624][k8s] Support user-specified annotations for the rest Service
     add 32b79d1  [FLINK-17748][table] Remove registration of TableSource/TableSink in table env

No new revisions were added by this update.

Summary of changes:
 .../cassandra/CassandraConnectorITCase.java        |   3 +-
 .../connector/hbase/source/HBaseTableSource.java   |   2 +-
 .../connector/hbase/HBaseConnectorITCase.java      |  15 +--
 .../flink/sql/tests/BatchSQLTestProgram.java       |   7 +-
 .../flink/sql/tests/StreamSQLTestProgram.java      |   5 +-
 .../apache/flink/table/tpcds/TpcdsTestProgram.java |   3 +-
 .../java/org/apache/flink/orc/OrcTableSource.java  |   2 +-
 .../org/apache/flink/orc/OrcTableSourceITCase.java |   5 +-
 .../flink/formats/parquet/ParquetTableSource.java  |   2 +-
 .../formats/parquet/ParquetTableSourceITCase.java  |   5 +-
 flink-python/pyflink/table/table_environment.py    |   4 +-
 .../client/gateway/local/ExecutionContext.java     |   5 +-
 .../table/client/gateway/local/LocalExecutor.java  |   3 +-
 .../client/gateway/local/ExecutionContextTest.java |   2 +-
 .../apache/flink/table/api/TableEnvironment.java   |  52 +----------
 .../table/api/internal/TableEnvironmentImpl.java   |  33 +------
 .../api/internal/TableEnvironmentInternal.java     |  31 ++++++-
 .../table/descriptors/ConnectTableDescriptor.java  |   2 +-
 .../flink/table/api/TableEnvironmentITCase.scala   |   7 +-
 .../apache/flink/table/api/batch/ExplainTest.scala |   6 +-
 .../flink/table/api/stream/ExplainTest.scala       |  16 ++--
 .../plan/batch/sql/DagOptimizationTest.scala       |  58 ++++++------
 .../planner/plan/batch/sql/LegacySinkTest.scala    |   6 +-
 .../planner/plan/batch/sql/TableSourceTest.scala   |   6 +-
 ...hProjectIntoLegacyTableSourceScanRuleTest.scala |   4 +-
 .../plan/stream/sql/DagOptimizationTest.scala      | 101 ++++++++++++++-------
 .../planner/plan/stream/sql/LegacySinkTest.scala   |  29 ++++--
 .../stream/sql/MiniBatchIntervalInferTest.scala    |  11 ++-
 .../planner/plan/stream/sql/TableSourceTest.scala  |  25 ++---
 .../plan/stream/table/TableSourceTest.scala        |  26 +++---
 .../validation/LegacyTableSinkValidationTest.scala |   4 +-
 .../runtime/batch/sql/TableScanITCase.scala        |   8 +-
 .../runtime/batch/sql/TableSourceITCase.scala      |   8 +-
 .../batch/sql/agg/AggregateITCaseBase.scala        |   2 +-
 .../runtime/batch/sql/join/JoinITCase.scala        |   6 +-
 .../batch/table/LegacyTableSinkITCase.scala        |  10 +-
 .../runtime/stream/sql/AggregateITCase.scala       |   6 +-
 .../planner/runtime/stream/sql/CalcITCase.scala    |   4 +-
 .../runtime/stream/sql/CorrelateITCase.scala       |  18 ++--
 .../runtime/stream/sql/Limit0RemoveITCase.scala    |  18 ++--
 .../planner/runtime/stream/sql/RankITCase.scala    |  40 ++++----
 .../runtime/stream/sql/TableScanITCase.scala       |  10 +-
 .../runtime/stream/sql/TableSourceITCase.scala     |  18 ++--
 .../planner/runtime/stream/sql/UnnestITCase.scala  |   4 +-
 .../runtime/stream/sql/WindowAggregateITCase.scala |   6 +-
 .../runtime/stream/table/AggregateITCase.scala     |   4 +-
 .../planner/runtime/stream/table/JoinITCase.scala  |  14 +--
 .../stream/table/LegacyTableSinkITCase.scala       |  28 +++---
 .../planner/runtime/utils/BatchTableEnvUtil.scala  |   5 +-
 .../flink/table/planner/utils/TableTestBase.scala  |  15 ++-
 .../flink/table/api/internal/TableEnvImpl.scala    |  49 ++--------
 .../table/runtime/batch/JavaTableSourceITCase.java |   5 +-
 .../flink/table/api/TableEnvironmentITCase.scala   |  32 ++++---
 .../org/apache/flink/table/api/TableITCase.scala   |   8 +-
 .../apache/flink/table/api/TableSourceTest.scala   |  51 +++++++----
 .../apache/flink/table/api/batch/ExplainTest.scala |  17 ++--
 .../sql/validation/InsertIntoValidationTest.scala  |  14 ++-
 .../validation/InsertIntoValidationTest.scala      |   7 +-
 .../flink/table/api/stream/ExplainTest.scala       |  17 ++--
 .../sql/validation/InsertIntoValidationTest.scala  |  11 ++-
 .../table/api/stream/table/TableSourceTest.scala   |  25 ++---
 .../validation/InsertIntoValidationTest.scala      |   8 +-
 .../table/validation/TableSinkValidationTest.scala |  10 +-
 .../validation/TableSourceValidationTest.scala     |   6 +-
 .../api/validation/TableSinksValidationTest.scala  |   8 +-
 .../api/validation/TableSourceValidationTest.scala |  26 +++---
 .../batch/sql/PartitionableSinkITCase.scala        |   7 +-
 .../runtime/batch/sql/TableEnvironmentITCase.scala |  47 ++++++----
 .../runtime/batch/sql/TableSourceITCase.scala      |   8 +-
 .../batch/table/TableEnvironmentITCase.scala       |   4 +-
 .../runtime/batch/table/TableSinkITCase.scala      |   7 +-
 .../runtime/batch/table/TableSourceITCase.scala    |  49 +++++-----
 .../runtime/stream/TimeAttributesITCase.scala      |   9 +-
 .../runtime/stream/sql/InsertIntoITCase.scala      |  19 ++--
 .../table/runtime/stream/sql/SortITCase.scala      |   5 +-
 .../flink/table/runtime/stream/sql/SqlITCase.scala |   6 +-
 .../runtime/stream/sql/TableSourceITCase.scala     |   4 +-
 .../runtime/stream/table/AggregateITCase.scala     |   4 +-
 .../table/runtime/stream/table/JoinITCase.scala    |   6 +-
 .../runtime/stream/table/TableSinkITCase.scala     |  27 +++---
 .../runtime/stream/table/TableSourceITCase.scala   |  44 ++++-----
 .../flink/table/utils/MockTableEnvironment.scala   |   9 --
 .../src/main/scala/SpendReport.scala               |   6 +-
 83 files changed, 659 insertions(+), 600 deletions(-)