You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2026/05/09 20:14:45 UTC
(flink-connector-hive) 01/15: [FLINK-35702][parquet] support parquet read nested in nested (#24991)
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 <60...@users.noreply.github.com>
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)