|
Push Down Method public getCleanUpInterval() : long from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to public getCleanUpInterval() : long from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Method public BackPressureStatsTracker(coordinator StackTraceSampleCoordinator, cleanUpInterval int, numSamples int, backPressureStatsRefreshInterval int, delayBetweenSamples Time) from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to public BackPressureStatsTrackerImpl(coordinator StackTraceSampleCoordinator, cleanUpInterval int, numSamples int, backPressureStatsRefreshInterval int, delayBetweenSamples Time) from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Method package invalidateOperatorStatsCache() : void from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to package invalidateOperatorStatsCache() : void from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Method public triggerStackTraceSample(vertex ExecutionJobVertex) : boolean from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to public triggerStackTraceSample(vertex ExecutionJobVertex) : boolean from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Method public cleanUpOperatorStatsCache() : void from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to public cleanUpOperatorStatsCache() : void from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Method public getOperatorBackPressureStats(vertex ExecutionJobVertex) : Optional<OperatorBackPressureStats> from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to public getOperatorBackPressureStats(vertex ExecutionJobVertex) : Optional<OperatorBackPressureStats> from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Method public shutDown() : void from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to public shutDown() : void from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Method private triggerStackTraceSampleInternal(vertex ExecutionJobVertex) : boolean from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private triggerStackTraceSampleInternal(vertex ExecutionJobVertex) : boolean from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Change Parameter Type statsTracker : BackPressureStatsTracker to statsTracker : BackPressureStatsTrackerImpl in method private triggerStatsSample(statsTracker BackPressureStatsTrackerImpl, vertex ExecutionJobVertex) : OperatorBackPressureStats in class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImplITCase |
From |
To |
|
Change Parameter Type backPressureStatsTracker : BackPressureStatsTracker to backPressureStatsTrackerImpl : BackPressureStatsTrackerImpl in method public JobVertexBackPressureHandler(executionGraphHolder ExecutionGraphCache, executor Executor, backPressureStatsTrackerImpl BackPressureStatsTrackerImpl, refreshInterval int) in class org.apache.flink.runtime.rest.handler.legacy.JobVertexBackPressureHandler |
From |
To |
|
Change Parameter Type backPressureStatsTracker : BackPressureStatsTracker to backPressureStatsTrackerImpl : BackPressureStatsTrackerImpl in method public JobManagerServices(executorService ScheduledExecutorService, libraryCacheManager BlobLibraryCacheManager, restartStrategyFactory RestartStrategyFactory, rpcAskTimeout Time, stackTraceSampleCoordinator StackTraceSampleCoordinator, backPressureStatsTrackerImpl BackPressureStatsTrackerImpl) in class org.apache.flink.runtime.jobmaster.JobManagerServices |
From |
To |
|
Push Down Attribute private shutDown : boolean from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private shutDown : boolean from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute private lock : Object from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private lock : Object from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute private coordinator : StackTraceSampleCoordinator from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private coordinator : StackTraceSampleCoordinator from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute private LOG : Logger from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private LOG : Logger from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute package EXPECTED_CLASS_NAME : String from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to package EXPECTED_CLASS_NAME : String from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute private cleanUpInterval : int from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private cleanUpInterval : int from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute private backPressureStatsRefreshInterval : int from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private backPressureStatsRefreshInterval : int from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute package MAX_STACK_TRACE_DEPTH : int from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to package MAX_STACK_TRACE_DEPTH : int from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute private numSamples : int from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private numSamples : int from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute private delayBetweenSamples : Time from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private delayBetweenSamples : Time from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute package EXPECTED_METHOD_NAME : String from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to package EXPECTED_METHOD_NAME : String from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute private pendingStats : Set<ExecutionJobVertex> from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private pendingStats : Set<ExecutionJobVertex> from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Push Down Attribute private operatorStatsCache : Cache<ExecutionJobVertex,OperatorBackPressureStats> from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTracker to private operatorStatsCache : Cache<ExecutionJobVertex,OperatorBackPressureStats> from class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl |
From |
To |
|
Change Variable Type statsTracker : BackPressureStatsTracker to statsTracker : BackPressureStatsTrackerImpl in method public testResponseNoStatsAvailable() : void in class org.apache.flink.runtime.rest.handler.legacy.JobVertexBackPressureHandlerTest |
From |
To |
|
Change Variable Type statsTracker : BackPressureStatsTracker to statsTracker : BackPressureStatsTrackerImpl in method public testResponseStatsAvailable() : void in class org.apache.flink.runtime.rest.handler.legacy.JobVertexBackPressureHandlerTest |
From |
To |
|
Change Variable Type tracker : BackPressureStatsTracker to tracker : BackPressureStatsTrackerImpl in method public testTriggerStackTraceSample() : void in class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImplTest |
From |
To |
|
Change Variable Type statsTracker : BackPressureStatsTracker to statsTracker : BackPressureStatsTrackerImpl in method public testResponsePassedRefreshInterval() : void in class org.apache.flink.runtime.rest.handler.legacy.JobVertexBackPressureHandlerTest |
From |
To |
|
Change Variable Type backPressureStatsTracker : BackPressureStatsTracker to backPressureStatsTrackerImpl : BackPressureStatsTrackerImpl in method public fromConfiguration(config Configuration, blobServer BlobServer) : JobManagerServices in class org.apache.flink.runtime.jobmaster.JobManagerServices |
From |
To |
|
Change Variable Type statsTracker : BackPressureStatsTracker to statsTracker : BackPressureStatsTrackerImpl in method public testBackPressuredProducer() : void in class org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImplITCase |
From |
To |