OriginalCompleteBefore

OriginalCompleteAfter

Before

After

Project

Commit

CompilationUnit

LineNos

Names

TemplateVariableToCodeBefore

RelevantImports

TemplateVariableToCodeAfter

isRelevant

isSafe

slotSharingID = streamGraph.getStreamNode(entry.getKey()).getSlotSharingID()

slotSharingGroup = streamGraph.getStreamNode(entry.getKey()).getSlotSharingGroup()

streamGraph.getStreamNode(entry.getKey()).getSlotSharingID()

streamGraph.getStreamNode(entry.getKey()).getSlotSharingGroup()

flink

c40cfd317947b6b0f384ac3e067c0939a4586810

org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator

_1	422
_2	421

_1	slotSharingID
_2	slotSharingGroup

v0	streamGraph.getStreamNode(entry.getKey())

v0	streamGraph.getStreamNode(entry.getKey())

AssignedTo

True

int slotSharingID=streamGraph.getStreamNode(entry.getKey()).getSlotSharingID();

String slotSharingGroup=streamGraph.getStreamNode(entry.getKey()).getSlotSharingGroup();