ic4y commented on code in PR #2560:
URL:
https://github.com/apache/incubator-seatunnel/pull/2560#discussion_r957150345
##########
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java:
##########
@@ -64,13 +63,12 @@ public class PhysicalPlan {
* in {@link org.apache.seatunnel.engine.server.scheduler.JobScheduler}
whenComplete method will be called.
*/
private final CompletableFuture<JobStatus> jobEndFuture;
- private final PassiveCompletableFuture<JobStatus> passiveCompletableFuture;
/**
* This future only can completion by the {@link SubPlan } subPlanFuture.
* When subPlanFuture completed, this NonCompletableFuture's whenComplete
method will be called.
*/
- private final PassiveCompletableFuture<PipelineState>[]
waitForCompleteBySubPlan;
+ private List<PassiveCompletableFuture<PipelineState>>
waitForCompleteBySubPlan;
Review Comment:
`waitForCompleteBySubPlan ` looks like this is not used
--
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]
