Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
todo in LlapBaseInputFormat.constructSubmitWorkRequestProto()
// TODO Figure out where credentials will come from. Normally Hive sets up // URLs on the tez dag, for which Tez acquires credentials. // taskCredentials.addAll(getContext().getCredentials()); // Preconditions.checkState(currentQueryIdentifierProto.getDagIdentifier() == // taskSpec.getTaskAttemptID().getTaskID().getVertexID().getDAGId().getId()); // ByteBuffer credentialsBinary = credentialMap.get(currentQueryIdentifierProto); // if (credentialsBinary == null) { // credentialsBinary = serializeCredentials(getContext().getCredentials()); // credentialMap.putIfAbsent(currentQueryIdentifierProto, credentialsBinary.duplicate()); // } else { // credentialsBinary = credentialsBinary.duplicate(); // } // builder.setCredentialsBinary(ByteString.copyFrom(credentialsBinary));