OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
newPartitions.add(part);clone.add(clonePartitions);newPartitions.add(part)newPartitions.add(clonePartitions)flink085d4db849b9c659ba6bb2c7d66a04debeb048c4org.apache.flink.streaming.connectors.kafka.KafkaConsumerPartitionAssignmentTest
_1199
_2418
_1newPartitions
_2clone
TCIVarnewPartitions
TCIVarnewPartitions
UsesFalse