This is an automated email from the ASF dual-hosted git repository. MartijnVisser pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7b4517ae36737a5296599d981ec49077803f3229 Author: Martijn Visser <[email protected]> AuthorDate: Mon Oct 12 14:01:24 2026 +0100 [hotfix][parquet] Use AssertJ in ParquetTimestampITCase Generated-by: Claude Code (Claude Opus 5.5) --- .../apache/flink/formats/parquet/ParquetTimestampITCase.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java b/flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java index 515d00e0c00..a40e104d4b5 100644 --- a/flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java +++ b/flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java @@ -55,7 +55,7 @@ import static org.apache.flink.connector.file.table.FileSystemConnectorOptions.S import static org.apache.flink.formats.parquet.ParquetFileFormatFactory.TIMESTAMP_TIME_UNIT; import static org.apache.flink.formats.parquet.ParquetFileFormatFactory.UTC_TIMEZONE; import static org.apache.flink.formats.parquet.ParquetFileFormatFactory.WRITE_INT64_TIMESTAMP; -import static org.junit.Assert.assertEquals; +import static org.assertj.core.api.Assertions.assertThat; /** Test int64 timestamp. */ @ExtendWith(ParameterizedTestExtension.class) @@ -257,11 +257,12 @@ public class ParquetTimestampITCase extends FsStreamingSinkITCaseBase { public void check(String sqlQuery, Seq<Row> expectedResult) { List<Row> result = CollectionUtil.iteratorToList(tEnv().sqlQuery(sqlQuery).execute().collect()); - assertEquals( + List<String> expected = JavaScalaConversionUtil.toJava(expectedResult).stream() .map(row -> TestSinkUtil.rowToString(row, TimeZone.getTimeZone("UTC"))) .sorted() - .collect(Collectors.toList()), + .collect(Collectors.toList()); + List<String> actual = result.stream() .map( row -> { @@ -271,6 +272,7 @@ public class ParquetTimestampITCase extends FsStreamingSinkITCaseBase { row, TimeZone.getTimeZone("UTC")); }) .sorted() - .collect(Collectors.toList())); + .collect(Collectors.toList()); + assertThat(actual).isEqualTo(expected); } }
