You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@hive.apache.org by "Sergey Shelukhin (JIRA)" <ji...@apache.org> on 2016/05/10 22:54:13 UTC
[jira] [Commented] (HIVE-13651) LlapBaseInputFormat: figure out
where credentials come from
[ https://issues.apache.org/jira/browse/HIVE-13651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279151#comment-15279151 ]
Sergey Shelukhin commented on HIVE-13651:
-----------------------------------------
Oh, so this JIRA already exists. The serialized token will be a part of getSplits UDF output. Does it make sense after that?
> LlapBaseInputFormat: figure out where credentials come from
> -----------------------------------------------------------
>
> Key: HIVE-13651
> URL: https://issues.apache.org/jira/browse/HIVE-13651
> Project: Hive
> Issue Type: Sub-task
> Components: llap
> Reporter: Jason Dere
>
> todo in LlapBaseInputFormat.constructSubmitWorkRequestProto()
> {code}
> // 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));
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)