[ 
https://issues.apache.org/jira/browse/SAMZA-780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14935804#comment-14935804
 ] 

Navina Ramesh commented on SAMZA-780:
-------------------------------------

Just committed. Thanks for the RB!  :) 
We can skip RB for small 1 or 2 line changes! Thanks for your contribution!

> Exception in thread "Container Allocator Thread" 
> java.lang.ClassCastException: org.apache.hadoop.security.token.Token cannot 
> be cast to org.apache.hadoop.security.token.TokenIdentifier
> ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: SAMZA-780
>                 URL: https://issues.apache.org/jira/browse/SAMZA-780
>             Project: Samza
>          Issue Type: Bug
>          Components: yarn
>    Affects Versions: 0.10.0
>            Reporter: Michael Martin
>            Assignee: Michael Martin
>            Priority: Blocker
>         Attachments: SAMZA-780.patch
>
>
> When running a Samza job in Hadoop 2.6.0 against the latest source code I get 
> the following error:
> {code}
> java version "1.8.0_60"
> Java(TM) SE Runtime Environment (build 1.8.0_60-b27)
> Java HotSpot(TM) 64-Bit Server VM (build 25.60-b23, mixed mode)
> Exception in thread "Container Allocator Thread" 
> java.lang.ClassCastException: org.apache.hadoop.security.token.Token cannot 
> be cast to org.apache.hadoop.security.token.TokenIdentifier
>       at 
> org.apache.samza.job.yarn.ContainerUtil.startContainer(ContainerUtil.java:174)
>       at 
> org.apache.samza.job.yarn.ContainerUtil.runContainer(ContainerUtil.java:109)
>       at 
> org.apache.samza.job.yarn.ContainerAllocator.run(ContainerAllocator.java:66)
>       at java.lang.Thread.run(Thread.java:745)
> {code}
> The offending line of code is attempting an invalid cast, and instead should 
> be doing something like:
> {code}
> TokenIdentifier token = ((Token) iter.next()).decodeIdentifier();
> {code}
> See 
> https://github.com/apache/hadoop/blob/release-2.6.0/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/security/token/Token.java
>  for reference



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to