|
Pull Up Method public getNumberTaskManagers() : int from class org.apache.flink.test.util.MiniClusterResourceConfiguration to public getNumberTaskManagers() : int from class org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration |
From |
To |
|
Pull Up Method public getConfiguration() : Configuration from class org.apache.flink.test.util.MiniClusterResourceConfiguration to public getConfiguration() : Configuration from class org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration |
From |
To |
|
Pull Up Method public getTestEnvironment() : TestEnvironment from class org.apache.flink.test.util.MiniClusterResource to public getTestEnvironment() : TestEnvironment from class org.apache.flink.test.util.MiniClusterWithClientResource |
From |
To |
|
Pull Up Method public before() : void from class org.apache.flink.test.util.MiniClusterResource to public before() : void from class org.apache.flink.test.util.MiniClusterWithClientResource |
From |
To |
|
Pull Up Method public getRpcServiceSharing() : RpcServiceSharing from class org.apache.flink.test.util.MiniClusterResourceConfiguration to public getRpcServiceSharing() : RpcServiceSharing from class org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration |
From |
To |
|
Pull Up Method public getClusterClient() : ClusterClient<?> from class org.apache.flink.test.util.MiniClusterResource to public getClusterClient() : ClusterClient<?> from class org.apache.flink.test.util.MiniClusterWithClientResource |
From |
To |
|
Pull Up Method public after() : void from class org.apache.flink.test.util.MiniClusterResource to public after() : void from class org.apache.flink.test.util.MiniClusterWithClientResource |
From |
To |
|
Pull Up Method public getShutdownTimeout() : Time from class org.apache.flink.test.util.MiniClusterResourceConfiguration to public getShutdownTimeout() : Time from class org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration |
From |
To |
|
Pull Up Method public getNumberSlotsPerTaskManager() : int from class org.apache.flink.test.util.MiniClusterResourceConfiguration to public getNumberSlotsPerTaskManager() : int from class org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration |
From |
To |
|
Pull Up Method public getWebUIPort() : int from class org.apache.flink.test.util.MiniClusterResource to public getNumberSlots() : int from class org.apache.flink.runtime.testutils.MiniClusterResource |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method public testThroughput() : void in class org.apache.flink.test.runtime.NetworkStackThroughputITCase |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method public testSubmitWithUnknownSavepointPath() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method public testCanRestoreWithModifiedStatelessOperators() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method public testNettyEpoll() : void in class org.apache.flink.test.runtime.NettyEpollITCase |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method private restoreJobAndVerifyState(savepointPath String, clusterFactory MiniClusterResourceFactory, parallelism int) : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method public testTriggerSavepointWithCheckpointingDisabled() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method private submitJobAndGetVerifiedSavepoint(clusterFactory MiniClusterResourceFactory, parallelism int) : String in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method private testExternalizedCheckpoints(checkpointDir File, zooKeeperQuorum String, backend StateBackend, localRecovery boolean) : void in class org.apache.flink.test.checkpointing.ResumeCheckpointManuallyITCase |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method public testTriggerSavepointForNonExistingJob() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method public testSavepointForJobWithIteration() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method public main(args String[]) : void in class org.apache.flink.test.manual.StreamingScalabilityAndLatency |
From |
To |
|
Change Variable Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in method private trySetUpCluster() : MiniClusterWithClientResource in class org.apache.flink.test.runtime.NettyEpollITCase |
From |
To |
|
Change Attribute Type flink : MiniClusterResource to flink : MiniClusterWithClientResource in class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.example.failing.JobSubmissionFailsITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.misc.CustomSerializationITCase |
From |
To |
|
Change Attribute Type flink : MiniClusterResource to flink : MiniClusterWithClientResource in class org.apache.flink.streaming.connectors.kafka.KafkaShortRetentionTestBase |
From |
To |
|
Change Attribute Type CLUSTER : MiniClusterResource to CLUSTER : MiniClusterWithClientResource in class org.apache.flink.runtime.webmonitor.WebFrontendITCase |
From |
To |
|
Change Attribute Type miniClusterResource : MiniClusterResource to miniClusterResource : MiniClusterWithClientResource in class org.apache.flink.test.runtime.IPv6HostnamesITCase |
From |
To |
|
Change Attribute Type miniClusterResource : MiniClusterResource to miniClusterResource : MiniClusterWithClientResource in class org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.hdfstests.DistributedCacheDfsTest |
From |
To |
|
Change Attribute Type miniClusterResource : MiniClusterResource to miniClusterResource : MiniClusterWithClientResource in class org.apache.flink.test.checkpointing.utils.SavepointMigrationTestBase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.table.client.gateway.local.LocalExecutorITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.recovery.SimpleRecoveryFailureRateStrategyITBase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.accumulators.AccumulatorLiveITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.checkpointing.KeyedStateCheckpointingITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.checkpointing.EventTimeAllWindowCheckpointingITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.misc.AutoParallelismITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.misc.SuccessAfterNetworkBuffersFailureITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.misc.MiscellaneousIssuesITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.accumulators.AccumulatorErrorITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.runtime.metrics.JobManagerMetricsITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.runtime.jobmanager.JMXJobManagerMetricTest |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.recovery.SimpleRecoveryFixedDelayRestartStrategyITBase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.state.operator.restore.AbstractOperatorRestoreTestBase |
From |
To |
|
Change Attribute Type miniClusterResource : MiniClusterResource to miniClusterResource : MiniClusterWithClientResource in class org.apache.flink.queryablestate.itcases.HAQueryableStateRocksDBBackendITCase |
From |
To |
|
Change Attribute Type miniClusterResource : MiniClusterResource to miniClusterResource : MiniClusterWithClientResource in class org.apache.flink.test.util.AbstractTestBase |
From |
To |
|
Change Attribute Type CLUSTER : MiniClusterResource to CLUSTER : MiniClusterWithClientResource in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.checkpointing.WindowCheckpointingITCase |
From |
To |
|
Change Attribute Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in class org.apache.flink.runtime.webmonitor.history.HistoryServerTest |
From |
To |
|
Change Attribute Type cluster : MiniClusterResource to cluster : MiniClusterWithClientResource in class org.apache.flink.test.checkpointing.RescalingITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.queryablestate.itcases.NonHAQueryableStateRocksDBBackendITCase |
From |
To |
|
Change Attribute Type miniClusterResource : MiniClusterResource to miniClusterResource : MiniClusterWithClientResource in class org.apache.flink.queryablestate.itcases.HAQueryableStateFsBackendITCase |
From |
To |
|
Change Attribute Type CLUSTER : MiniClusterResource to CLUSTER : MiniClusterWithClientResource in class org.apache.flink.test.cancelling.CancelingTestBase |
From |
To |
|
Change Attribute Type miniClusterResource : MiniClusterResource to miniClusterResource : MiniClusterWithClientResource in class org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.operators.CustomDistributionITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase |
From |
To |
|
Change Attribute Type miniClusterResource : MiniClusterResource to miniClusterResource : MiniClusterWithClientResource in class org.apache.flink.streaming.test.examples.windowing.TopSpeedWindowingExampleITCase |
From |
To |
|
Change Attribute Type MINI_CLUSTER_RESOURCE : MiniClusterResource to MINI_CLUSTER_RESOURCE : MiniClusterWithClientResource in class org.apache.flink.queryablestate.itcases.NonHAQueryableStateFsBackendITCase |
From |
To |