Skip to content

Commit 0616ed4

Browse files
committed
fix java 8
1 parent 0b9bdd3 commit 0616ed4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

fluss-lake/fluss-lake-iceberg/src/main/java/com/alibaba/fluss/lake/iceberg/tiering/IcebergLakeCommitter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -128,9 +128,9 @@ public long commit(IcebergCommittable committable, Map<String, String> snapshotP
128128
// referenced by
129129
// the position delete files that are being committed.
130130
RowDelta rowDelta = icebergTable.newRowDelta();
131-
Arrays.stream(committable.getDataFiles().toArray(DataFile[]::new))
131+
Arrays.stream(committable.getDataFiles().stream().toArray(DataFile[]::new))
132132
.forEach(rowDelta::addRows);
133-
Arrays.stream(committable.getDeleteFiles().toArray(DeleteFile[]::new))
133+
Arrays.stream(committable.getDeleteFiles().stream().toArray(DeleteFile[]::new))
134134
.forEach(rowDelta::addDeletes);
135135
snapshotProperties.forEach(rowDelta::set);
136136
rowDelta.commit();

0 commit comments

Comments
 (0)