Couple of questions: Could you outline the steps you followed to run this application ? Do you have any custom code that is creating or modifying a Configuration object ? Can you try building and running some of the example programs at: https://github.com/DataTorrent/examples/tree/master/tutorials for instance *fileOutput* or *fileIO*; do they run into the same issue ?
Ram On Tue, Nov 15, 2016 at 2:06 AM, [email protected] < [email protected]> wrote: > 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. >
