|
Change Variable Type sampleFuture : Future<StackTraceSample> to sampleFuture : CompletableFuture<StackTraceSample> in method public testTriggerStackTraceSampleTimeout() : void in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |
|
Change Variable Type sampleFutures : List<Future<StackTraceSample>> to sampleFutures : List<CompletableFuture<StackTraceSample>> in method public testShutDown() : void in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |
|
Change Variable Type future : CompletableFuture<StackTraceSampleResponse> to future : FlinkCompletableFuture<StackTraceSampleResponse> in method private mockExecutionVertexWithTimeout(executionId ExecutionAttemptID, state ExecutionState, scheduledExecutorService ScheduledExecutorService, timeout int) : ExecutionVertex in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |
|
Change Variable Type sample : Future<StackTraceSample> to sample : CompletableFuture<StackTraceSample> in method public triggerStackTraceSample(vertex ExecutionJobVertex) : boolean in class org.apache.flink.runtime.webmonitor.BackPressureStatsTracker |
From |
To |
|
Change Variable Type sampleFuture : Future<StackTraceSample> to sampleFuture : CompletableFuture<StackTraceSample> in method public testTriggerStackTraceSampleNotRunningTasks() : void in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |
|
Change Variable Type sampleFuture : Future<StackTraceSample> to sampleFuture : CompletableFuture<StackTraceSample> in method public testCancelStackTraceSample() : void in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |
|
Change Variable Type sampleFuture : Future<StackTraceSample> to sampleFuture : CompletableFuture<StackTraceSample> in method public testCollectStackTraceForCanceledSample() : void in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |
|
Change Variable Type future : Future<StackTraceSample> to future : CompletableFuture<StackTraceSample> in method public testShutDown() : void in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |
|
Change Variable Type stackTraceSampleFuture : Future<StackTraceSampleResponse> to stackTraceSampleFuture : CompletableFuture<StackTraceSampleResponse> in method public triggerStackTraceSample(tasksToSample ExecutionVertex[], numSamples int, delayBetweenSamples Time, maxStackTraceDepth int) : CompletableFuture<StackTraceSample> in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinator |
From |
To |
|
Change Variable Type sampleFuture : Future<StackTraceSample> to sampleFuture : CompletableFuture<StackTraceSample> in method public testCollectForDiscardedPendingSample() : void in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |
|
Change Variable Type sampleFuture : Future<StackTraceSample> to sampleFuture : CompletableFuture<StackTraceSample> in method public testTriggerStackTraceSampleResetRunningTasks() : void in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |
|
Change Variable Type sampleFuture : Future<StackTraceSample> to sampleFuture : CompletableFuture<StackTraceSample> in method public testTriggerStackTraceSample() : void in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |