OriginalCompleteBefore	OriginalCompleteAfter	Before	After	Project	Commit	CompilationUnit	LineNos	Names	TemplateVariableToCodeBefore	RelevantImports	TemplateVariableToCodeAfter	isRelevant	isSafe
topics = Collections.singletonList(new KafkaTopicPartition(topic,partition))	partitionsWithInitialOffsets = Collections.singletonMap(new KafkaTopicPartition(topic,partition),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	Collections.singletonList(new KafkaTopicPartition(topic,partition))	Collections.singletonMap(new KafkaTopicPartition(topic,partition),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka09FetcherTest	_1 375 _2 373	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(topic,partition)	java.util.Collections	v0 new KafkaTopicPartition(topic,partition)	AssignedTo	True
List<KafkaTopicPartition> topics=Collections.singletonList(new KafkaTopicPartition(topic,partition));	Map<KafkaTopicPartition,Long> partitionsWithInitialOffsets=Collections.singletonMap(new KafkaTopicPartition(topic,partition),KafkaTopicPartitionStateSentinel.GROUP_OFFSET);	Collections.singletonList(new KafkaTopicPartition(topic,partition))	Collections.singletonMap(new KafkaTopicPartition(topic,partition),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka09FetcherTest	_1 375 _2 373	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(topic,partition)	java.util.Collections	v0 new KafkaTopicPartition(topic,partition)	AssignedTo	True
topics = Collections.singletonList(new KafkaTopicPartition(STR0,42))	partitionsWithInitialOffsets = Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	Collections.singletonList(new KafkaTopicPartition(STR0,42))	Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka09FetcherTest	_1 259 _2 258	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(STR0,42)	java.util.Collections	v0 new KafkaTopicPartition(STR0,42)	AssignedTo	True
List<KafkaTopicPartition> topics=Collections.singletonList(new KafkaTopicPartition(STR0,42));	Map<KafkaTopicPartition,Long> partitionsWithInitialOffsets=Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET);	Collections.singletonList(new KafkaTopicPartition(STR0,42))	Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka09FetcherTest	_1 259 _2 258	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(STR0,42)	java.util.Collections	v0 new KafkaTopicPartition(STR0,42)	AssignedTo	True
topics = Collections.singletonList(new KafkaTopicPartition(STR0,42))	partitionsWithInitialOffsets = Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	Collections.singletonList(new KafkaTopicPartition(STR0,42))	Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka09FetcherTest	_1 121 _2 121	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(STR0,42)	java.util.Collections	v0 new KafkaTopicPartition(STR0,42)	AssignedTo	True
List<KafkaTopicPartition> topics=Collections.singletonList(new KafkaTopicPartition(STR0,42));	Map<KafkaTopicPartition,Long> partitionsWithInitialOffsets=Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET);	Collections.singletonList(new KafkaTopicPartition(STR0,42))	Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka09FetcherTest	_1 121 _2 121	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(STR0,42)	java.util.Collections	v0 new KafkaTopicPartition(STR0,42)	AssignedTo	True
topics = Collections.singletonList(new KafkaTopicPartition(topic,partition))	partitionsWithInitialOffsets = Collections.singletonMap(new KafkaTopicPartition(topic,partition),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	Collections.singletonList(new KafkaTopicPartition(topic,partition))	Collections.singletonMap(new KafkaTopicPartition(topic,partition),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka010FetcherTest	_1 375 _2 373	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(topic,partition)	java.util.Collections	v0 new KafkaTopicPartition(topic,partition)	AssignedTo	True
List<KafkaTopicPartition> topics=Collections.singletonList(new KafkaTopicPartition(topic,partition));	Map<KafkaTopicPartition,Long> partitionsWithInitialOffsets=Collections.singletonMap(new KafkaTopicPartition(topic,partition),KafkaTopicPartitionStateSentinel.GROUP_OFFSET);	Collections.singletonList(new KafkaTopicPartition(topic,partition))	Collections.singletonMap(new KafkaTopicPartition(topic,partition),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka010FetcherTest	_1 375 _2 373	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(topic,partition)	java.util.Collections	v0 new KafkaTopicPartition(topic,partition)	AssignedTo	True
topics = Collections.singletonList(new KafkaTopicPartition(STR0,42))	partitionsWithInitialOffsets = Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	Collections.singletonList(new KafkaTopicPartition(STR0,42))	Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka010FetcherTest	_1 259 _2 258	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(STR0,42)	java.util.Collections	v0 new KafkaTopicPartition(STR0,42)	AssignedTo	True
List<KafkaTopicPartition> topics=Collections.singletonList(new KafkaTopicPartition(STR0,42));	Map<KafkaTopicPartition,Long> partitionsWithInitialOffsets=Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET);	Collections.singletonList(new KafkaTopicPartition(STR0,42))	Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka010FetcherTest	_1 259 _2 258	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(STR0,42)	java.util.Collections	v0 new KafkaTopicPartition(STR0,42)	AssignedTo	True
topics = Collections.singletonList(new KafkaTopicPartition(STR0,42))	partitionsWithInitialOffsets = Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	Collections.singletonList(new KafkaTopicPartition(STR0,42))	Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka010FetcherTest	_1 121 _2 121	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(STR0,42)	java.util.Collections	v0 new KafkaTopicPartition(STR0,42)	AssignedTo	True
List<KafkaTopicPartition> topics=Collections.singletonList(new KafkaTopicPartition(STR0,42));	Map<KafkaTopicPartition,Long> partitionsWithInitialOffsets=Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET);	Collections.singletonList(new KafkaTopicPartition(STR0,42))	Collections.singletonMap(new KafkaTopicPartition(STR0,42),KafkaTopicPartitionStateSentinel.GROUP_OFFSET)	flink	ed68fedbe90db03823d75a020510ad3c344fa73e	org.apache.flink.streaming.connectors.kafka.Kafka010FetcherTest	_1 121 _2 121	_1 topics _2 partitionsWithInitialOffsets	v0 new KafkaTopicPartition(STR0,42)	java.util.Collections	v0 new KafkaTopicPartition(STR0,42)	AssignedTo	True