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 cbaea29 Partial Revert "[FLINK-15669] [sql-client] Fix SQL client
can't cancel flink job"
new f0a4b09 [FLINK-17339][table-api] Change default planner to blink
new 04c52f8 [FLINK-17339][table-planner] Update test cases due to default
planner change.
new 2421f94 [FLINK-17339][sql-client] Change default planner to blink.
new cb523d3 [FLINK-17339][table-planner-blink] Simplify test cases due to
default planner changing.
new aa4e1d6 [FLINK-17339][examples] Update examples due to default
planner changing.
new a9f8a0b [FLINK-17339][misc] Update tests due to default planner
changing.
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-connectors/flink-connector-cassandra/pom.xml | 2 +-
.../flink/sql/tests/StreamSQLTestProgram.java | 2 +-
.../table/examples/java/StreamSQLExample.java | 14 +-
.../examples/java/StreamWindowSQLExample.java | 10 +-
.../table/examples/scala/StreamSQLExample.scala | 14 +-
.../org/apache/flink/ml/common/MLEnvironment.java | 5 +-
.../apache/flink/ml/common/MLEnvironmentTest.java | 4 +-
.../table/tests/test_environment_settings.py | 4 +-
.../table/tests/test_table_environment_api.py | 6 +-
flink-python/pyflink/testing/test_case_utils.py | 8 +-
.../org/apache/flink/api/scala/FlinkILoop.scala | 5 +-
.../client/config/entries/ExecutionEntry.java | 6 +-
.../flink/table/api/EnvironmentSettings.java | 18 +--
.../apache/flink/table/api/EnvironmentTest.java | 4 +-
.../flink/table/api/TableUtilsStreamingITCase.java | 2 +-
.../planner/catalog/CatalogConstraintTest.java | 2 +-
.../flink/table/planner/catalog/CatalogITCase.java | 2 +-
.../planner/catalog/CatalogStatisticsTest.java | 2 +-
.../flink/table/api/TableEnvironmentITCase.scala | 4 +-
.../flink/table/api/TableEnvironmentTest.scala | 2 +-
.../table/planner/catalog/CatalogTableITCase.scala | 4 +-
.../table/planner/catalog/CatalogTableTest.scala | 2 +-
.../table/planner/catalog/CatalogViewITCase.scala | 4 +-
.../table/planner/codegen/agg/AggTestBase.scala | 4 +-
.../expressions/utils/ExpressionTestBase.scala | 3 +-
.../table/validation/JoinValidationTest.scala | 4 +-
.../validation/SetOperatorsValidationTest.scala | 6 +-
.../planner/plan/utils/FlinkRelOptUtilTest.scala | 2 +-
.../harness/GroupAggregateHarnessTest.scala | 2 +-
.../runtime/harness/OverWindowHarnessTest.scala | 2 +-
.../harness/TableAggregateHarnessTest.scala | 2 +-
.../planner/runtime/utils/BatchTestBase.scala | 2 +-
.../planner/runtime/utils/StreamingTestBase.scala | 2 +-
.../flink/table/planner/utils/TableTestBase.scala | 11 +-
.../table/api/StreamTableEnvironmentTest.java | 3 +-
.../table/runtime/stream/sql/FunctionITCase.java | 8 +-
.../table/runtime/stream/sql/JavaSqlITCase.java | 13 +-
.../table/runtime/stream/table/FunctionITCase.java | 9 +-
.../table/runtime/stream/table/ValuesITCase.java | 5 +-
.../flink/table/api/stream/ExplainTest.scala | 9 +-
.../api/stream/StreamTableEnvironmentTest.scala | 5 +-
.../StreamTableEnvironmentValidationTest.scala | 7 +-
.../sql/validation/InsertIntoValidationTest.scala | 16 +--
.../validation/InsertIntoValidationTest.scala | 9 +-
.../table/validation/JoinValidationTest.scala | 16 ++-
.../validation/SetOperatorsValidationTest.scala | 14 +-
.../validation/UnsupportedOpsValidationTest.scala | 25 +---
.../api/validation/TableSourceValidationTest.scala | 59 +--------
.../flink/table/catalog/CatalogTableITCase.scala | 8 +-
.../table/match/PatternTranslatorTestBase.scala | 5 +-
.../runtime/harness/AggFunctionHarnessTest.scala | 9 +-
.../harness/GroupAggregateHarnessTest.scala | 18 ++-
.../table/runtime/harness/MatchHarnessTest.scala | 6 +-
.../harness/TableAggregateHarnessTest.scala | 21 ++-
.../runtime/stream/TimeAttributesITCase.scala | 115 +++-------------
.../runtime/stream/sql/InsertIntoITCase.scala | 49 ++-----
.../table/runtime/stream/sql/JoinITCase.scala | 120 +++++++++--------
.../runtime/stream/sql/MatchRecognizeITCase.scala | 81 +++++-------
.../runtime/stream/sql/OverWindowITCase.scala | 146 +++------------------
.../runtime/stream/sql/SetOperatorsITCase.scala | 12 +-
.../table/runtime/stream/sql/SortITCase.scala | 9 +-
.../flink/table/runtime/stream/sql/SqlITCase.scala | 142 ++++++++++----------
.../runtime/stream/sql/TableSourceITCase.scala | 7 +-
.../runtime/stream/sql/TemporalJoinITCase.scala | 19 ++-
.../runtime/stream/table/AggregateITCase.scala | 91 +++----------
.../table/runtime/stream/table/CalcITCase.scala | 82 +-----------
.../runtime/stream/table/CorrelateITCase.scala | 11 +-
.../runtime/stream/table/GroupWindowITCase.scala | 62 +++++----
.../table/GroupWindowTableAggregateITCase.scala | 59 +++++----
.../table/runtime/stream/table/JoinITCase.scala | 128 +++---------------
.../runtime/stream/table/OverWindowITCase.scala | 40 +++---
.../runtime/stream/table/RetractionITCase.scala | 42 +++---
.../runtime/stream/table/SetOperatorsITCase.scala | 42 ++----
.../stream/table/TableAggregateITCase.scala | 30 +++--
.../runtime/stream/table/TableSinkITCase.scala | 92 +++----------
.../runtime/stream/table/TableSourceITCase.scala | 100 +++++++-------
76 files changed, 698 insertions(+), 1212 deletions(-)
