[iceberg] branch master updated: Flink: fix compiling error from PR #6753 (#6953)

[stevenwu]

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

stevenwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/master by this push:
     new baceaf8b75 Flink: fix compiling error from PR #6753 (#6953)
baceaf8b75 is described below

commit baceaf8b75e9e610eb64c872cb82e02d1085f2fc
Author: Steven Zhen Wu <stevenz...@gmail.com>
AuthorDate: Mon Feb 27 20:13:40 2023 -0800

    Flink: fix compiling error from PR #6753 (#6953)
---
 .../java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
 
b/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
index b28af0706b..6552fe834c 100644
--- 
a/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
+++ 
b/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
@@ -18,6 +18,7 @@
  */
 package org.apache.iceberg.flink.sink;
 
+import java.util.List;
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.test.util.MiniClusterWithClientResource;
@@ -27,6 +28,7 @@ import org.apache.iceberg.FileFormat;
 import org.apache.iceberg.PartitionSpec;
 import org.apache.iceberg.SnapshotRef;
 import org.apache.iceberg.TableProperties;
+import org.apache.iceberg.data.Record;
 import org.apache.iceberg.flink.HadoopCatalogResource;
 import org.apache.iceberg.flink.MiniClusterResource;
 import org.apache.iceberg.flink.SimpleDataUtil;
@@ -170,7 +172,8 @@ public class TestFlinkIcebergSinkV2 extends 
TestFlinkIcebergSinkV2Base {
         row -> row.getField(ROW_DATA_POS),
         true,
         elementsPerCheckpoint,
-        expectedRecords);
+        expectedRecords,
+        SnapshotRef.MAIN_BRANCH);
   }
 
   @Test