|
Change Parameter Type declineCheckpointConsumer : Consumer<Tuple4<JobID,ExecutionAttemptID,Long,Throwable>> to declineCheckpointConsumer : Consumer<DeclineCheckpoint> in method public TestingJobMasterGateway(address String, hostname String, cancelFunction Supplier<CompletableFuture<Acknowledge>>, stopFunction Supplier<CompletableFuture<Acknowledge>>, rescalingJobFunction BiFunction<Integer,RescalingBehaviour,CompletableFuture<Acknowledge>>, rescalingOperatorsFunction TriFunction<Collection<JobVertexID>,Integer,RescalingBehaviour,CompletableFuture<Acknowledge>>, updateTaskExecutionStateFunction Function<TaskExecutionState,CompletableFuture<Acknowledge>>, requestNextInputSplitFunction BiFunction<JobVertexID,ExecutionAttemptID,CompletableFuture<SerializedInputSplit>>, requestPartitionStateFunction BiFunction<IntermediateDataSetID,ResultPartitionID,CompletableFuture<ExecutionState>>, scheduleOrUpdateConsumersFunction Function<ResultPartitionID,CompletableFuture<Acknowledge>>, disconnectTaskManagerFunction Function<ResourceID,CompletableFuture<Acknowledge>>, disconnectResourceManagerConsumer Consumer<ResourceManagerId>, classloadingPropsSupplier Supplier<CompletableFuture<ClassloadingProps>>, offerSlotsFunction BiFunction<ResourceID,Collection<SlotOffer>,CompletableFuture<Collection<SlotOffer>>>, failSlotConsumer TriConsumer<ResourceID,AllocationID,Throwable>, registerTaskManagerFunction BiFunction<String,TaskManagerLocation,CompletableFuture<RegistrationResponse>>, taskManagerHeartbeatConsumer BiConsumer<ResourceID,AccumulatorReport>, resourceManagerHeartbeatConsumer Consumer<ResourceID>, requestJobDetailsSupplier Supplier<CompletableFuture<JobDetails>>, requestJobSupplier Supplier<CompletableFuture<ArchivedExecutionGraph>>, triggerSavepointFunction BiFunction<String,Boolean,CompletableFuture<String>>, requestOperatorBackPressureStatsFunction Function<JobVertexID,CompletableFuture<OperatorBackPressureStatsResponse>>, notifyAllocationFailureConsumer BiConsumer<AllocationID,Throwable>, acknowledgeCheckpointConsumer Consumer<Tuple5<JobID,ExecutionAttemptID,Long,CheckpointMetrics,TaskStateSnapshot>>, declineCheckpointConsumer Consumer<DeclineCheckpoint>, fencingTokenSupplier Supplier<JobMasterId>, requestKvStateLocationFunction BiFunction<JobID,String,CompletableFuture<KvStateLocation>>, notifyKvStateRegisteredFunction Function<Tuple6<JobID,JobVertexID,KeyGroupRange,String,KvStateID,InetSocketAddress>,CompletableFuture<Acknowledge>>, notifyKvStateUnregisteredFunction Function<Tuple4<JobID,JobVertexID,KeyGroupRange,String>,CompletableFuture<Acknowledge>>) in class org.apache.flink.runtime.jobmaster.utils.TestingJobMasterGateway |
From |
To |