lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-4277] supoort flink table source with computed column (#5897)

Browse Source 
Co-authored-by: chenshizhi <chenshizhi@bilibili.com>
This commit is contained in:
Shizhi Chen
2022-06-20 15:19:32 +08:00
committed by GitHub
parent efafb79eeb
commit 7481eacf23
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java
View File

@@ -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;