OriginalCompleteBefore

OriginalCompleteAfter

Before

After

Project

Commit

CompilationUnit

LineNos

Names

TemplateVariableToCodeBefore

RelevantImports

TemplateVariableToCodeAfter

isRelevant

isSafe

newPartitions = new ArrayList<>()

clone = new ArrayList<>(toClone.size())

new ArrayList<>()

new ArrayList<>(toClone.size())

flink

085d4db849b9c659ba6bb2c7d66a04debeb048c4

org.apache.flink.streaming.connectors.kafka.KafkaConsumerPartitionAssignmentTest

_1	199
_2	418

_1	newPartitions
_2	clone

v0

v0

AssignedTo

False

List<KafkaTopicPartition> newPartitions=new ArrayList<>();

List<List<KafkaTopicPartition>> clone=new ArrayList<>(toClone.size());