OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
offsets = (HashMap<KafkaTopicPartition,Long>)pendingOffsetsToCommit.remove(posInMap)offsets = (Map<KafkaTopicPartition,Long>)pendingOffsetsToCommit.remove(posInMap)(HashMap<KafkaTopicPartition,Long>)pendingOffsetsToCommit.remove(posInMap)(Map<KafkaTopicPartition,Long>)pendingOffsetsToCommit.remove(posInMap)flink085d4db849b9c659ba6bb2c7d66a04debeb048c4org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase
_1614
_2776
_1offsets
_2offsets
v0pendingOffsetsToCommit.remove(posInMap)
v0pendingOffsetsToCommit.remove(posInMap)
AssignedToTrue