You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gu...@apache.org on 2023/05/16 12:37:53 UTC
[flink] branch master updated (354c0f455b9 -> ce286c969a5)

This is an automated email from the ASF dual-hosted git repository.

guoweijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 354c0f455b9 [FLINK-31963][state] Fix rescaling bug in recovery from unaligned checkpoints. (#22584)
     add a8c757081c6 [FLINK-32060][test] Introduce NoOpTestExtension to make subclass unaware of @TestTemplate
     add ce286c969a5 [FLINK-32060][test] Migrate subclasses of BatchAbstractTestBase in table and other modules to JUnit5

No new revisions were added by this update.

Summary of changes:
 .../flink/formats/avro/AvroFilesystemITCase.java   |  16 ++--
 .../formats/csv/CsvFilesystemBatchITCase.java      |  23 +++--
 .../formats/csv/CsvFilesystemStreamITCase.java     |   2 +-
 .../formats/json/JsonBatchFileSystemITCase.java    |  20 ++--
 .../org/apache/flink/orc/OrcFileSystemITCase.java  |  41 ++++----
 .../formats/parquet/ParquetFileSystemITCase.java   |  25 ++---
 ...acyRowResource.java => LegacyRowExtension.java} |  16 +---
 .../planner/runtime/FileSystemITCaseBase.scala     | 106 +++++++++------------
 .../batch/sql/BatchFileSystemITCaseBase.scala      |   6 +-
 .../batch/sql/FileSystemTestCsvITCase.scala        |  16 ++--
 .../runtime/batch/table/AggregationITCase.scala    |  10 +-
 .../planner/runtime/batch/table/CalcITCase.scala   |  51 +++++-----
 .../runtime/batch/table/CorrelateITCase.scala      |  35 ++++---
 .../runtime/batch/table/GroupWindowITCase.scala    |  54 +++++++----
 .../planner/runtime/batch/table/JoinITCase.scala   |  12 ++-
 .../runtime/batch/table/LegacyLimitITCase.scala    |  12 +--
 .../batch/table/LegacyTableSinkITCase.scala        |  20 ++--
 .../planner/runtime/batch/table/LimitITCase.scala  |   4 +-
 .../runtime/batch/table/OverAggregateITCase.scala  |   6 +-
 .../runtime/batch/table/SetOperatorsITCase.scala   |  19 ++--
 .../planner/runtime/batch/table/SortITCase.scala   |  12 ++-
 .../runtime/batch/table/TableSinkITCase.scala      |  65 +++++++------
 .../stream/sql/StreamFileSystemITCaseBase.scala    |  14 +--
 .../stream/sql/StreamFileSystemTestCsvITCase.scala |  15 ++-
 .../parameterized/NoOpTestExtension.java           |  56 +++++++++++
 25 files changed, 365 insertions(+), 291 deletions(-)
 copy flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/{LegacyRowResource.java => LegacyRowExtension.java} (79%)
 create mode 100644 flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/extensions/parameterized/NoOpTestExtension.java