Skip to content

Commit 07bf2db

Browse files
committed
nit
1 parent 288f050 commit 07bf2db

File tree

1 file changed

+11
-2
lines changed

1 file changed

+11
-2
lines changed

fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/utils/IcebergConversions.java

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,13 +70,22 @@ public static Expression toFilterExpression(
7070
Expressions.and(
7171
expression,
7272
Expressions.equal(
73-
partitionFields.get(partitionIndex++).name(), partition));
73+
table.schema()
74+
.findColumnName(
75+
partitionFields
76+
.get(partitionIndex++)
77+
.sourceId()),
78+
partition));
7479
}
7580
}
7681
expression =
7782
Expressions.and(
7883
expression,
79-
Expressions.equal(partitionFields.get(partitionIndex).name(), bucket));
84+
Expressions.equal(
85+
table.schema()
86+
.findColumnName(
87+
partitionFields.get(partitionIndex).sourceId()),
88+
bucket));
8089
return expression;
8190
}
8291
}

0 commit comments

Comments
 (0)