You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Michael Martin (JIRA)" <ji...@apache.org> on 2015/09/29 05:23:04 UTC
[jira] [Created] (SAMZA-780) 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
Michael Martin created SAMZA-780:
------------------------------------
Summary: 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
Priority: Blocker
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)