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