|
Change Parameter Type executor : ForkableFlinkMiniCluster to executor : LocalFlinkMiniCluster in method public stopCluster(executor LocalFlinkMiniCluster, timeout FiniteDuration) : void in class org.apache.flink.test.util.TestBaseUtils |
From |
To |
|
Change Parameter Type executor : ForkableFlinkMiniCluster to executor : LocalFlinkMiniCluster in method public TestStreamEnvironment(executor LocalFlinkMiniCluster, parallelism int) in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Change Parameter Type executor : ForkableFlinkMiniCluster to executor : LocalFlinkMiniCluster in method public TestEnvironment(executor LocalFlinkMiniCluster, parallelism int, isObjectReuseEnabled boolean) in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Change Parameter Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in method public JobSubmitterRunnable(actorSystem ActorSystem, cluster LocalFlinkMiniCluster, graph JobGraph) in class org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase.JobSubmitterRunnable |
From |
To |
|
Change Parameter Type executor : ForkableFlinkMiniCluster to executor : LocalFlinkMiniCluster in method public TestEnvironment(executor LocalFlinkMiniCluster, parallelism int) in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Change Parameter Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in method public setAsContext(cluster LocalFlinkMiniCluster, parallelism int) : void in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Change Variable Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in method public startCluster(config Configuration, singleActorSystem boolean) : LocalFlinkMiniCluster in class org.apache.flink.test.util.TestBaseUtils |
From |
To |
|
Change Variable Type flink : ForkableFlinkMiniCluster to flink : LocalFlinkMiniCluster in method public testClusterWithIPv6host() : void in class org.apache.flink.test.runtime.IPv6HostnamesITCase |
From |
To |
|
Change Variable Type cluster : ForkableFlinkMiniCluster to cluster : TestingCluster in method public testTaskManagerRegistrationAtReelectedLeader() : void in class org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase |
From |
To |
|
Change Variable Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in method public testCollect() : void in class org.apache.flink.contrib.streaming.CollectITCase |
From |
To |
|
Change Variable Type flink : ForkableFlinkMiniCluster to flink : TestingCluster in method public testSubmitWithUnknownSavepointPath() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in method public testThis() : void in class org.apache.flink.test.recovery.FastFailuresITCase |
From |
To |
|
Change Variable Type flink : ForkableFlinkMiniCluster to flink : TestingCluster in method public testCheckpointsRemovedWithJobManagerBackendOnShutdown() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type finalFlink : ForkableFlinkMiniCluster to finalFlink : TestingCluster in method public testTriggerSavepointAndResume() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type flink : ForkableFlinkMiniCluster to flink : LocalFlinkMiniCluster in method public main(args String[]) : void in class org.apache.flink.streaming.connectors.kinesis.manualtests.ManualExactlyOnceTest |
From |
To |
|
Change Variable Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in method public testRestartWithFailingTaskManager() : void in class org.apache.flink.test.recovery.TaskManagerFailureRecoveryITCase |
From |
To |
|
Change Variable Type cluster : ForkableFlinkMiniCluster to cluster : TestingCluster in method public testJobExecutionOnClusterWithLeaderReelection() : void in class org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase |
From |
To |
|
Change Variable Type flink : ForkableFlinkMiniCluster to flink : TestingCluster in method public testTriggerSavepointAndResume() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type testMiniCluster : ForkableFlinkMiniCluster to testMiniCluster : LocalFlinkMiniCluster in method public testExternalProgram() : void in class org.apache.flink.api.avro.AvroExternalJarProgramITCase |
From |
To |
|
Change Variable Type flink : ForkableFlinkMiniCluster to flink : LocalFlinkMiniCluster in method public main(args String[]) : void in class org.apache.flink.streaming.connectors.kinesis.manualtests.ManualExactlyOnceWithStreamReshardingTest |
From |
To |
|
Change Variable Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in method public testSuccessfulProgramAfterFailure() : void in class org.apache.flink.test.misc.SuccessAfterNetworkBuffersFailureITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : TestingCluster in class org.apache.flink.test.checkpointing.RescalingITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.misc.CustomSerializationITCase |
From |
To |
|
Change Attribute Type executor : ForkableFlinkMiniCluster to executor : LocalFlinkMiniCluster in class org.apache.flink.test.util.AbstractTestBase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.checkpointing.WindowCheckpointingITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.graph.test.operations.DegreesWithExceptionITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase.JobSubmitterRunnable |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.streaming.util.StreamingMultipleProgramsTestBase |
From |
To |
|
Change Attribute Type executor : ForkableFlinkMiniCluster to executor : LocalFlinkMiniCluster in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.graph.test.operations.ReduceOnNeighborsWithExceptionITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : TestingCluster in class org.apache.flink.test.query.QueryableStateITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.misc.AutoParallelismITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.javaApiOperators.RemoteEnvironmentITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.misc.MiscellaneousIssuesITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase |
From |
To |
|
Change Attribute Type executor : ForkableFlinkMiniCluster to executor : LocalFlinkMiniCluster in class org.apache.flink.test.cancelling.CancelingTestBase |
From |
To |
|
Change Attribute Type flink : ForkableFlinkMiniCluster to flink : LocalFlinkMiniCluster in class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.recovery.SimpleRecoveryITCaseBase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.streaming.runtime.TimestampITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.graph.test.operations.ReduceOnEdgesWithExceptionITCase |
From |
To |
|
Change Attribute Type executor : ForkableFlinkMiniCluster to executor : LocalFlinkMiniCluster in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.web.WebFrontendITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.util.MultipleProgramsTestBase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.checkpointing.EventTimeAllWindowCheckpointingITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.failingPrograms.JobSubmissionFailsITCase |
From |
To |
|
Change Attribute Type testCluster : ForkableFlinkMiniCluster to testCluster : TestingCluster in class org.apache.flink.test.classloading.ClassLoaderITCase |
From |
To |
|
Change Attribute Type flink : ForkableFlinkMiniCluster to flink : LocalFlinkMiniCluster in class org.apache.flink.streaming.connectors.kafka.KafkaShortRetentionTestBase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.accumulators.AccumulatorErrorITCase |
From |
To |
|
Change Attribute Type cluster : ForkableFlinkMiniCluster to cluster : LocalFlinkMiniCluster in class org.apache.flink.test.javaApiOperators.CustomDistributionITCase |
From |
To |
|
Change Attribute Type flinkCluster : ForkableFlinkMiniCluster to flinkCluster : LocalFlinkMiniCluster in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase |
From |
To |