OriginalCompleteBefore	OriginalCompleteAfter	Before	After	Project	Commit	CompilationUnit	LineNos	Names	TemplateVariableToCodeBefore	RelevantImports	TemplateVariableToCodeAfter	isRelevant	isSafe
infoMessageListenerRpcGatewayFuture.thenAcceptAsync(new AcceptFunction<InfoMessageListenerRpcGateway>(){ @Override public void accept( InfoMessageListenerRpcGateway gateway){ log.info(STR0,infoMessageListenerAddress); infoMessageListeners.put(infoMessageListenerAddress,gateway); }},getMainThreadExecutor());	infoMessageListenerRpcGatewayFuture.thenAcceptAsync(new AcceptFunction<InfoMessageListenerRpcGateway>(){ @Override public void accept( InfoMessageListenerRpcGateway gateway){ log.info(STR0,address); infoMessageListeners.put(address,gateway); }},getMainThreadExecutor());	infoMessageListeners.put(infoMessageListenerAddress,gateway)	infoMessageListeners.put(address,gateway)	flink	70af08c62f1d30929a34314f8a5f704e2c44d5a1	org.apache.flink.runtime.resourcemanager.ResourceManager	_1 110 _2 122	_1 infoMessageListeners _2 infoMessageListeners	TCIVar infoMessageListeners v1 gateway		TCIVar infoMessageListeners v1 gateway	Uses	False