Skip to content

Commit 5691bd7

Browse files
committed
fix
1 parent bd6c5e0 commit 5691bd7

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/AppendTableCompactor.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -197,11 +197,9 @@ public List<Committable> prepareCommit(boolean waitCompaction, long checkpointId
197197
result.poll();
198198
tempList.add(future.get());
199199
}
200-
List<Committable> committables =
201-
tempList.stream()
202-
.map(s -> new Committable(checkpointId, Committable.Kind.FILE, s))
203-
.collect(Collectors.toList());
204-
return committables;
200+
return tempList.stream()
201+
.map(s -> new Committable(checkpointId, Committable.Kind.FILE, s))
202+
.collect(Collectors.toList());
205203
} catch (InterruptedException e) {
206204
throw new RuntimeException("Interrupted while waiting tasks done.", e);
207205
} catch (Exception e) {

0 commit comments

Comments
 (0)