Skip to content

Commit 66faa70

Browse files
committed
fix checkstyle
1 parent 13f0a8a commit 66faa70

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -303,9 +303,7 @@ private boolean buildForIncrementalClustering(
303303
RowAppendTableSink sink = new RowAppendTableSink(table, null, null, null);
304304
DataStream<Committable> written =
305305
sink.doWrite(
306-
FlinkSinkBuilder.mapToInternalRow(
307-
sorted,
308-
table.rowType()),
306+
FlinkSinkBuilder.mapToInternalRow(sorted, table.rowType()),
309307
commitUser,
310308
null);
311309
DataStream<Committable> clusterCommittable =

0 commit comments

Comments
 (0)