This is an automated email from the ASF dual-hosted git repository. snuyanzin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-hive.git
commit 84a16e1ba1d13df26918742724c2b3b3f0667fa1 Author: Wenchao Wu <[email protected]> AuthorDate: Sun Jun 30 19:38:46 2024 +0800 [FLINK-35702][parquet] support parquet read nested in nested (#24991) --- .../flink/connectors/hive/HiveTableSourceITCase.java | 14 +------------- 1 file changed, 1 insertion(+), 13 deletions(-) diff --git a/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceITCase.java b/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceITCase.java index 5b8ed9b1..27833a85 100644 --- a/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceITCase.java +++ b/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceITCase.java @@ -1059,19 +1059,7 @@ public class HiveTableSourceITCase extends BatchAbstractTestBase { sortedRows.addAll(rows); sortedRows.addAll(rows); sortedRows.sort(Comparator.comparingInt(o -> (Integer) o.getField(0))); - - List<Row> expectedRows = new ArrayList<>(); - for (int i = 0; i < sortedRows.size(); i++) { - Row rowExpect = Row.copy(sortedRows.get(i)); - Row nestedRow = (Row) rowExpect.getField(2); - if (nestedRow.getField(0) == null - && nestedRow.getField(1) == null - && nestedRow.getField(2) == null) { - rowExpect.setField(2, null); - } - expectedRows.add(rowExpect); - } - return expectedRows; + return sortedRows; } private static CloseableIterator<Row> executeAndGetResult(StreamTableEnvironment tEnv)
