test_class.declarator: system
test_class.modifier: private static
test_class.original_string: private static ActorSystem system;
test_class.type: ActorSystem
test_class.var_name: system
test_class.declarator: testJobGraph = new JobGraph("Test Job")
test_class.modifier: private static
test_class.original_string: private static JobGraph testJobGraph = new JobGraph("Test Job");
test_class.type: JobGraph
test_class.var_name: testJobGraph
test_class.file: flink-runtime/src/test/java/org/apache/flink/runtime/client/JobClientActorTest.java
test_class.identifier: JobClientActorTest
test_class.superclass: extends TestLogger
test_case.body: @Test(expected=JobClientActorConnectionTimeoutException.class)
  	public void testConnectionTimeoutAfterJobSubmission() throws Exception {
  		FiniteDuration jobClientActorTimeout = new FiniteDuration(5, TimeUnit.SECONDS);
  		FiniteDuration timeout = jobClientActorTimeout.$times(2);
  
  		UUID leaderSessionID = UUID.randomUUID();
  
  		ActorRef jobManager = system.actorOf(
  			Props.create(
  				JobAcceptingActor.class,
  				leaderSessionID));
  
  		TestingLeaderRetrievalService testingLeaderRetrievalService = new TestingLeaderRetrievalService(
  			jobManager.path().toString(),
  			leaderSessionID
  		);
  
  		Props jobClientActorProps = JobClientActor.createJobClientActorProps(
  			testingLeaderRetrievalService,
  			jobClientActorTimeout,
  			false);
  
  		ActorRef jobClientActor = system.actorOf(jobClientActorProps);
  
  		Future<Object> jobExecutionResult = Patterns.ask(
  			jobClientActor,
  			new JobClientMessages.SubmitJobAndWait(testJobGraph),
  			new Timeout(timeout));
  
  		Future<Object> waitFuture = Patterns.ask(jobManager, new RegisterTest(), new Timeout(timeout));
  
  		Await.result(waitFuture, timeout);
  
  		jobManager.tell(PoisonPill.getInstance(), ActorRef.noSender());
  
  		Await.result(jobExecutionResult, timeout);
  	}
test_case.class_method_signature: JobClientActorTest.testConnectionTimeoutAfterJobSubmission()
test_case.full_signature: @Test(expected=JobClientActorConnectionTimeoutException.class) public void testConnectionTimeoutAfterJobSubmission()
test_case.identifier: testConnectionTimeoutAfterJobSubmission
test_case.invocations: times randomUUID actorOf create toString path createJobClientActorProps actorOf ask ask result tell getInstance noSender result
test_case.modifiers: @Test(expected=JobClientActorConnectionTimeoutException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testConnectionTimeoutAfterJobSubmission()
focal_class.declarator: leaderRetrievalService
focal_class.modifier: private final
focal_class.original_string: private final LeaderRetrievalService leaderRetrievalService;
focal_class.type: LeaderRetrievalService
focal_class.var_name: leaderRetrievalService
focal_class.declarator: timeout
focal_class.modifier: private final
focal_class.original_string: private final FiniteDuration timeout;
focal_class.type: FiniteDuration
focal_class.var_name: timeout
focal_class.declarator: sysoutUpdates
focal_class.modifier: private final
focal_class.original_string: private final boolean sysoutUpdates;
focal_class.type: boolean
focal_class.var_name: sysoutUpdates
focal_class.declarator: jobSuccessfullySubmitted = false
focal_class.modifier: private
focal_class.original_string: private boolean jobSuccessfullySubmitted = false;
focal_class.type: boolean
focal_class.var_name: jobSuccessfullySubmitted
focal_class.declarator: terminated = false
focal_class.modifier: private
focal_class.original_string: private boolean terminated = false;
focal_class.type: boolean
focal_class.var_name: terminated
focal_class.declarator: jobManager
focal_class.modifier: private
focal_class.original_string: private ActorRef jobManager;
focal_class.type: ActorRef
focal_class.var_name: jobManager
focal_class.declarator: leaderSessionID
focal_class.modifier: private
focal_class.original_string: private UUID leaderSessionID;
focal_class.type: UUID
focal_class.var_name: leaderSessionID
focal_class.declarator: submitter
focal_class.modifier: private
focal_class.original_string: private ActorRef submitter;
focal_class.type: ActorRef
focal_class.var_name: submitter
focal_class.declarator: jobGraph
focal_class.modifier: private
focal_class.original_string: private JobGraph jobGraph;
focal_class.type: JobGraph
focal_class.var_name: jobGraph
focal_class.file: flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java
focal_class.identifier: JobClientActor
focal_class.interfaces: implements LeaderRetrievalListener
focal_class.class_method_signature: JobClientActor.JobClientActor(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_class.full_signature: public  JobClientActor(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_class.identifier: JobClientActor
focal_class.modifiers: public
focal_class.parameters: (
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_class.signature:  JobClientActor(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_class.class_method_signature: JobClientActor.preStart()
focal_class.full_signature: @Override public void preStart()
focal_class.identifier: preStart
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void preStart()
focal_class.class_method_signature: JobClientActor.postStop()
focal_class.full_signature: @Override public void postStop()
focal_class.identifier: postStop
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void postStop()
focal_class.class_method_signature: JobClientActor.handleMessage(Object message)
focal_class.full_signature: @Override protected void handleMessage(Object message)
focal_class.identifier: handleMessage
focal_class.modifiers: @Override protected
focal_class.parameters: (Object message)
focal_class.return: void
focal_class.signature: void handleMessage(Object message)
focal_class.class_method_signature: JobClientActor.getLeaderSessionID()
focal_class.full_signature: @Override protected UUID getLeaderSessionID()
focal_class.identifier: getLeaderSessionID
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: UUID
focal_class.signature: UUID getLeaderSessionID()
focal_class.class_method_signature: JobClientActor.logAndPrintMessage(ExecutionGraphMessages.ExecutionStateChanged message)
focal_class.full_signature: private void logAndPrintMessage(ExecutionGraphMessages.ExecutionStateChanged message)
focal_class.identifier: logAndPrintMessage
focal_class.modifiers: private
focal_class.parameters: (ExecutionGraphMessages.ExecutionStateChanged message)
focal_class.return: void
focal_class.signature: void logAndPrintMessage(ExecutionGraphMessages.ExecutionStateChanged message)
focal_class.class_method_signature: JobClientActor.logAndPrintMessage(ExecutionGraphMessages.JobStatusChanged message)
focal_class.full_signature: private void logAndPrintMessage(ExecutionGraphMessages.JobStatusChanged message)
focal_class.identifier: logAndPrintMessage
focal_class.modifiers: private
focal_class.parameters: (ExecutionGraphMessages.JobStatusChanged message)
focal_class.return: void
focal_class.signature: void logAndPrintMessage(ExecutionGraphMessages.JobStatusChanged message)
focal_class.class_method_signature: JobClientActor.notifyLeaderAddress(String leaderAddress, UUID leaderSessionID)
focal_class.full_signature: @Override public void notifyLeaderAddress(String leaderAddress, UUID leaderSessionID)
focal_class.identifier: notifyLeaderAddress
focal_class.modifiers: @Override public
focal_class.parameters: (String leaderAddress, UUID leaderSessionID)
focal_class.return: void
focal_class.signature: void notifyLeaderAddress(String leaderAddress, UUID leaderSessionID)
focal_class.class_method_signature: JobClientActor.handleError(Exception exception)
focal_class.full_signature: @Override public void handleError(Exception exception)
focal_class.identifier: handleError
focal_class.modifiers: @Override public
focal_class.parameters: (Exception exception)
focal_class.return: void
focal_class.signature: void handleError(Exception exception)
focal_class.class_method_signature: JobClientActor.disconnectFromJobManager()
focal_class.full_signature: private void disconnectFromJobManager()
focal_class.identifier: disconnectFromJobManager
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void disconnectFromJobManager()
focal_class.class_method_signature: JobClientActor.connectToJobManager(ActorRef jobManager)
focal_class.full_signature: private void connectToJobManager(ActorRef jobManager)
focal_class.identifier: connectToJobManager
focal_class.modifiers: private
focal_class.parameters: (ActorRef jobManager)
focal_class.return: void
focal_class.signature: void connectToJobManager(ActorRef jobManager)
focal_class.class_method_signature: JobClientActor.tryToSubmitJob(final JobGraph jobGraph)
focal_class.full_signature: private void tryToSubmitJob(final JobGraph jobGraph)
focal_class.identifier: tryToSubmitJob
focal_class.modifiers: private
focal_class.parameters: (final JobGraph jobGraph)
focal_class.return: void
focal_class.signature: void tryToSubmitJob(final JobGraph jobGraph)
focal_class.class_method_signature: JobClientActor.terminate()
focal_class.full_signature: private void terminate()
focal_class.identifier: terminate
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void terminate()
focal_class.class_method_signature: JobClientActor.isConnected()
focal_class.full_signature: private boolean isConnected()
focal_class.identifier: isConnected
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isConnected()
focal_class.class_method_signature: JobClientActor.hasJobBeenSubmitted()
focal_class.full_signature: private boolean hasJobBeenSubmitted()
focal_class.identifier: hasJobBeenSubmitted
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasJobBeenSubmitted()
focal_class.class_method_signature: JobClientActor.createJobClientActorProps(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_class.full_signature: public static Props createJobClientActorProps(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_class.identifier: createJobClientActorProps
focal_class.modifiers: public static
focal_class.parameters: (
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_class.return: Props
focal_class.signature: Props createJobClientActorProps(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_class.superclass: extends FlinkUntypedActor
focal_method.body: public static Props createJobClientActorProps(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates) {
  		return Props.create(
  			JobClientActor.class,
  			leaderRetrievalService,
  			timeout,
  			sysoutUpdates);
  	}
focal_method.class_method_signature: JobClientActor.createJobClientActorProps(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_method.full_signature: public static Props createJobClientActorProps(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_method.identifier: createJobClientActorProps
focal_method.invocations: create
focal_method.modifiers: public static
focal_method.parameters: (
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)
focal_method.return: Props
focal_method.signature: Props createJobClientActorProps(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout,
  			boolean sysoutUpdates)