apex-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "prakashduttaru@hotmail.com" <prakashdutt...@hotmail.com>
Subject SortedWordCount example is not running
Date Tue, 15 Nov 2016 10:06:30 GMT
Hi Support team

Not able to start SortedWordCount example because the apex console is
showing failed everytime when using list-apps command after putting the apa
file name with its part.
My hadoop configuration is :
It is single node cluster
hadoop 2.2
Java 1.7
OS:CentOS

The dt.log file is showing below error:

rent.stram.ResourceRequestHandler: Found host null
2016-11-15 14:24:27,473 INFO com.datatorrent.stram.ResourceRequestHandler:
Strict anti-affinity = [] for container with operators
PTOperator[id=1,name=lineReader]
2016-11-15 14:24:27,473 INFO com.datatorrent.stram.ResourceRequestHandler:
Found host null
2016-11-15 14:24:27,474 INFO com.datatorrent.stram.ResourceRequestHandler:
Strict anti-affinity = [] for container with operators
PTOperator[id=3,name=windowWordCount]
2016-11-15 14:24:27,474 INFO com.datatorrent.stram.ResourceRequestHandler:
Found host null
2016-11-15 14:24:27,474 INFO com.datatorrent.stram.ResourceRequestHandler:
Strict anti-affinity = [] for container with operators
PTOperator[id=5,name=wcWriter]
2016-11-15 14:24:27,474 INFO com.datatorrent.stram.ResourceRequestHandler:
Found host null
2016-11-15 14:24:27,474 INFO
com.datatorrent.stram.StreamingAppMasterService: Asking RM for containers:
[Capability[<memory:1024, vCores:1>]Priority[0], Capability[<memory:1024,
vCores:1>]Priority[1], Capability[<memory:1024, vCores:1>]Priority[2],
Capability[<memory:1024, vCores:1>]Priority[3], Capability[<memory:1024,
vCores:1>]Priority[4]]
2016-11-15 14:24:27,474 INFO
com.datatorrent.stram.StreamingAppMasterService: Requested container:
Capability[<memory:1024, vCores:1>]Priority[0] on host: [null]
2016-11-15 14:24:27,486 INFO
com.datatorrent.stram.StreamingAppMasterService: Requested container:
Capability[<memory:1024, vCores:1>]Priority[1] on host: [null]
2016-11-15 14:24:27,486 INFO
com.datatorrent.stram.StreamingAppMasterService: Requested container:
Capability[<memory:1024, vCores:1>]Priority[2] on host: [null]
2016-11-15 14:24:27,486 INFO
com.datatorrent.stram.StreamingAppMasterService: Requested container:
Capability[<memory:1024, vCores:1>]Priority[3] on host: [null]
2016-11-15 14:24:27,486 INFO
com.datatorrent.stram.StreamingAppMasterService: Requested container:
Capability[<memory:1024, vCores:1>]Priority[4] on host: [null]
2016-11-15 14:24:28,538 INFO
com.datatorrent.stram.StreamingAppMasterService: Got new container.,
containerId=container_1479174466882_0005_01_000002,
containerNode=localhost:43913, containerNodeURI=localhost:8042,
containerResourceMemory1024, priority0
2016-11-15 14:24:28,555 INFO com.datatorrent.stram.LaunchContainerRunnable:
Setting up container launch context for
containerid=container_1479174466882_0005_01_000002
2016-11-15 14:24:28,565 INFO com.datatorrent.stram.LaunchContainerRunnable:
CLASSPATH:
./*:$HADOOP_CONF_DIR:$HADOOP_COMMON_HOME/share/hadoop/common/*:$HADOOP_COMMON_HOME/share/hadoop/common/lib/*:$HADOOP_HDFS_HOME/share/hadoop/hdfs/*:$HADOOP_HDFS_HOME/share/hadoop/hdfs/lib/*:$HADOOP_YARN_HOME/share/hadoop/yarn/*:$HADOOP_YARN_HOME/share/hadoop/yarn/lib/*:.
2016-11-15 14:24:28,950 ERROR com.datatorrent.stram.StreamingAppMaster:
Exiting Application Master
java.lang.IllegalArgumentException: Wrong FS:
file:/root/datatorrent/apps/application_1479174466882_0005/myapexapp-1.0-SNAPSHOT.jar,
expected: hdfs://localhost:8020
	at org.apache.hadoop.fs.FileSystem.checkPath(FileSystem.java:642)
	at
org.apache.hadoop.hdfs.DistributedFileSystem.getPathName(DistributedFileSystem.java:181)
	at
org.apache.hadoop.hdfs.DistributedFileSystem.access$000(DistributedFileSystem.java:92)
	at
org.apache.hadoop.hdfs.DistributedFileSystem$17.doCall(DistributedFileSystem.java:1106)
	at
org.apache.hadoop.hdfs.DistributedFileSystem$17.doCall(DistributedFileSystem.java:1102)
	at
org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81)
	at
org.apache.hadoop.hdfs.DistributedFileSystem.getFileStatus(DistributedFileSystem.java:1102)
	at
com.datatorrent.stram.LaunchContainerRunnable.addFilesToLocalResources(LaunchContainerRunnable.java:139)
	at
com.datatorrent.stram.LaunchContainerRunnable.run(LaunchContainerRunnable.java:170)
	at
com.datatorrent.stram.StreamingAppMasterService.execute(StreamingAppMasterService.java:917)
	at
com.datatorrent.stram.StreamingAppMasterService.run(StreamingAppMasterService.java:652)
	at
com.datatorrent.stram.StreamingAppMaster.main(StreamingAppMaster.java:104)


Please suggest me the solutions. 

Thanks in advance.
Prakash



--
View this message in context: http://apache-apex-users-list.78494.x6.nabble.com/SortedWordCount-example-is-not-running-tp1126.html
Sent from the Apache Apex Users list mailing list archive at Nabble.com.

Mime
View raw message