Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Other TODOs from LlapTaskUmbilicalExternalClient:
- From submitWork():
// // TODO Also send out information saying that the fragment is finishable - if that is not already included in the main fragment. // // This entire call is only required if we're doing more than scans. MRInput has no dependencies and is always finishable // QueryIdentifierProto queryIdentifier = QueryIdentifierProto // .newBuilder() // .setAppIdentifier(submitWorkRequestProto.getApplicationIdString()).setDagIdentifier(submitWorkRequestProto.getFragmentSpec().getDagId()) // .build(); // LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto sourceStateUpdatedRequest = // LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.newBuilder().setQueryIdentifier(queryIdentifier).setState( // LlapDaemonProtocolProtos.SourceStateProto.S_SUCCEEDED). // setSrcName(TODO) // communicator.sendSourceStateUpdate(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.newBuilder().setQueryIdentifier(submitWorkRequestProto.getFragmentSpec().getFragmentIdentifierString()).set);
- HeartbeatCheckTask.run(): If the heartbeat times out and we abandon the LLAP task, we may want to notify the LLAP daemon that we are no longer interested in this task.