Skip to content

Commit c0d68d3

Browse files
committed
[flink] Fixed an issue with field type matching errors during lookup. (apache#6972)
1 parent c455db2 commit c0d68d3

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -129,8 +129,11 @@ public FileStoreLookupFunction(
129129
.collect(Collectors.toList());
130130

131131
this.projectFieldsGetters =
132-
Arrays.stream(projection)
133-
.mapToObj(i -> InternalRow.createFieldGetter(rowType.getTypeAt(i), i))
132+
IntStream.range(0, projection.length)
133+
.mapToObj(
134+
i ->
135+
InternalRow.createFieldGetter(
136+
rowType.getTypeAt(projection[i]), i))
134137
.collect(Collectors.toList());
135138

136139
// add primary keys

0 commit comments

Comments
 (0)