|
Change Parameter Type inputStates : List<OperatorStateHandle> to inputStates : OperatorSubtaskState in method private repartitionAndExecute(topic String, inputStates OperatorSubtaskState, oldParallelism int, newParallelism int, maxParallelism int, inputData Iterator<Integer>) : OperatorSubtaskState in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase |
From |
To |
|
Change Parameter Type previousParallelSubtaskStates : List<OperatorStateHandle> to previousParallelSubtaskStates : List<List<OperatorStateHandle>> in method private groupByStateMode(previousParallelSubtaskStates List<List<OperatorStateHandle>>) : GroupByStateNameResults in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Parameter Type managedOperatorStates : List<List<OperatorStateHandle>> to managedOperatorStates : List<List<List<OperatorStateHandle>>> in method private splitManagedAndRawOperatorStates(operatorStates List<OperatorState>, managedOperatorStates List<List<List<OperatorStateHandle>>>, rawOperatorStates List<List<List<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Parameter Type chainOpParallelStates : List<OperatorStateHandle> to chainOpParallelStates : List<List<OperatorStateHandle>> in method public applyRepartitioner(operatorID OperatorID, opStateRepartitioner OperatorStateRepartitioner, chainOpParallelStates List<List<OperatorStateHandle>>, oldParallelism int, newParallelism int) : Map<OperatorInstanceID,List<OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Parameter Type previousParallelSubtaskStates : List<OperatorStateHandle> to previousParallelSubtaskStates : List<List<OperatorStateHandle>> in method public repartitionState(previousParallelSubtaskStates List<List<OperatorStateHandle>>, oldParallelism int, newParallelism int) : List<List<OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Parameter Type rawOperatorStates : List<List<OperatorStateHandle>> to rawOperatorStates : List<List<List<OperatorStateHandle>>> in method private splitManagedAndRawOperatorStates(operatorStates List<OperatorState>, managedOperatorStates List<List<List<OperatorStateHandle>>>, rawOperatorStates List<List<List<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Parameter Type inputStates : List<OperatorStateHandle> to inputStates : OperatorSubtaskState in method private repartitionAndExecute(topic String, inputStates OperatorSubtaskState, oldParallelism int, newParallelism int, maxParallelism int, inputData Iterator<Integer>) : OperatorSubtaskState in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Change Parameter Type previousParallelSubtaskStates : List<OperatorStateHandle> to previousParallelSubtaskStates : List<List<OperatorStateHandle>> in method public repartitionState(previousParallelSubtaskStates List<List<OperatorStateHandle>>, oldParallelism int, newParallelism int) : List<List<OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.OperatorStateRepartitioner |
From |
To |
|
Rename Variable rawOperatorState : List<OperatorStateHandle> to rawOpStatePerSubtasks : List<List<OperatorStateHandle>> in method private splitManagedAndRawOperatorStates(operatorStates List<OperatorState>, managedOperatorStates List<List<List<OperatorStateHandle>>>, rawOperatorStates List<List<List<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Rename Variable psh : OperatorStateHandle to operatorStateHandle : OperatorStateHandle in method private groupByStateMode(previousParallelSubtaskStates List<List<OperatorStateHandle>>) : GroupByStateNameResults in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Rename Variable uniformBroadcastNameToState : Map<String,List<Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo>>> to nameToBroadcastState : Map<String,List<Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo>>> in method private repartition(nameToStateByMode GroupByStateNameResults, newParallelism int) : List<Map<StreamStateHandle,OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Rename Variable broadcastNameToState : Map<String,List<Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo>>> to nameToUnionState : Map<String,List<Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo>>> in method private repartition(nameToStateByMode GroupByStateNameResults, newParallelism int) : List<Map<StreamStateHandle,OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Rename Variable managedOperatorState : List<OperatorStateHandle> to managedOpStatePerSubtasks : List<List<OperatorStateHandle>> in method private splitManagedAndRawOperatorStates(operatorStates List<OperatorState>, managedOperatorStates List<List<List<OperatorStateHandle>>>, rawOperatorStates List<List<List<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Rename Variable distributeNameToState : Map<String,List<Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo>>> to nameToDistributeState : Map<String,List<Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo>>> in method private repartition(nameToStateByMode GroupByStateNameResults, newParallelism int) : List<Map<StreamStateHandle,OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Rename Variable i : int to subTaskIndex : int in method private splitManagedAndRawOperatorStates(operatorStates List<OperatorState>, managedOperatorStates List<List<List<OperatorStateHandle>>>, rawOperatorStates List<List<List<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type outputStates : List<OperatorStateHandle> to outputStates : List<OperatorSubtaskState> in method private repartitionAndExecute(topic String, inputStates OperatorSubtaskState, oldParallelism int, newParallelism int, maxParallelism int, inputData Iterator<Integer>) : OperatorSubtaskState in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase |
From |
To |
|
Change Variable Type rawOperatorState : List<OperatorStateHandle> to rawOpStatePerSubtasks : List<List<OperatorStateHandle>> in method private splitManagedAndRawOperatorStates(operatorStates List<OperatorState>, managedOperatorStates List<List<List<OperatorStateHandle>>>, rawOperatorStates List<List<List<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type oldRawOperatorStates : List<List<OperatorStateHandle>> to oldRawOperatorStates : List<List<List<OperatorStateHandle>>> in method package reDistributePartitionableStates(oldOperatorStates List<OperatorState>, newParallelism int, newOperatorIDs List<OperatorID>, newManagedOperatorStates Map<OperatorInstanceID,List<OperatorStateHandle>>, newRawOperatorStates Map<OperatorInstanceID,List<OperatorStateHandle>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type previousParallelOpInstanceStates : List<OperatorStateHandle> to previousParallelOpInstanceStates : List<List<OperatorStateHandle>> in method private doTestPartitionableStateRepartitioning(r Random, oldParallelism int, newParallelism int, numNamedStates int, maxPartitionsPerState int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type operatorSubtaskState : List<OperatorStateHandle> to operatorSubtaskState : OperatorSubtaskState in method public testScaleUpAfterScalingDown() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Change Variable Type outputStates : List<OperatorStateHandle> to outputStates : List<OperatorSubtaskState> in method private repartitionAndExecute(topic String, inputStates OperatorSubtaskState, oldParallelism int, newParallelism int, maxParallelism int, inputData Iterator<Integer>) : OperatorSubtaskState in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Change Variable Type managedOperatorState : List<OperatorStateHandle> to managedOpStatePerSubtasks : List<List<OperatorStateHandle>> in method private splitManagedAndRawOperatorStates(operatorStates List<OperatorState>, managedOperatorStates List<List<List<OperatorStateHandle>>>, rawOperatorStates List<List<List<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type oldManagedOperatorStates : List<List<OperatorStateHandle>> to oldManagedOperatorStates : List<List<List<OperatorStateHandle>>> in method package reDistributePartitionableStates(oldOperatorStates List<OperatorState>, newParallelism int, newOperatorIDs List<OperatorID>, newManagedOperatorStates Map<OperatorInstanceID,List<OperatorStateHandle>>, newRawOperatorStates Map<OperatorInstanceID,List<OperatorStateHandle>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type operatorSubtaskState : List<OperatorStateHandle> to operatorSubtaskState : OperatorSubtaskState in method public testScaleUpAfterScalingDown() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase |
From |
To |