<BUG>LOG.log(Level.FINEST, "RuntimeStart: {0}", runtimeStart);this.remoteManager.registerHandler(EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.class,evaluatorHeartbeatHandler);this.remoteManager.registerHandler(ReefServiceProtos.RuntimeErrorProto.class, evaluatorResourceManagerErrorHandler);this.resourceManagerStatus.setRunning();</BUG><CONTEXT>this.resourceManagerStartHandler = resourceManagerStartHandler;this.driverStatusManager = driverStatusManager;}@Overridepublic synchronized void onNext(final RuntimeStart runtimeStart) {<extra_id_0>this.driverStatusManager.onRunning();</CONTEXT>
this.remoteManager.registerHandler(this.evaluatorHeartbeatHandler);this.remoteManager.registerHandler(ReefServiceProtos.RuntimeErrorProto.class,this.evaluatorResourceManagerErrorHandler);this.resourceManagerStatus.setRunning();