[flink-table-store] branch master updated: [FLINK-29063] Fix FileFormatTest read the same value from file twice

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


The following commit(s) were added to refs/heads/master by this push:
     new 3e444561 [FLINK-29063] Fix FileFormatTest read the same value from 
file twice
3e444561 is described below

commit 3e4445611c97fde9b796f5be46385f945998f1c3
Author: Kirill Listopad <kiril.ls...@gmail.com>
AuthorDate: Tue Aug 23 11:50:53 2022 +0300

    [FLINK-29063] Fix FileFormatTest read the same value from file twice
    
    This closes #272
---
 .../java/org/apache/flink/table/store/file/FileFormatTest.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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 e096cf00..32f2a12e 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 @@ public class FileFormatTest {
         // 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 @@ public class FileFormatTest {
         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);
     }