Aitozi commented on code in PR #4386:
URL: https://github.com/apache/paimon/pull/4386#discussion_r1820235483
##########
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/PartitionMarkDoneTrigger.java:
##########
@@ -65,21 +78,30 @@ public class PartitionMarkDoneTrigger {
@Nullable private final Long idleTime;
private final boolean markDoneWhenEndInput;
private final Map<String, Long> pendingPartitions;
+ private final List<PartitionMarkDoneAction> actions;
+ private final boolean waitCompaction;
+ private final InternalRowPartitionComputer partitionComputer;
public PartitionMarkDoneTrigger(
State state,
PartitionTimeExtractor timeExtractor,
@Nullable Duration timeInterval,
@Nullable Duration idleTime,
- boolean markDoneWhenEndInput)
+ boolean markDoneWhenEndInput,
Review Comment:
I reset the commit, and updated in https://github.com/apache/paimon/pull/4398
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
