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(-)