You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2020/12/21 18:16:20 UTC

[iceberg] branch master updated: Flink: Fix missing List parameter in tests (#1970)

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

blue 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 9f6e947  Flink: Fix missing List parameter in tests (#1970)
9f6e947 is described below

commit 9f6e94743017b88a2e65ead4cde38ff3e234ae8e
Author: Harold Miao <mi...@miaohong.org>
AuthorDate: Tue Dec 22 02:16:10 2020 +0800

    Flink: Fix missing List parameter in tests (#1970)
---
 flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSource.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSource.java b/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSource.java
index cb63148..1ed4f7b 100644
--- a/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSource.java
+++ b/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSource.java
@@ -92,7 +92,7 @@ public class TestFlinkTableSource extends FlinkCatalogTestBase {
     String sqlLimitExceed = String.format("SELECT * FROM %s LIMIT 3", TABLE_NAME);
     List<Object[]> resultExceed = sql(sqlLimitExceed);
     Assert.assertEquals("should have 2 record", 2, resultExceed.size());
-    List expectedList = Lists.newArrayList();
+    List<Object[]> expectedList = Lists.newArrayList();
     expectedList.add(new Object[] {1, "a"});
     expectedList.add(new Object[] {2, "b"});
     Assert.assertArrayEquals("Should produce the expected records", resultExceed.toArray(), expectedList.toArray());