OriginalCompleteBefore	OriginalCompleteAfter	Before	After	Project	Commit	CompilationUnit	LineNos	Names	TemplateVariableToCodeBefore	RelevantImports	TemplateVariableToCodeAfter	isRelevant	isSafe
return stats;	return CompletableFuture.completedFuture(stats);	stats	CompletableFuture.completedFuture(stats)	pulsar	f3f82dd13ff8692ff25bdab80d5db67d500345fa	org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic	_1 819 _2 819	_1 getInternalStats _2 getInternalStats	v0 stats	java.util.concurrent.CompletableFuture	v0 stats	Returns	True
return STR0;	return CompletableFuture.completedFuture(STR0);	STR0	CompletableFuture.completedFuture(STR0)	flink	ab1fbfdfe6c1f2b6885710f98b9480cb90396ac0	org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler	_1 78 _2 81	_1 handleRequest _2 handleRequest	v0 STR0	java.util.concurrent.CompletableFuture	v0 STR0	Returns	True
return STR0;	return CompletableFuture.completedFuture(STR0);	STR0	CompletableFuture.completedFuture(STR0)	flink	ab1fbfdfe6c1f2b6885710f98b9480cb90396ac0	org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler	_1 78 _2 81	_1 handleRequest _2 handleRequest	v0 STR0	java.util.concurrent.CompletableFuture	v0 STR0	Returns	True
return STR0;	return CompletableFuture.completedFuture(STR0);	STR0	CompletableFuture.completedFuture(STR0)	flink	ab1fbfdfe6c1f2b6885710f98b9480cb90396ac0	org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler	_1 78 _2 81	_1 handleRequest _2 handleRequest	v0 STR0	java.util.concurrent.CompletableFuture	v0 STR0	Returns	True
return STR0;	return CompletableFuture.completedFuture(STR0);	STR0	CompletableFuture.completedFuture(STR0)	flink	ab1fbfdfe6c1f2b6885710f98b9480cb90396ac0	org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler	_1 78 _2 81	_1 handleRequest _2 handleRequest	v0 STR0	java.util.concurrent.CompletableFuture	v0 STR0	Returns	True
return STR0;	return CompletableFuture.completedFuture(STR0);	STR0	CompletableFuture.completedFuture(STR0)	flink	ab1fbfdfe6c1f2b6885710f98b9480cb90396ac0	org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler	_1 78 _2 81	_1 handleRequest _2 handleRequest	v0 STR0	java.util.concurrent.CompletableFuture	v0 STR0	Returns	True
return writer.toString();	return CompletableFuture.completedFuture(writer.toString());	writer.toString()	CompletableFuture.completedFuture(writer.toString())	flink	ab1fbfdfe6c1f2b6885710f98b9480cb90396ac0	org.apache.flink.runtime.webmonitor.handlers.JobVertexBackPressureHandler	_1 68 _2 73	_1 handleRequest _2 handleRequest	v0 writer.toString()	java.util.concurrent.CompletableFuture	v0 writer.toString()	Returns	True
return STR0;	return CompletableFuture.completedFuture(STR0);	STR0	CompletableFuture.completedFuture(STR0)	flink	ab1fbfdfe6c1f2b6885710f98b9480cb90396ac0	org.apache.flink.runtime.webmonitor.handlers.JobVertexBackPressureHandler	_1 68 _2 73	_1 handleRequest _2 handleRequest	v0 STR0	java.util.concurrent.CompletableFuture	v0 STR0	Returns	True
return graph.getJsonPlan();	return CompletableFuture.completedFuture(graph.getJsonPlan());	graph.getJsonPlan()	CompletableFuture.completedFuture(graph.getJsonPlan())	flink	ab1fbfdfe6c1f2b6885710f98b9480cb90396ac0	org.apache.flink.runtime.webmonitor.handlers.JobPlanHandler	_1 47 _2 49	_1 handleRequest _2 handleRequest	v0 graph.getJsonPlan()	java.util.concurrent.CompletableFuture	v0 graph.getJsonPlan()	Returns	True
return ERROR_MESSAGE;	return CompletableFuture.completedFuture(ERROR_MESSAGE);	ERROR_MESSAGE	CompletableFuture.completedFuture(ERROR_MESSAGE)	flink	ab1fbfdfe6c1f2b6885710f98b9480cb90396ac0	org.apache.flink.runtime.webmonitor.handlers.JarAccessDeniedHandler	_1 44 _2 50	_1 handleJsonRequest _2 handleJsonRequest	v0 ERROR_MESSAGE	java.util.concurrent.CompletableFuture	v0 ERROR_MESSAGE	Returns	True
return Optional.of(cached);	return CompletableFuture.completedFuture(Optional.of(cached));	Optional.of(cached)	CompletableFuture.completedFuture(Optional.of(cached))	flink	ab1fbfdfe6c1f2b6885710f98b9480cb90396ac0	org.apache.flink.runtime.webmonitor.ExecutionGraphHolder	_1 62 _2 61	_1 getExecutionGraph _2 getExecutionGraph	v0 Optional.of(cached)	java.util.concurrent.CompletableFuture	v0 Optional.of(cached)	Returns	True
return InMemoryBatchIterator.of(rows,SentinelRow.SENTINEL,functionImplementation.hasLazyResultSet());	return CompletableFuture.completedFuture(InMemoryBatchIterator.of(rows,SentinelRow.SENTINEL,functionImplementation.hasLazyResultSet()));	InMemoryBatchIterator.of(rows,SentinelRow.SENTINEL,functionImplementation.hasLazyResultSet())	CompletableFuture.completedFuture(InMemoryBatchIterator.of(rows,SentinelRow.SENTINEL,functionImplementation.hasLazyResultSet()))	crate	6f9c1c65c7403c465d4c181b79babf8459a5182e	io.crate.execution.engine.collect.sources.TableFunctionCollectSource	_1 60 _2 61	_1 getIterator _2 getIterator	v0 InMemoryBatchIterator.of(rows,SentinelRow.SENTINEL,functionImplementation.hasLazyResultSet())	java.util.concurrent.CompletableFuture	v0 InMemoryBatchIterator.of(rows,SentinelRow.SENTINEL,functionImplementation.hasLazyResultSet())	Returns	True
return projectors.wrap(InMemoryBatchIterator.of(getShardsIterator(collectTask.txnCtx(),collectPhase,localNodeId),SentinelRow.SENTINEL,true));	return CompletableFuture.completedFuture(projectors.wrap(InMemoryBatchIterator.of(getShardsIterator(collectTask.txnCtx(),collectPhase,localNodeId),SentinelRow.SENTINEL,true)));	projectors.wrap(InMemoryBatchIterator.of(getShardsIterator(collectTask.txnCtx(),collectPhase,localNodeId),SentinelRow.SENTINEL,true))	CompletableFuture.completedFuture(projectors.wrap(InMemoryBatchIterator.of(getShardsIterator(collectTask.txnCtx(),collectPhase,localNodeId),SentinelRow.SENTINEL,true)))	crate	6f9c1c65c7403c465d4c181b79babf8459a5182e	io.crate.execution.engine.collect.sources.ShardCollectSource	_1 261 _2 263	_1 getIterator _2 getIterator	v0 projectors.wrap(InMemoryBatchIterator.of(getShardsIterator(collectTask.txnCtx(),collectPhase,localNodeId),SentinelRow.SENTINEL,true))	java.util.concurrent.CompletableFuture	v0 projectors.wrap(InMemoryBatchIterator.of(getShardsIterator(collectTask.txnCtx(),collectPhase,localNodeId),SentinelRow.SENTINEL,true))	Returns	True
return FileReadingIterator.newInstance(fileUris,ctx.topLevelInputs(),ctx.expressions(),fileUriCollectPhase.compression(),fileInputFactoryMap,fileUriCollectPhase.sharedStorage(),fileUriCollectPhase.nodeIds().size(),getReaderNumber(fileUriCollectPhase.nodeIds(),clusterService.state().nodes().getLocalNodeId()),fileUriCollectPhase.inputFormat());	return CompletableFuture.completedFuture(FileReadingIterator.newInstance(fileUris,ctx.topLevelInputs(),ctx.expressions(),fileUriCollectPhase.compression(),fileInputFactoryMap,fileUriCollectPhase.sharedStorage(),fileUriCollectPhase.nodeIds().size(),getReaderNumber(fileUriCollectPhase.nodeIds(),clusterService.state().nodes().getLocalNodeId()),fileUriCollectPhase.inputFormat()));	FileReadingIterator.newInstance(fileUris,ctx.topLevelInputs(),ctx.expressions(),fileUriCollectPhase.compression(),fileInputFactoryMap,fileUriCollectPhase.sharedStorage(),fileUriCollectPhase.nodeIds().size(),getReaderNumber(fileUriCollectPhase.nodeIds(),clusterService.state().nodes().getLocalNodeId()),fileUriCollectPhase.inputFormat())	CompletableFuture.completedFuture(FileReadingIterator.newInstance(fileUris,ctx.topLevelInputs(),ctx.expressions(),fileUriCollectPhase.compression(),fileInputFactoryMap,fileUriCollectPhase.sharedStorage(),fileUriCollectPhase.nodeIds().size(),getReaderNumber(fileUriCollectPhase.nodeIds(),clusterService.state().nodes().getLocalNodeId()),fileUriCollectPhase.inputFormat()))	crate	6f9c1c65c7403c465d4c181b79babf8459a5182e	io.crate.execution.engine.collect.sources.FileCollectSource	_1 68 _2 69	_1 getIterator _2 getIterator	v0 FileReadingIterator.newInstance(fileUris,ctx.topLevelInputs(),ctx.expressions(),fileUriCollectPhase.compression(),fileInputFactoryMap,fileUriCollectPhase.sharedStorage(),fileUriCollectPhase.nodeIds().size(),getReaderNumber(fileUriCollectPhase.nodeIds(),clusterService.state().nodes().getLocalNodeId()),fileUriCollectPhase.inputFormat())	java.util.concurrent.CompletableFuture	v0 FileReadingIterator.newInstance(fileUris,ctx.topLevelInputs(),ctx.expressions(),fileUriCollectPhase.compression(),fileInputFactoryMap,fileUriCollectPhase.sharedStorage(),fileUriCollectPhase.nodeIds().size(),getReaderNumber(fileUriCollectPhase.nodeIds(),clusterService.state().nodes().getLocalNodeId()),fileUriCollectPhase.inputFormat())	Returns	True
return InMemoryBatchIterator.empty(SentinelRow.SENTINEL);	return CompletableFuture.completedFuture(InMemoryBatchIterator.empty(SentinelRow.SENTINEL));	InMemoryBatchIterator.empty(SentinelRow.SENTINEL)	CompletableFuture.completedFuture(InMemoryBatchIterator.empty(SentinelRow.SENTINEL))	crate	6f9c1c65c7403c465d4c181b79babf8459a5182e	io.crate.execution.engine.collect.sources.CollectSourceResolver.VoidCollectSource	_1 180 _2 181	_1 getIterator _2 getIterator	v0 InMemoryBatchIterator.empty(SentinelRow.SENTINEL)	java.util.concurrent.CompletableFuture	v0 InMemoryBatchIterator.empty(SentinelRow.SENTINEL)	Returns	True
return topics;	return CompletableFuture.completedFuture(topics);	topics	CompletableFuture.completedFuture(topics)	pulsar	871a1e028febc45742842754a801073a47d71698	org.apache.pulsar.broker.namespace.NamespaceService	_1 906 _2 907	_1 getListOfNonPersistentTopics _2 getListOfNonPersistentTopics	v0 topics	java.util.concurrent.CompletableFuture	v0 topics	Returns	True
return true;	return CompletableFuture.completedFuture(true);	true	CompletableFuture.completedFuture(true)	pulsar	48f5a2f62c148b3df617be060fefed51f3145979	org.apache.pulsar.broker.authorization.AuthorizationService	_1 496 _2 363	_1 allowTopicOperation _2 allowTenantOperationAsync	v0 true	java.util.concurrent.CompletableFuture	v0 true	Returns	True
return true;	return CompletableFuture.completedFuture(true);	true	CompletableFuture.completedFuture(true)	pulsar	48f5a2f62c148b3df617be060fefed51f3145979	org.apache.pulsar.broker.authorization.AuthorizationService	_1 455 _2 424	_1 allowNamespacePolicyOperation _2 allowNamespaceOperationAsync	v0 true	java.util.concurrent.CompletableFuture	v0 true	Returns	True
return resolveInfo;	return CompletableFuture.completedFuture(resolveInfo);	resolveInfo	CompletableFuture.completedFuture(resolveInfo)	platform_frameworks_base	149e0fe89e59e92f63c40c75c3f4aec1dd38210a	com.android.internal.app.IntentForwarderActivityTest.TestInjector	_1 673 _2 680	_1 resolveActivityAsUser _2 resolveActivityAsUser	v0 resolveInfo	java.util.concurrent.CompletableFuture	v0 resolveInfo	Returns	True
return this;	return CompletableFuture.completedFuture(this);	this	CompletableFuture.completedFuture(this)	armeria	429b658cf057be454691b2489270cc4ca4f55fb6	com.linecorp.armeria.client.Endpoint	_1 119 _2 121	_1 resolve _2 resolve	v0 this	java.util.concurrent.CompletableFuture	v0 this	Returns	True
return configurationManager.getConfiguration(cacheName,true);	return CompletableFuture.completedFuture(configurationManager.getConfiguration(cacheName,true));	configurationManager.getConfiguration(cacheName,true)	CompletableFuture.completedFuture(configurationManager.getConfiguration(cacheName,true))	infinispan	978848177b76e8432be98efa8d94031b25e8b769	org.infinispan.globalstate.impl.GlobalConfigurationManagerImpl	_1 128 _2 135	_1 getOrCreateCache _2 getOrCreateCache	v0 configurationManager.getConfiguration(cacheName,true)	java.util.concurrent.CompletableFuture	v0 configurationManager.getConfiguration(cacheName,true)	Returns	True
return null;	return CompletableFuture.completedFuture(null);	null	CompletableFuture.completedFuture(null)	pulsar	91c4254cae3be91774220c9fea145d3e433b6a01	org.apache.pulsar.client.impl.schema.generic.MultiVersionSchemaInfoProvider	_1 59 _2 69	_1 getSchemaByVersion _2 getSchemaByVersion	v0 null	java.util.concurrent.CompletableFuture	v0 null	Returns	True
return schemaInfo;	return CompletableFuture.completedFuture(schemaInfo);	schemaInfo	CompletableFuture.completedFuture(schemaInfo)	pulsar	91c4254cae3be91774220c9fea145d3e433b6a01	org.apache.pulsar.client.impl.schema.KeyValueSchema.KeyValueSchema	_1 149 _2 152	_1 getLatestSchema _2 getLatestSchema	v0 schemaInfo	java.util.concurrent.CompletableFuture	v0 schemaInfo	Returns	True
return schemaInfo;	return CompletableFuture.completedFuture(schemaInfo);	schemaInfo	CompletableFuture.completedFuture(schemaInfo)	pulsar	91c4254cae3be91774220c9fea145d3e433b6a01	org.apache.pulsar.client.impl.schema.KeyValueSchema.KeyValueSchema	_1 144 _2 147	_1 getSchemaByVersion _2 getSchemaByVersion	v0 schemaInfo	java.util.concurrent.CompletableFuture	v0 schemaInfo	Returns	True
return response;	return CompletableFuture.completedFuture(response);	response	CompletableFuture.completedFuture(response)	beam	2495a0496b2bae5cc59a2b9fab7c526e2bec0ca0	org.apache.beam.sdk.io.aws2.sns.SnsClientMockSuccess	_1 35 _2 40	_1 publish _2 publish	v0 response	java.util.concurrent.CompletableFuture	v0 response	Returns	True
return null;	return CompletableFuture.completedFuture(null);	null	CompletableFuture.completedFuture(null)	hbase	72270866cbacbcfd10f2ad2cce33362577eeef4d	org.apache.hadoop.hbase.client.TestBufferedMutator.DoNothingRegistry	_1 58 _2 41	_1 getClusterId _2 getClusterId	v0 null	java.util.concurrent.CompletableFuture	v0 null	Returns	True
return null;	return CompletableFuture.completedFuture(null);	null	CompletableFuture.completedFuture(null)	hbase	72270866cbacbcfd10f2ad2cce33362577eeef4d	org.apache.hadoop.hbase.client.TestBufferedMutator.DoNothingRegistry	_1 52 _2 36	_1 getMetaRegionLocation _2 getMetaRegionLocation	v0 null	java.util.concurrent.CompletableFuture	v0 null	Returns	True
return STR0;	return CompletableFuture.completedFuture(STR0);	STR0	CompletableFuture.completedFuture(STR0)	hbase	72270866cbacbcfd10f2ad2cce33362577eeef4d	org.apache.hadoop.hbase.client.TestAsyncProcess.MyConnectionImpl.TestRegistry	_1 468 _2 466	_1 getClusterId _2 getClusterId	v0 STR0	java.util.concurrent.CompletableFuture	v0 STR0	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.taskexecutor.TaskExecutor	_1 539 _2 552	_1 confirmCheckpoint _2 confirmCheckpoint	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.taskexecutor.TaskExecutor	_1 521 _2 530	_1 triggerCheckpoint _2 triggerCheckpoint	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.taskexecutor.TaskExecutor	_1 561 _2 577	_1 requestSlot _2 requestSlot	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.taskexecutor.TaskExecutor	_1 446 _2 454	_1 updatePartitions _2 updatePartitions	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.taskexecutor.TaskExecutor	_1 446 _2 454	_1 updatePartitions _2 updatePartitions	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.taskexecutor.TaskExecutor	_1 423 _2 431	_1 stopTask _2 stopTask	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.taskexecutor.TaskExecutor	_1 404 _2 411	_1 cancelTask _2 cancelTask	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.taskexecutor.TaskExecutor	_1 291 _2 292	_1 submitTask _2 submitTask	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return taskExecutors.size();	return CompletableFuture.completedFuture(taskExecutors.size());	taskExecutors.size()	CompletableFuture.completedFuture(taskExecutors.size())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.resourcemanager.ResourceManager	_1 539 _2 547	_1 getNumberOfRegisteredTaskManagers _2 getNumberOfRegisteredTaskManagers	v0 taskExecutors.size()	java.util.concurrent.CompletableFuture	v0 taskExecutors.size()	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.resourcemanager.ResourceManager	_1 410 _2 413	_1 requestSlot _2 requestSlot	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return new ClassloadingProps(libraryCacheManager.getBlobServerPort(),executionGraph.getRequiredJarFiles(),executionGraph.getRequiredClasspaths());	return CompletableFuture.completedFuture(new ClassloadingProps(libraryCacheManager.getBlobServerPort(),executionGraph.getRequiredJarFiles(),executionGraph.getRequiredClasspaths()));	new ClassloadingProps(libraryCacheManager.getBlobServerPort(),executionGraph.getRequiredJarFiles(),executionGraph.getRequiredClasspaths())	CompletableFuture.completedFuture(new ClassloadingProps(libraryCacheManager.getBlobServerPort(),executionGraph.getRequiredJarFiles(),executionGraph.getRequiredClasspaths()))	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.jobmaster.JobMaster	_1 675 _2 697	_1 requestClassloadingProps _2 requestClassloadingProps	v0 new ClassloadingProps(libraryCacheManager.getBlobServerPort(),executionGraph.getRequiredJarFiles(),executionGraph.getRequiredClasspaths())	java.util.concurrent.CompletableFuture	v0 new ClassloadingProps(libraryCacheManager.getBlobServerPort(),executionGraph.getRequiredJarFiles(),executionGraph.getRequiredClasspaths())	Returns	True
return location;	return CompletableFuture.completedFuture(location);	location	CompletableFuture.completedFuture(location)	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.jobmaster.JobMaster	_1 619 _2 641	_1 lookupKvStateLocation _2 lookupKvStateLocation	v0 location	java.util.concurrent.CompletableFuture	v0 location	Returns	True
return producerExecution.getState();	return CompletableFuture.completedFuture(producerExecution.getState());	producerExecution.getState()	CompletableFuture.completedFuture(producerExecution.getState())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.jobmaster.JobMaster	_1 501 _2 515	_1 requestPartitionState _2 requestPartitionState	v0 producerExecution.getState()	java.util.concurrent.CompletableFuture	v0 producerExecution.getState()	Returns	True
return execution.getState();	return CompletableFuture.completedFuture(execution.getState());	execution.getState()	CompletableFuture.completedFuture(execution.getState())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.jobmaster.JobMaster	_1 501 _2 515	_1 requestPartitionState _2 requestPartitionState	v0 execution.getState()	java.util.concurrent.CompletableFuture	v0 execution.getState()	Returns	True
return new SerializedInputSplit(serializedInputSplit);	return CompletableFuture.completedFuture(new SerializedInputSplit(serializedInputSplit));	new SerializedInputSplit(serializedInputSplit)	CompletableFuture.completedFuture(new SerializedInputSplit(serializedInputSplit))	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.jobmaster.JobMaster	_1 449 _2 459	_1 requestNextInputSplit _2 requestNextInputSplit	v0 new SerializedInputSplit(serializedInputSplit)	java.util.concurrent.CompletableFuture	v0 new SerializedInputSplit(serializedInputSplit)	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.jobmaster.JobMaster	_1 427 _2 431	_1 updateTaskExecutionState _2 updateTaskExecutionState	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.jobmaster.JobMaster	_1 536 _2 554	_1 scheduleOrUpdateConsumers _2 scheduleOrUpdateConsumers	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return jobManagerRunners.keySet();	return CompletableFuture.completedFuture(jobManagerRunners.keySet());	jobManagerRunners.keySet()	CompletableFuture.completedFuture(jobManagerRunners.keySet())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.dispatcher.Dispatcher	_1 195 _2 201	_1 listJobs _2 listJobs	v0 jobManagerRunners.keySet()	java.util.concurrent.CompletableFuture	v0 jobManagerRunners.keySet()	Returns	True
return Acknowledge.get();	return CompletableFuture.completedFuture(Acknowledge.get());	Acknowledge.get()	CompletableFuture.completedFuture(Acknowledge.get())	flink	d95d20eb45185151d731c9b41e9b1ac22cf81334	org.apache.flink.runtime.dispatcher.Dispatcher	_1 134 _2 136	_1 submitJob _2 submitJob	v0 Acknowledge.get()	java.util.concurrent.CompletableFuture	v0 Acknowledge.get()	Returns	True
return null;	return CompletableFuture.completedFuture(null);	null	CompletableFuture.completedFuture(null)	atomix	fa46abdd6f9ab4e77365ab6ce05d4cfd960fd0ae	io.atomix.core.impl.CorePrimitivesService	_1 284 _2 288	_1 getPrimitive _2 getPrimitiveAsync	v0 null	java.util.concurrent.CompletableFuture	v0 null	Returns	True