OriginalCompleteBefore	OriginalCompleteAfter	Before	After	Project	Commit	CompilationUnit	LineNos	Names	TemplateVariableToCodeBefore	RelevantImports	TemplateVariableToCodeAfter	isRelevant	isSafe
return client.getLookup().getTopicsUnderNamespace(namespace,Mode.NON_PERSISTENT).get();	return client.getLookup().getTopicsUnderNamespace(namespace,Mode.NON_PERSISTENT);	client.getLookup().getTopicsUnderNamespace(namespace,Mode.NON_PERSISTENT).get()	client.getLookup().getTopicsUnderNamespace(namespace,Mode.NON_PERSISTENT)	pulsar	871a1e028febc45742842754a801073a47d71698	org.apache.pulsar.broker.namespace.NamespaceService	_1 941 _2 941	_1 getNonPersistentTopicsFromPeerCluster _2 getNonPersistentTopicsFromPeerCluster	v0 client.getLookup().getTopicsUnderNamespace(namespace,Mode.NON_PERSISTENT)		v0 client.getLookup().getTopicsUnderNamespace(namespace,Mode.NON_PERSISTENT)	Returns	True
return dispatcherGatewayRetriever.getFuture().get();	return dispatcherGatewayRetriever.getFuture();	dispatcherGatewayRetriever.getFuture().get()	dispatcherGatewayRetriever.getFuture()	flink	6d9b6ca3f61bb0c66812b8bed5c63d833a2bf26a	org.apache.flink.runtime.minicluster.MiniCluster	_1 733 _2 670	_1 getDispatcherGateway _2 getDispatcherGatewayFuture	v0 dispatcherGatewayRetriever.getFuture()		v0 dispatcherGatewayRetriever.getFuture()	Returns	True
return miniCluster.stopWithSavepoint(jobId,savepointDirector,advanceToEndOfEventTime).get();	return miniCluster.stopWithSavepoint(jobId,savepointDirector,advanceToEndOfEventTime);	miniCluster.stopWithSavepoint(jobId,savepointDirector,advanceToEndOfEventTime).get()	miniCluster.stopWithSavepoint(jobId,savepointDirector,advanceToEndOfEventTime)	flink	d938c19480c220344827271ff8da729cd91735b3	org.apache.flink.client.program.MiniClusterClient	_1 80 _2 88	_1 stopWithSavepoint _2 stopWithSavepoint	v0 miniCluster.stopWithSavepoint(jobId,savepointDirector,advanceToEndOfEventTime)		v0 miniCluster.stopWithSavepoint(jobId,savepointDirector,advanceToEndOfEventTime)	Returns	True
return miniCluster.triggerSavepoint(jobId,savepointDirectory,true).get();	return miniCluster.triggerSavepoint(jobId,savepointDirectory,true);	miniCluster.triggerSavepoint(jobId,savepointDirectory,true).get()	miniCluster.triggerSavepoint(jobId,savepointDirectory,true)	flink	d938c19480c220344827271ff8da729cd91735b3	org.apache.flink.client.program.MiniClusterClient	_1 75 _2 83	_1 cancelWithSavepoint _2 cancelWithSavepoint	v0 miniCluster.triggerSavepoint(jobId,savepointDirectory,true)		v0 miniCluster.triggerSavepoint(jobId,savepointDirectory,true)	Returns	True