commit 287fe32f652780f116b7c1084f8b362ed56cfacb
author Kirill Listopad <kiril.lstpd@gmail.com> Tue Aug 23 11:50:53 2022 +0300
committer JingsongLi <lzljs3620320@aliyun.com> Tue Aug 23 16:51:40 2022 +0800
tree cc55832e82be441fd29067bcdc5e9b0b96b17fed
parent aa85abe38963796904c77dd5062ee84d569bf9a2

[FLINK-29063] Fix FileFormatTest read the same value from file twice

This closes #272

flink-table-store-core/src/test/java/org/apache/flink/table/store/file/FileFormatTest.java

diff --git a/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/FileFormatTest.java b/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/FileFormatTest.java
index e096cf0..32f2a12 100644
--- a/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/FileFormatTest.java
+++ b/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/FileFormatTest.java
@@ -57,9 +57,9 @@
         // write
 
         List<RowData> expected = new ArrayList<>();
-        expected.add(GenericRowData.of(1, 1));
-        expected.add(GenericRowData.of(2, 2));
-        expected.add(GenericRowData.of(3, 3));
+        expected.add(GenericRowData.of(1, 11));
+        expected.add(GenericRowData.of(2, 22));
+        expected.add(GenericRowData.of(3, 33));
         FSDataOutputStream out = fs.create(path, FileSystem.WriteMode.NO_OVERWRITE);
         BulkWriter<RowData> writer = avro.createWriterFactory(rowType).create(out);
         for (RowData row : expected) {
@@ -77,7 +77,7 @@
         List<RowData> result = new ArrayList<>();
         Utils.forEachRemaining(
                 reader,
-                rowData -> result.add(GenericRowData.of(rowData.getInt(0), rowData.getInt(0))));
+                rowData -> result.add(GenericRowData.of(rowData.getInt(0), rowData.getInt(1))));
 
         assertThat(result).isEqualTo(expected);
     }