From 7481eacf23794a5957eba39c401100ad2219e887 Mon Sep 17 00:00:00 2001 From: Shizhi Chen <107476116+chenshzh@users.noreply.github.com> Date: Mon, 20 Jun 2022 15:19:32 +0800 Subject: [PATCH] [HUDI-4277] supoort flink table source with computed column (#5897) Co-authored-by: chenshizhi --- .../src/main/java/org/apache/hudi/table/HoodieTableSource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java index 183685738..e76bb29bd 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java @@ -156,7 +156,7 @@ public class HoodieTableSource implements this.fileIndex = FileIndex.instance(this.path, this.conf); this.requiredPartitions = requiredPartitions; this.requiredPos = requiredPos == null - ? IntStream.range(0, schema.getColumnCount()).toArray() + ? IntStream.range(0, schema.toPhysicalRowDataType().getChildren().size()).toArray() : requiredPos; this.limit = limit == null ? NO_LIMIT_CONSTANT : limit; this.filters = filters == null ? Collections.emptyList() : filters;