Open pjbear1215 opened 10 years ago
so did I. In my case there was no problem to run that program on Yarn. anyone knows this problem ?
Caused by: org.apache.hadoop.mapred.InvalidInputException: Input path does not exist: hdfs://localhost:9000/user/jwpark/sample
Can you access the file via HDFS on the command line? E.g., using:
hdfs dfs -get hdfs://localhost:9000/user/jwpark/sample
Also, please check the port, as the default is 8020
.
@puppybit Can you attach the log of the run where you have an exception?
@bgchun Here is my STDERR,txt file !!
2014-11-05 20:21:36,121 FINE reef.runtime.common.Launcher.main main | Launcher started with user name [puppybit]
2014-11-05 20:21:36,183 FINE reef.runtime.common.Launcher.main main | Launcher started. Assertions are DISABLED in this process.
2014-11-05 20:21:36,426 FINE reef.wake.impl.StageManager.
2014-11-05 20:21:39,571 FINE hadoop.ipc.Client.close main | IPC Client (341354045) connection to localhost/127.0.0.1:9000 from puppybit: closed
2014-11-05 20:21:39,572 FINEST hadoop.ipc.ProtobufRpcEngine.invoke main | 1: Exception <- localhost/127.0.0.1:9000: getFileInfo {java.net.ConnectException: Call From andyLinu/127.0.0.1 to localhost:9000 failed on connection exception: java.net.ConnectException: Connection refused; For more details see: http://wiki.apache.org/hadoop/ConnectionRefused}
2014-11-05 20:21:39,574 SEVERE reef.runtime.common.launch.REEFErrorHandler.onNext main | Uncaught exception.
java.lang.Exception: Unable to instantiate the clock
at org.apache.reef.runtime.common.launch.LaunchClass.fail(LaunchClass.java:182)
at org.apache.reef.runtime.common.launch.LaunchClass.getClock(LaunchClass.java:149)
at org.apache.reef.runtime.common.launch.LaunchClass.run(LaunchClass.java:162)
at org.apache.reef.runtime.common.Launcher.main(Launcher.java:111)
Caused by: java.lang.RuntimeException: org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:127)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519)
at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:531)
at org.apache.reef.runtime.common.launch.LaunchClass.getClock(LaunchClass.java:147)
... 2 more
Caused by: org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:651)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:657)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:662)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:662)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:513)
at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116)
... 8 more
Caused by: java.lang.RuntimeException: Unable to get InputSplits using the specified InputFormat
at org.apache.reef.io.data.loading.impl.InputFormatLoadingService.
2014-11-05 20:21:39,576 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.getHandler main | RemoteManager: REEFLAUNCHER destinationIdentifier: socket://192.168.0.5:15979 messageType: org.apache.reef.proto.ReefServiceProtos$RuntimeErrorProto
2014-11-05 20:21:39,576 FINE reef.wake.remote.impl.ProxyEventHandler.q\000~\000Pq\000~\000Qq\000~\000Rsq\000~\000\024\000\000\000Qt\000+org.apache.hadoop.fs.FileSystemLinkResolvert\000\033FileSystemLinkResolver.javat\000\aresolvesq\000~\000\024\000\000\004
t\000,org.apache.hadoop.hdfs.DistributedFileSystemq\000~\000Qt\000\rgetFileStatussq\000~\000\024\000\000\0009t\000\034org.apache.hadoop.fs.Globbert\000\fGlobber.javaq\000~\000Zsq\000~\000\024\000\000\000\370q\000~\000\q\000~\000]t\000\004globsq\000~\000\024\000\000\006jt\000\037org.apache.hadoop.fs.FileSystemt\000\017FileSystem.javat\000\nglobStatussq\000~\000\024\000\000\001\001t\000(org.apache.hadoop.mapred.FileInputFormatt\000\024FileInputFormat.javat\000\030singleThreadedListStatussq\000~\000\024\000\000\000\344q\000~\000eq\000~\000ft\000\nlistStatussq\000~\000\024\000\000\0010q\000~\000eq\000~\000ft\000\tgetSplitssq\000~\000\024\000\000\000Yt\000>org.apache.reef.io.data.loading.impl.InputFormatLoadingServicet\000\036InputFormatLoadingService.javat\000\006q\000~\000Pq\000~\000Qq\000~\000Rsq\000~\000\024\000\000\000Qq\000~\000Uq\000~\000Vq\000~\000Wsq\000~\000\024\000\000\004
q\000~\000Yq\000~\000Qq\000~\000Zsq\000~\000\024\000\000\0009q\000~\000\q\000~\000]q\000~\000Zsq\000~\000\024\000\000\000\370q\000~\000\q\000~\000]q\000~\000_sq\000~\000\024\000\000\006jq\000~\000aq\000~\000bq\000~\000csq\000~\000\024\000\000\001\001q\000~\000eq\000~\000fq\000~\000gsq\000~\000\024\000\000\000\344q\000~\000eq\000~\000fq\000~\000isq\000~\000\024\000\000\0010q\000~\000eq\000~\000fq\000~\000ksq\000~\000\024\000\000\000Yq\000~\000mq\000~\000nq\000~\000osq\000~\000\024\377\377\377\376q\000~\000qq\000~\000rq\000~\000ssq\000~\000\024\000\000\0009q\000~\000qq\000~\000rq\000~\000usq\000~\000\024\000\000\000-q\000~\000wq\000~\000xq\000~\000usq\000~\000\024\000\000\002\016q\000~\000zq\000~\000{q\000~\000usq\000~\000\024\000\000\002{q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\221q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\001q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002\023q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\000\223q\000~\000\225q\000~\000\226q\000~\000\227sq\000~\000\024\000\000\000\242q\000~\000\225q\000~\000\226q\000~\000\231sq\000~\000\024\000\000\000oq\000~\000\233q\000~\000\234q\000~\000\235q\000~\000\241xt\0009Unable to get InputSplits using the specified InputFormatuq\000~\000\022\000\000\000\030sq\000~\000\024\000\000\000dq\000~\000mq\000~\000nq\000~\000osq\000~\000\024\377\377\377\376q\000~\000qq\000~\000rq\000~\000ssq\000~\000\024\000\000\0009q\000~\000qq\000~\000rq\000~\000usq\000~\000\024\000\000\000-q\000~\000wq\000~\000xq\000~\000usq\000~\000\024\000\000\002\016q\000~\000zq\000~\000{q\000~\000usq\000~\000\024\000\000\002{q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\221q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\001q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002\023q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\000\223q\000~\000\225q\000~\000\226q\000~\000\227sq\000~\000\024\000\000\000\242q\000~\000\225q\000~\000\226q\000~\000\231sq\000~\000\024\000\000\000oq\000~\000\233q\000~\000\234q\000~\000\235q\000~\000\241xt\002%Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\022\000\000\000\023sq\000~\000\024\000\000\002\213q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\221q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\001q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002\023q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\000\223q\000~\000\225q\000~\000\226q\000~\000\227sq\000~\000\024\000\000\000\242q\000~\000\225q\000~\000\226q\000~\000\231sq\000~\000\024\000\000\000oq\000~\000\233q\000~\000\234q\000~\000\235q\000~\000\241xt\002Yorg.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\022\000\000\000\tsq\000~\000\024\000\000\000q\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002\023q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\000\223q\000~\000\225q\000~\000\226q\000~\000\227sq\000~\000\024\000\000\000\242q\000~\000\225q\000~\000\226q\000~\000\231sq\000~\000\024\000\000\000oq\000~\000\233q\000~\000\234q\000~\000\235q\000~\000\241xt\000\037Unable to instantiate the clockuq\000~\000\022\000\000\000\004sq\000~\000\024\000\000\000\266q\000~\000\225q\000~\000\226t\000\004failsq\000~\000\024\000\000\000\225q\000~\000\225q\000~\000\226q\000~\000\227sq\000~\000\024\000\000\000\242q\000~\000\225q\000~\000\226q\000~\000\231sq\000~\000\024\000\000\000oq\000~\000\233q\000~\000\234q\000~\000\235q\000~\000\241x"
identifier: "K-means Clustering"
2014-11-05 20:21:39,631 SEVERE reef.runtime.common.launch.REEFErrorHandler.onNext main | Uncaught exception.
java.lang.Exception: Fatal exception while executing the clock
at org.apache.reef.runtime.common.launch.LaunchClass.fail(LaunchClass.java:182)
at org.apache.reef.runtime.common.launch.LaunchClass.run(LaunchClass.java:164)
at org.apache.reef.runtime.common.Launcher.main(Launcher.java:111)
Caused by: java.lang.RuntimeException: Unable to instantiate the clock
at org.apache.reef.runtime.common.launch.LaunchClass.getClock(LaunchClass.java:150)
at org.apache.reef.runtime.common.launch.LaunchClass.run(LaunchClass.java:162)
... 1 more
Caused by: java.lang.RuntimeException: org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:127)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519)
at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:531)
at org.apache.reef.runtime.common.launch.LaunchClass.getClock(LaunchClass.java:147)
... 2 more
Caused by: org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:651)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:657)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:662)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:662)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:513)
at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116)
... 8 more
Caused by: java.lang.RuntimeException: Unable to get InputSplits using the specified InputFormat
at org.apache.reef.io.data.loading.impl.InputFormatLoadingService.
2014-11-05 20:21:39,633 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.open org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1 | No cached link for /192.168.0.5:15979 thread Thread[org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1,5,main]
2014-11-05 20:21:39,634 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.getHandler main | RemoteManager: REEFLAUNCHER destinationIdentifier: socket://192.168.0.5:15979 messageType: org.apache.reef.proto.ReefServiceProtos$RuntimeErrorProto
2014-11-05 20:21:39,635 FINE reef.wake.remote.impl.ProxyEventHandler.q\000~\000Pq\000~\000Qq\000~\000Rsq\000~\000\024\000\000\000Qt\000+org.apache.hadoop.fs.FileSystemLinkResolvert\000\033FileSystemLinkResolver.javat\000\aresolvesq\000~\000\024\000\000\004
t\000,org.apache.hadoop.hdfs.DistributedFileSystemq\000~\000Qt\000\rgetFileStatussq\000~\000\024\000\000\0009t\000\034org.apache.hadoop.fs.Globbert\000\fGlobber.javaq\000~\000Zsq\000~\000\024\000\000\000\370q\000~\000\q\000~\000]t\000\004globsq\000~\000\024\000\000\006jt\000\037org.apache.hadoop.fs.FileSystemt\000\017FileSystem.javat\000\nglobStatussq\000~\000\024\000\000\001\001t\000(org.apache.hadoop.mapred.FileInputFormatt\000\024FileInputFormat.javat\000\030singleThreadedListStatussq\000~\000\024\000\000\000\344q\000~\000eq\000~\000ft\000\nlistStatussq\000~\000\024\000\000\0010q\000~\000eq\000~\000ft\000\tgetSplitssq\000~\000\024\000\000\000Yt\000>org.apache.reef.io.data.loading.impl.InputFormatLoadingServicet\000\036InputFormatLoadingService.javat\000\006q\000~\000Pq\000~\000Qq\000~\000Rsq\000~\000\024\000\000\000Qq\000~\000Uq\000~\000Vq\000~\000Wsq\000~\000\024\000\000\004
q\000~\000Yq\000~\000Qq\000~\000Zsq\000~\000\024\000\000\0009q\000~\000\q\000~\000]q\000~\000Zsq\000~\000\024\000\000\000\370q\000~\000\q\000~\000]q\000~\000_sq\000~\000\024\000\000\006jq\000~\000aq\000~\000bq\000~\000csq\000~\000\024\000\000\001\001q\000~\000eq\000~\000fq\000~\000gsq\000~\000\024\000\000\000\344q\000~\000eq\000~\000fq\000~\000isq\000~\000\024\000\000\0010q\000~\000eq\000~\000fq\000~\000ksq\000~\000\024\000\000\000Yq\000~\000mq\000~\000nq\000~\000osq\000~\000\024\377\377\377\376q\000~\000qq\000~\000rq\000~\000ssq\000~\000\024\000\000\0009q\000~\000qq\000~\000rq\000~\000usq\000~\000\024\000\000\000-q\000~\000wq\000~\000xq\000~\000usq\000~\000\024\000\000\002\016q\000~\000zq\000~\000{q\000~\000usq\000~\000\024\000\000\002{q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\221q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\001q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002\023q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\000\223q\000~\000\225q\000~\000\226q\000~\000\227sq\000~\000\024\000\000\000\242q\000~\000\225q\000~\000\226q\000~\000\231sq\000~\000\024\000\000\000oq\000~\000\233q\000~\000\234q\000~\000\235q\000~\000\241xt\0009Unable to get InputSplits using the specified InputFormatuq\000~\000\022\000\000\000\030sq\000~\000\024\000\000\000dq\000~\000mq\000~\000nq\000~\000osq\000~\000\024\377\377\377\376q\000~\000qq\000~\000rq\000~\000ssq\000~\000\024\000\000\0009q\000~\000qq\000~\000rq\000~\000usq\000~\000\024\000\000\000-q\000~\000wq\000~\000xq\000~\000usq\000~\000\024\000\000\002\016q\000~\000zq\000~\000{q\000~\000usq\000~\000\024\000\000\002{q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\221q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\001q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002\023q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\000\223q\000~\000\225q\000~\000\226q\000~\000\227sq\000~\000\024\000\000\000\242q\000~\000\225q\000~\000\226q\000~\000\231sq\000~\000\024\000\000\000oq\000~\000\233q\000~\000\234q\000~\000\235q\000~\000\241xt\002%Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\022\000\000\000\023sq\000~\000\024\000\000\002\213q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\221q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002oq\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\226q\000~\000}q\000~\000~q\000~\000sq\000~\000\024\000\000\002\001q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002\023q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\000\223q\000~\000\225q\000~\000\226q\000~\000\227sq\000~\000\024\000\000\000\242q\000~\000\225q\000~\000\226q\000~\000\231sq\000~\000\024\000\000\000oq\000~\000\233q\000~\000\234q\000~\000\235q\000~\000\241xt\002Yorg.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\022\000\000\000\tsq\000~\000\024\000\000\000q\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002 q\000~\000}q\000~\000~q\000~\000\212sq\000~\000\024\000\000\000tq\000~\000\214q\000~\000\215q\000~\000\216sq\000~\000\024\000\000\002\aq\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\002\023q\000~\000}q\000~\000~q\000~\000\210sq\000~\000\024\000\000\000\223q\000~\000\225q\000~\000\226q\000~\000\227sq\000~\000\024\000\000\000\242q\000~\000\225q\000~\000\226q\000~\000\231sq\000~\000\024\000\000\000oq\000~\000\233q\000~\000\234q\000~\000\235q\000~\000\241xt\000\037Unable to instantiate the clockuq\000~\000\022\000\000\000\004sq\000~\000\024\000\000\000\266q\000~\000\225q\000~\000\226t\000\004failsq\000~\000\024\000\000\000\225q\000~\000\225q\000~\000\226q\000~\000\227sq\000~\000\024\000\000\000\242q\000~\000\225q\000~\000\226q\000~\000\231sq\000~\000\024\000\000\000oq\000~\000\233q\000~\000\234q\000~\000\235q\000~\000\241x"
identifier: "K-means Clustering"
2014-11-05 20:21:39,650 FINE reef.wake.remote.impl.ProxyEventHandler.onNext main | remoteid: /192.168.0.5:15979
name: "reef"
message: "Fatal exception while executing the clock"
exception: "\254\355\000\005sr\000\023java.lang.Exception\320\375\037>\032;\034\304\002\000\000xr\000\023java.lang.Throwable\325\3065\'9w\270\313\003\000\004L\000\005causet\000\025Ljava/lang/Throwable;L\000\rdetailMessaget\000\022Ljava/lang/String;[\000\nstackTracet\000\036[Ljava/lang/StackTraceElement;L\000\024suppressedExceptionst\000\020Ljava/util/List;xpsr\000\032java.lang.RuntimeException\236_\006G\n4\203\345\002\000\000xq\000~\000\000sq\000~\000\asr\0002org.apache.reef.tang.exceptions.InjectionException\000\000\000\000\000\000\000\001\002\000\000xq\000~\000\000sq\000~\000\asr\000\031java.net.ConnectException5+\341\342\250\367/\277\002\000\000xr\000\030java.net.SocketException\255\237\211\305A\037^j\002\000\000xr\000\023java.io.IOExceptionl\200sde%\360\253\002\000\000xq\000~\000\000sq\000~\000\rq\000~\000\021t\000\022Connection refusedur\000\036[Ljava.lang.StackTraceElement;\002F*<<\375\"9\002\000\000xp\000\000\0008sr\000\033java.lang.StackTraceElementa\t\305\232&6\335\205\002\000\004I\000\nlineNumberL\000\016declaringClassq\000~\000\003L\000\bfileNameq\000~\000\003L\000\nmethodNameq\000~\000\003xp\377\377\377\376t\000\034sun.nio.ch.SocketChannelImplt\000\026SocketChannelImpl.javat\000\fcheckConnectsq\000~\000\025\000\000\002\343q\000~\000\027q\000~\000\030t\000\rfinishConnectsq\000~\000\025\000\000\000\316t\000)org.apache.hadoop.net.SocketIOWithTimeoutt\000\030SocketIOWithTimeout.javat\000\aconnectsq\000~\000\025\000\000\002\021t\000\036org.apache.hadoop.net.NetUtilst\000\rNetUtils.javaq\000~\000\037sq\000~\000\025\000\000\001\355q\000~\000!q\000~\000\"q\000~\000\037sq\000~\000\025\000\000\002\t\000\'org.apache.hadoop.ipc.Client$Connectiont\000\vClient.javat\000\017setupConnectionsq\000~\000\025\000\000\002\273q\000~\000%q\000~\000&t\000\016setupIOstreamssq\000~\000\025\000\000\001oq\000~\000%q\000~\000&t\000\vaccess$2800sq\000~\000\025\000\000\005\266t\000\034org.apache.hadoop.ipc.Clientq\000~\000&t\000\rgetConnectionsq\000~\000\025\000\000\005eq\000~\000-q\000~\000&t\000\004callsq\000~\000\025\000\000\005Sq\000~\000-q\000~\000&q\000~\0000sq\000~\000\025\000\000\000\316t\000/org.apache.hadoop.ipc.ProtobufRpcEngine$Invokert\000\026ProtobufRpcEngine.javat\000\006invokesq\000~\000\025\377\377\377\377t\000\026com.sun.proxy.$Proxy21pt\000\vgetFileInfosq\000~\000\025\377\377\377\376t\000$sun.reflect.NativeMethodAccessorImplt\000\035NativeMethodAccessorImpl.javat\000\ainvoke0sq\000~\000\025\000\000\0009q\000~\000:q\000~\000;q\000~\0005sq\000~\000\025\000\000\000+t\000(sun.reflect.DelegatingMethodAccessorImplt\000!DelegatingMethodAccessorImpl.javaq\000~\0005sq\000~\000\025\000\000\002^t\000\030java.lang.reflect.Methodt\000\vMethod.javaq\000~\0005sq\000~\000\025\000\000\000\276t\0001org.apache.hadoop.io.retry.RetryInvocationHandlert\000\033RetryInvocationHandler.javat\000\finvokeMethodsq\000~\000\025\000\000\000gq\000~\000Eq\000~\000Fq\000~\0005sq\000~\000\025\377\377\377\377q\000~\0007pq\000~\0008sq\000~\000\025\000\000\002\273t\000Dorg.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPBt\000\'ClientNamenodeProtocolTranslatorPB.javaq\000~\0008sq\000~\000\025\000\000\006\342t\000 org.apache.hadoop.hdfs.DFSClientt\000\016DFSClient.javaq\000~\0008sq\000~\000\025\000\000\004dt\000/org.apache.hadoop.hdfs.DistributedFileSystem$17t\000\032DistributedFileSystem.javat\000\006doCallsq\000~\000\025\000\000\004q\000~\000Qq\000~\000Rq\000~\000Ssq\000~\000\025\000\000\000Qt\000+org.apache.hadoop.fs.FileSystemLinkResolvert\000\033FileSystemLinkResolver.javat\000\aresolvesq\000~\000\025\000\000\004
t\000,org.apache.hadoop.hdfs.DistributedFileSystemq\000~\000Rt\000\rgetFileStatussq\000~\000\025\000\000\0009t\000\034org.apache.hadoop.fs.Globbert\000\fGlobber.javaq\000~\000[sq\000~\000\025\000\000\000\370q\000~\000]q\000~\000^t\000\004globsq\000~\000\025\000\000\006jt\000\037org.apache.hadoop.fs.FileSystemt\000\017FileSystem.javat\000\nglobStatussq\000~\000\025\000\000\001\001t\000(org.apache.hadoop.mapred.FileInputFormatt\000\024FileInputFormat.javat\000\030singleThreadedListStatussq\000~\000\025\000\000\000\344q\000~\000fq\000~\000gt\000\nlistStatussq\000~\000\025\000\000\0010q\000~\000fq\000~\000gt\000\tgetSplitssq\000~\000\025\000\000\000Yt\000>org.apache.reef.io.data.loading.impl.InputFormatLoadingServicet\000\036InputFormatLoadingService.javat\000\006q\000~\000Qq\000~\000Rq\000~\000Ssq\000~\000\025\000\000\000Qq\000~\000Vq\000~\000Wq\000~\000Xsq\000~\000\025\000\000\004
q\000~\000Zq\000~\000Rq\000~\000[sq\000~\000\025\000\000\0009q\000~\000]q\000~\000^q\000~\000[sq\000~\000\025\000\000\000\370q\000~\000]q\000~\000^q\000~\000`sq\000~\000\025\000\000\006jq\000~\000bq\000~\000cq\000~\000dsq\000~\000\025\000\000\001\001q\000~\000fq\000~\000gq\000~\000hsq\000~\000\025\000\000\000\344q\000~\000fq\000~\000gq\000~\000jsq\000~\000\025\000\000\0010q\000~\000fq\000~\000gq\000~\000lsq\000~\000\025\000\000\000Yq\000~\000nq\000~\000oq\000~\000psq\000~\000\025\377\377\377\376q\000~\000rq\000~\000sq\000~\000tsq\000~\000\025\000\000\0009q\000~\000rq\000~\000sq\000~\000vsq\000~\000\025\000\000\000-q\000~\000xq\000~\000yq\000~\000vsq\000~\000\025\000\000\002\016q\000~\000{q\000~\000|q\000~\000vsq\000~\000\025\000\000\002{q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\221q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\001q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002\023q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\000\223q\000~\000\226q\000~\000\227q\000~\000\230sq\000~\000\025\000\000\000\242q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242xt\0009Unable to get InputSplits using the specified InputFormatuq\000~\000\023\000\000\000\030sq\000~\000\025\000\000\000dq\000~\000nq\000~\000oq\000~\000psq\000~\000\025\377\377\377\376q\000~\000rq\000~\000sq\000~\000tsq\000~\000\025\000\000\0009q\000~\000rq\000~\000sq\000~\000vsq\000~\000\025\000\000\000-q\000~\000xq\000~\000yq\000~\000vsq\000~\000\025\000\000\002\016q\000~\000{q\000~\000|q\000~\000vsq\000~\000\025\000\000\002{q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\221q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\001q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002\023q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\000\223q\000~\000\226q\000~\000\227q\000~\000\230sq\000~\000\025\000\000\000\242q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242xt\002%Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\023\000\000\000\023sq\000~\000\025\000\000\002\213q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\221q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\001q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002\023q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\000\223q\000~\000\226q\000~\000\227q\000~\000\230sq\000~\000\025\000\000\000\242q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242xt\002Yorg.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\023\000\000\000\tsq\000~\000\025\000\000\000q\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002\023q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\000\223q\000~\000\226q\000~\000\227q\000~\000\230sq\000~\000\025\000\000\000\242q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242xt\000\037Unable to instantiate the clockuq\000~\000\023\000\000\000\003sq\000~\000\025\000\000\000\226q\000~\000\226q\000~\000\227q\000~\000\230sq\000~\000\025\000\000\000\242q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242xt\000)Fatal exception while executing the clockuq\000~\000\023\000\000\000\003sq\000~\000\025\000\000\000\266q\000~\000\226q\000~\000\227t\000\004failsq\000~\000\025\000\000\000\244q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242x"
identifier: "K-means Clustering"
2014-11-05 20:21:39,651 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.onNext main | transport get link: localAddr: /192.168.0.5:34884 remoteAddr: /192.168.0.5:15979
2014-11-05 20:21:39,652 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.setLink main | thread Thread[main,5,main] link localAddr: /192.168.0.5:34884 remoteAddr: /192.168.0.5:15979
2014-11-05 20:21:39,652 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.consumeQueue main | RemoteEvent localAddr=/192.168.0.5:16671 remoteAddr=/192.168.0.5:15979 sourceName= sinkName=default seq=1 event=name: "reef"
message: "Fatal exception while executing the clock"
exception: "\254\355\000\005sr\000\023java.lang.Exception\320\375\037>\032;\034\304\002\000\000xr\000\023java.lang.Throwable\325\3065\'9w\270\313\003\000\004L\000\005causet\000\025Ljava/lang/Throwable;L\000\rdetailMessaget\000\022Ljava/lang/String;[\000\nstackTracet\000\036[Ljava/lang/StackTraceElement;L\000\024suppressedExceptionst\000\020Ljava/util/List;xpsr\000\032java.lang.RuntimeException\236_\006G\n4\203\345\002\000\000xq\000~\000\000sq\000~\000\asr\0002org.apache.reef.tang.exceptions.InjectionException\000\000\000\000\000\000\000\001\002\000\000xq\000~\000\000sq\000~\000\asr\000\031java.net.ConnectException5+\341\342\250\367/\277\002\000\000xr\000\030java.net.SocketException\255\237\211\305A\037^j\002\000\000xr\000\023java.io.IOExceptionl\200sde%\360\253\002\000\000xq\000~\000\000sq\000~\000\rq\000~\000\021t\000\022Connection refusedur\000\036[Ljava.lang.StackTraceElement;\002F*<<\375\"9\002\000\000xp\000\000\0008sr\000\033java.lang.StackTraceElementa\t\305\232&6\335\205\002\000\004I\000\nlineNumberL\000\016declaringClassq\000~\000\003L\000\bfileNameq\000~\000\003L\000\nmethodNameq\000~\000\003xp\377\377\377\376t\000\034sun.nio.ch.SocketChannelImplt\000\026SocketChannelImpl.javat\000\fcheckConnectsq\000~\000\025\000\000\002\343q\000~\000\027q\000~\000\030t\000\rfinishConnectsq\000~\000\025\000\000\000\316t\000)org.apache.hadoop.net.SocketIOWithTimeoutt\000\030SocketIOWithTimeout.javat\000\aconnectsq\000~\000\025\000\000\002\021t\000\036org.apache.hadoop.net.NetUtilst\000\rNetUtils.javaq\000~\000\037sq\000~\000\025\000\000\001\355q\000~\000!q\000~\000\"q\000~\000\037sq\000~\000\025\000\000\002\t\000\'org.apache.hadoop.ipc.Client$Connectiont\000\vClient.javat\000\017setupConnectionsq\000~\000\025\000\000\002\273q\000~\000%q\000~\000&t\000\016setupIOstreamssq\000~\000\025\000\000\001oq\000~\000%q\000~\000&t\000\vaccess$2800sq\000~\000\025\000\000\005\266t\000\034org.apache.hadoop.ipc.Clientq\000~\000&t\000\rgetConnectionsq\000~\000\025\000\000\005eq\000~\000-q\000~\000&t\000\004callsq\000~\000\025\000\000\005Sq\000~\000-q\000~\000&q\000~\0000sq\000~\000\025\000\000\000\316t\000/org.apache.hadoop.ipc.ProtobufRpcEngine$Invokert\000\026ProtobufRpcEngine.javat\000\006invokesq\000~\000\025\377\377\377\377t\000\026com.sun.proxy.$Proxy21pt\000\vgetFileInfosq\000~\000\025\377\377\377\376t\000$sun.reflect.NativeMethodAccessorImplt\000\035NativeMethodAccessorImpl.javat\000\ainvoke0sq\000~\000\025\000\000\0009q\000~\000:q\000~\000;q\000~\0005sq\000~\000\025\000\000\000+t\000(sun.reflect.DelegatingMethodAccessorImplt\000!DelegatingMethodAccessorImpl.javaq\000~\0005sq\000~\000\025\000\000\002^t\000\030java.lang.reflect.Methodt\000\vMethod.javaq\000~\0005sq\000~\000\025\000\000\000\276t\0001org.apache.hadoop.io.retry.RetryInvocationHandlert\000\033RetryInvocationHandler.javat\000\finvokeMethodsq\000~\000\025\000\000\000gq\000~\000Eq\000~\000Fq\000~\0005sq\000~\000\025\377\377\377\377q\000~\0007pq\000~\0008sq\000~\000\025\000\000\002\273t\000Dorg.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPBt\000\'ClientNamenodeProtocolTranslatorPB.javaq\000~\0008sq\000~\000\025\000\000\006\342t\000 org.apache.hadoop.hdfs.DFSClientt\000\016DFSClient.javaq\000~\0008sq\000~\000\025\000\000\004dt\000/org.apache.hadoop.hdfs.DistributedFileSystem$17t\000\032DistributedFileSystem.javat\000\006doCallsq\000~\000\025\000\000\004q\000~\000Qq\000~\000Rq\000~\000Ssq\000~\000\025\000\000\000Qt\000+org.apache.hadoop.fs.FileSystemLinkResolvert\000\033FileSystemLinkResolver.javat\000\aresolvesq\000~\000\025\000\000\004
t\000,org.apache.hadoop.hdfs.DistributedFileSystemq\000~\000Rt\000\rgetFileStatussq\000~\000\025\000\000\0009t\000\034org.apache.hadoop.fs.Globbert\000\fGlobber.javaq\000~\000[sq\000~\000\025\000\000\000\370q\000~\000]q\000~\000^t\000\004globsq\000~\000\025\000\000\006jt\000\037org.apache.hadoop.fs.FileSystemt\000\017FileSystem.javat\000\nglobStatussq\000~\000\025\000\000\001\001t\000(org.apache.hadoop.mapred.FileInputFormatt\000\024FileInputFormat.javat\000\030singleThreadedListStatussq\000~\000\025\000\000\000\344q\000~\000fq\000~\000gt\000\nlistStatussq\000~\000\025\000\000\0010q\000~\000fq\000~\000gt\000\tgetSplitssq\000~\000\025\000\000\000Yt\000>org.apache.reef.io.data.loading.impl.InputFormatLoadingServicet\000\036InputFormatLoadingService.javat\000\006q\000~\000Qq\000~\000Rq\000~\000Ssq\000~\000\025\000\000\000Qq\000~\000Vq\000~\000Wq\000~\000Xsq\000~\000\025\000\000\004
q\000~\000Zq\000~\000Rq\000~\000[sq\000~\000\025\000\000\0009q\000~\000]q\000~\000^q\000~\000[sq\000~\000\025\000\000\000\370q\000~\000]q\000~\000^q\000~\000`sq\000~\000\025\000\000\006jq\000~\000bq\000~\000cq\000~\000dsq\000~\000\025\000\000\001\001q\000~\000fq\000~\000gq\000~\000hsq\000~\000\025\000\000\000\344q\000~\000fq\000~\000gq\000~\000jsq\000~\000\025\000\000\0010q\000~\000fq\000~\000gq\000~\000lsq\000~\000\025\000\000\000Yq\000~\000nq\000~\000oq\000~\000psq\000~\000\025\377\377\377\376q\000~\000rq\000~\000sq\000~\000tsq\000~\000\025\000\000\0009q\000~\000rq\000~\000sq\000~\000vsq\000~\000\025\000\000\000-q\000~\000xq\000~\000yq\000~\000vsq\000~\000\025\000\000\002\016q\000~\000{q\000~\000|q\000~\000vsq\000~\000\025\000\000\002{q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\221q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\001q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002\023q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\000\223q\000~\000\226q\000~\000\227q\000~\000\230sq\000~\000\025\000\000\000\242q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242xt\0009Unable to get InputSplits using the specified InputFormatuq\000~\000\023\000\000\000\030sq\000~\000\025\000\000\000dq\000~\000nq\000~\000oq\000~\000psq\000~\000\025\377\377\377\376q\000~\000rq\000~\000sq\000~\000tsq\000~\000\025\000\000\0009q\000~\000rq\000~\000sq\000~\000vsq\000~\000\025\000\000\000-q\000~\000xq\000~\000yq\000~\000vsq\000~\000\025\000\000\002\016q\000~\000{q\000~\000|q\000~\000vsq\000~\000\025\000\000\002{q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\221q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\001q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002\023q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\000\223q\000~\000\226q\000~\000\227q\000~\000\230sq\000~\000\025\000\000\000\242q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242xt\002%Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\023\000\000\000\023sq\000~\000\025\000\000\002\213q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\221q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002oq\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\226q\000~\000~q\000~\000q\000~\000\200sq\000~\000\025\000\000\002\001q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002\023q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\000\223q\000~\000\226q\000~\000\227q\000~\000\230sq\000~\000\025\000\000\000\242q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242xt\002Yorg.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\023\000\000\000\tsq\000~\000\025\000\000\000q\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002 q\000~\000~q\000~\000q\000~\000\213sq\000~\000\025\000\000\000tq\000~\000\215q\000~\000\216q\000~\000\217sq\000~\000\025\000\000\002\aq\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\002\023q\000~\000~q\000~\000q\000~\000\211sq\000~\000\025\000\000\000\223q\000~\000\226q\000~\000\227q\000~\000\230sq\000~\000\025\000\000\000\242q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242xt\000\037Unable to instantiate the clockuq\000~\000\023\000\000\000\003sq\000~\000\025\000\000\000\226q\000~\000\226q\000~\000\227q\000~\000\230sq\000~\000\025\000\000\000\242q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242xt\000)Fatal exception while executing the clockuq\000~\000\023\000\000\000\003sq\000~\000\025\000\000\000\266q\000~\000\226q\000~\000\227t\000\004failsq\000~\000\025\000\000\000\244q\000~\000\226q\000~\000\227q\000~\000\232sq\000~\000\025\000\000\000oq\000~\000\234q\000~\000\235q\000~\000\236q\000~\000\242x"
identifier: "K-means Clustering"
2014-11-05 20:21:39,696 FINEST reef.wake.remote.transport.netty.NettyLink.write main | write [id: 0xd52d0b04, /192.168.0.5:34884 => /192.168.0.5:15979] [B@3b49ca31
2014-11-05 20:21:39,697 FINEST reef.wake.remote.transport.netty.NettyLink.write org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1 | write [id: 0xd52d0b04, /192.168.0.5:34884 => /192.168.0.5:15979] [B@6979755f
2014-11-05 20:21:39,699 FINER reef.runtime.common.launch.LaunchClass.run main | RETURN Clock terminated
2014-11-05 20:21:39,699 FINE reef.runtime.common.Launcher.main main | Launcher exiting
2014-11-05 20:21:39,700 FINER reef.runtime.common.launch.LaunchClass.close main | ENTRY
2014-11-05 20:21:39,701 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.close main | RemoteManager: REEF_LAUNCHER Closing remote manager id: socket://192.168.0.5:16671
2014-11-05 20:21:39,702 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closing sender stage socket://192.168.0.5:16671
2014-11-05 20:21:39,703 FINE reef.wake.remote.impl.RemoteSenderStage.close pool-4-thread-1 | close org.apache.reef.wake.remote.transport.netty.NettyMessagingTransport@34edb5aa
2014-11-05 20:21:39,704 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closed the remote sender stage
2014-11-05 20:21:39,705 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closing transport socket://192.168.0.5:16671
2014-11-05 20:21:39,706 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.close pool-4-thread-1 | Closing netty transport socket address: /192.168.0.5:16671
2014-11-05 20:21:39,715 FINER reef.wake.remote.transport.netty.AbstractNettyEventListener.closeChannel org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-1 | Channel closed: [id: 0xd52d0b04, /192.168.0.5:34884 :> /192.168.0.5:15979]. Link ref found and removed: true
2014-11-05 20:21:39,746 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.close pool-4-thread-1 | Closing netty transport socket address: /192.168.0.5:16671 done
2014-11-05 20:21:39,748 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closed the transport
2014-11-05 20:21:39,748 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closing receiver stage socket://192.168.0.5:16671
2014-11-05 20:21:39,750 FINE reef.wake.remote.impl.OrderedRemoteReceiverStage.close pool-4-thread-1 | close
2014-11-05 20:21:39,750 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closed the remote receiver stage
2014-11-05 20:21:39,751 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.close main | Close executor terminated properly.
2014-11-05 20:21:39,752 FINER reef.runtime.common.launch.LaunchClass.close main | RETURN
2014-11-05 20:21:39,753 INFO reef.runtime.common.Launcher.main main | Exiting Launcher.main()
2014-11-05 20:21:39,756 FINEST reef.runtime.common.Launcher.main main | Threads running after Launcher.close():
Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-6':
java.lang.Thread.sleep(Native Method)
io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362)
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
java.lang.Thread.run(Thread.java:745)
Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-17':
java.lang.Thread.sleep(Native Method)
io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362)
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
java.lang.Thread.run(Thread.java:745)
Thread 'Reference Handler':
java.lang.Object.wait(Native Method)
java.lang.Object.wait(Object.java:503)
java.lang.ref.Reference$ReferenceHandler.run(Reference.java:133)
Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-9':
java.lang.Thread.sleep(Native Method)
io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362)
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
java.lang.Thread.run(Thread.java:745)
Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-20':
java.lang.Thread.sleep(Native Method)
io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362)
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
java.lang.Thread.run(Thread.java:745)
Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-4':
java.lang.Thread.sleep(Native Method)
io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362)
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
java.lang.Thread.run(Thread.java:745)
Thread 'SingleThreadStage
@pjbear1215 You're running the code with /run.sh -input sample -local true
, which means you'll run k-means on local runtime. Thus, the sample
you're trying to use is the one on the local file system. However REEF is looking for a sample
on the Hadoop file system. The code seems to search the Hadoop FS by default, so try to add the prefix file://
to the absolute path of sample
.
For example, ./run.sh -input file:///home/username/sample -local true
.
@pjbear1215 In fact, we're trying to do some fixes to make REEF read data from local FS by default, if the job is going to run on local runtime (-local true
). Please add a comment if adding file://
still doesn't solve the problem.
@puppybit I can't find any Input path does not exist: hdfs://...
in your STDERR.txt
, but since you can successfully run k-means on YARN, maybe you're having the problem as the issue reporter?
@jsjason Thanks for your suggestion. With your advice, InvalidInputException disappeared. Unfortunately, I have still got some error message such as "Unable to instantiate the clock" and "Fatal exception while executing the clock". The following is my "STDERR.txt" for this time. Thanks.
2014-11-06 20:11:56,872 FINE reef.runtime.common.Launcher.main main | Launcher started with user name [jwpark]
2014-11-06 20:11:56,955 FINE reef.runtime.common.Launcher.main main | Launcher started. Assertions are DISABLED in this process.
2014-11-06 20:11:57,191 FINE reef.wake.impl.StageManager.
2014-11-06 20:12:00,050 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.getHandler main | RemoteManager: REEFLAUNCHER destinationIdentifier: socket://192.168.0.187:10424 messageType: org.apache.reef.proto.ReefServiceProtos$RuntimeErrorProto
2014-11-06 20:12:00,051 FINE reef.wake.remote.impl.ProxyEventHandler.
2014-11-06 20:12:00,212 SEVERE reef.runtime.common.launch.REEFErrorHandler.onNext main | Uncaught exception.
java.lang.Exception: Fatal exception while executing the clock
at org.apache.reef.runtime.common.launch.LaunchClass.fail(LaunchClass.java:182)
at org.apache.reef.runtime.common.launch.LaunchClass.run(LaunchClass.java:164)
at org.apache.reef.runtime.common.Launcher.main(Launcher.java:111)
Caused by: java.lang.RuntimeException: Unable to instantiate the clock
at org.apache.reef.runtime.common.launch.LaunchClass.getClock(LaunchClass.java:150)
at org.apache.reef.runtime.common.launch.LaunchClass.run(LaunchClass.java:162)
... 1 more
Caused by: java.lang.RuntimeException: org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:127)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:531)
at org.apache.reef.runtime.common.launch.LaunchClass.getClock(LaunchClass.java:147)
... 2 more
Caused by: org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:651)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:657)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:662)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:662)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:513)
at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116)
... 5 more
Caused by: java.lang.IllegalArgumentException: Wrong FS: file://home/jwpark/woong/reef-tutorial/bin/sample, expected: file:///
at org.apache.hadoop.fs.FileSystem.checkPath(FileSystem.java:643)
at org.apache.hadoop.fs.RawLocalFileSystem.pathToFile(RawLocalFileSystem.java:79)
at org.apache.hadoop.fs.RawLocalFileSystem.deprecatedGetFileStatus(RawLocalFileSystem.java:506)
at org.apache.hadoop.fs.RawLocalFileSystem.getFileLinkStatusInternal(RawLocalFileSystem.java:724)
at org.apache.hadoop.fs.RawLocalFileSystem.getFileStatus(RawLocalFileSystem.java:501)
at org.apache.hadoop.fs.FilterFileSystem.getFileStatus(FilterFileSystem.java:397)
at org.apache.hadoop.fs.Globber.getFileStatus(Globber.java:57)
at org.apache.hadoop.fs.Globber.glob(Globber.java:248)
at org.apache.hadoop.fs.FileSystem.globStatus(FileSystem.java:1642)
at org.apache.hadoop.mapred.FileInputFormat.singleThreadedListStatus(FileInputFormat.java:257)
at org.apache.hadoop.mapred.FileInputFormat.listStatus(FileInputFormat.java:228)
at org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:304)
at org.apache.reef.io.data.loading.impl.InputFormatLoadingService.
2014-11-06 20:12:00,213 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.open org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1 | No cached link for /192.168.0.187:10424 thread Thread[org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1,5,main]
2014-11-06 20:12:00,214 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.getHandler main | RemoteManager: REEFLAUNCHER destinationIdentifier: socket://192.168.0.187:10424 messageType: org.apache.reef.proto.ReefServiceProtos$RuntimeErrorProto
2014-11-06 20:12:00,214 FINE reef.wake.remote.impl.ProxyEventHandler.q\000~\000dxt\002\332org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample)uq\000~\000\017\000\000\000\006sq\000~\000\021\000\000\000q\000~\000Rq\000~\000Sq\000~\000Tsq\000~\000\021\000\000\002\aq\000~\000Cq\000~\000Dq\000~\000Nsq\000~\000\021\000\000\002\023q\000~\000Cq\000~\000Dq\000~\000Nsq\000~\000\021\000\000\000\223q\000~\000Xq\000~\000Yq\000~\000Zsq\000~\000\021\000\000\000\242q\000~\000Xq\000~\000Yq\000~\000\\sq\000~\000\021\000\000\000oq\000~\000^q\000~\000_q\000~\000
q\000~\000dxt\000\037Unable to instantiate the clockuq\000~\000\017\000\000\000\003sq\000~\000\021\000\000\000\226q\000~\000Xq\000~\000Yq\000~\000Zsq\000~\000\021\000\000\000\242q\000~\000Xq\000~\000Yq\000~\000\sq\000~\000\021\000\000\000oq\000~\000^q\000~\000_q\000~\000q\000~\000dxt\000)Fatal exception while executing the clockuq\000~\000\017\000\000\000\003sq\000~\000\021\000\000\000\266q\000~\000Xq\000~\000Yt\000\004failsq\000~\000\021\000\000\000\244q\000~\000Xq\000~\000Yq\000~\000\\sq\000~\000\021\000\000\000oq\000~\000^q\000~\000_q\000~\000
q\000~\000dx"
identifier: "K-means Clustering"
2014-11-06 20:12:00,223 FINER reef.runtime.common.launch.LaunchClass.run main | RETURN Clock terminated
2014-11-06 20:12:00,223 FINE reef.runtime.common.Launcher.main main | Launcher exiting
2014-11-06 20:12:00,224 FINER reef.runtime.common.launch.LaunchClass.close main | ENTRY
2014-11-06 20:12:00,224 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.close main | RemoteManager: REEFLAUNCHER Closing remote manager id: socket://192.168.0.187:12125
2014-11-06 20:12:00,226 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.open org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2 | Link null for /192.168.0.187:10424 found
2014-11-06 20:12:00,227 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.open org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2 | No cached link for /192.168.0.187:10424 thread Thread[org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2,5,main]
2014-11-06 20:12:00,228 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closing sender stage socket://192.168.0.187:12125
2014-11-06 20:12:00,228 FINE reef.wake.remote.impl.RemoteSenderStage.close pool-4-thread-1 | close org.apache.reef.wake.remote.transport.netty.NettyMessagingTransport@31a264bb
2014-11-06 20:12:00,232 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.setLink org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2 | thread Thread[org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2,5,main] link localAddr: /192.168.0.187:43098 remoteAddr: /192.168.0.187:10424
2014-11-06 20:12:00,232 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.setLink org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1 | thread Thread[org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1,5,main] link localAddr: /192.168.0.187:43098 remoteAddr: /192.168.0.187:10424
2014-11-06 20:12:00,233 FINEST reef.wake.remote.transport.netty.NettyClientEventListener.channelActive org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-1 | io.netty.channel.DefaultChannelHandlerContext@1c834a72
2014-11-06 20:12:00,234 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.consumeQueue org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2 | RemoteEvent localAddr=/192.168.0.187:12125 remoteAddr=/192.168.0.187:10424 sourceName= sinkName=default seq=1 event=name: "reef"
message: "Fatal exception while executing the clock"
exception: "\254\355\000\005sr\000\023java.lang.Exception\320\375\037>\032;\034\304\002\000\000xr\000\023java.lang.Throwable\325\3065\'9w\270\313\003\000\004L\000\005causet\000\025Ljava/lang/Throwable;L\000\rdetailMessaget\000\022Ljava/lang/String;[\000\nstackTracet\000\036[Ljava/lang/StackTraceElement;L\000\024suppressedExceptionst\000\020Ljava/util/List;xpsr\000\032java.lang.RuntimeException\236\006G\n4\203\345\002\000\000xq\000~\000\000sq\000~\000\asr\0002org.apache.reef.tang.exceptions.InjectionException\000\000\000\000\000\000\000\001\002\000\000xq\000~\000\000sr\000\"java.lang.IllegalArgumentException\265\211s\323}f\217\274\002\000\000xq\000~\000\aq\000~\000\rt\000OWrong FS: file://home/jwpark/woong/reef-tutorial/bin/sample, expected: file:///ur\000\036[Ljava.lang.StackTraceElement;\002F*<<\375\"9\002\000\000xp\000\000\000!sr\000\033java.lang.StackTraceElementa\t\305\232&6\335\205\002\000\004I\000\nlineNumberL\000\016declaringClassq\000~\000\003L\000\bfileNameq\000~\000\003L\000\nmethodNameq\000~\000\003xp\000\000\002\203t\000\037org.apache.hadoop.fs.FileSystemt\000\017FileSystem.javat\000\tcheckPathsq\000~\000\021\000\000\000Ot\000\'org.apache.hadoop.fs.RawLocalFileSystemt\000\027RawLocalFileSystem.javat\000\npathToFilesq\000~\000\021\000\000\001\372q\000~\000\027q\000~\000\030t\000\027deprecatedGetFileStatussq\000~\000\021\000\000\002\324q\000~\000\027q\000~\000\030t\000\031getFileLinkStatusInternalsq\000~\000\021\000\000\001\365q\000~\000\027q\000~\000\030t\000\rgetFileStatussq\000~\000\021\000\000\001\215t\000%org.apache.hadoop.fs.FilterFileSystemt\000\025FilterFileSystem.javaq\000~\000\037sq\000~\000\021\000\000\0009t\000\034org.apache.hadoop.fs.Globbert\000\fGlobber.javaq\000~\000\037sq\000~\000\021\000\000\000\370q\000~\000$q\000~\000%t\000\004globsq\000~\000\021\000\000\006jq\000~\000\023q\000~\000\024t\000\nglobStatussq\000~\000\021\000\000\001\001t\000(org.apache.hadoop.mapred.FileInputFormatt\000\024FileInputFormat.javat\000\030singleThreadedListStatussq\000~\000\021\000\000\000\344q\000~\000+q\000~\000,t\000\nlistStatussq\000~\000\021\000\000\0010q\000~\000+q\000~\000,t\000\tgetSplitssq\000~\000\021\000\000\000Yt\000>org.apache.reef.io.data.loading.impl.InputFormatLoadingServicet\000\036InputFormatLoadingService.javat\000\006q\000~\000dxt\002\332org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = file://home/jwpark/woong/reef-tutorial/bin/sample)uq\000~\000\017\000\000\000\006sq\000~\000\021\000\000\000q\000~\000Rq\000~\000Sq\000~\000Tsq\000~\000\021\000\000\002\aq\000~\000Cq\000~\000Dq\000~\000Nsq\000~\000\021\000\000\002\023q\000~\000Cq\000~\000Dq\000~\000Nsq\000~\000\021\000\000\000\223q\000~\000Xq\000~\000Yq\000~\000Zsq\000~\000\021\000\000\000\242q\000~\000Xq\000~\000Yq\000~\000\\sq\000~\000\021\000\000\000oq\000~\000^q\000~\000_q\000~\000
q\000~\000dxt\000\037Unable to instantiate the clockuq\000~\000\017\000\000\000\003sq\000~\000\021\000\000\000\226q\000~\000Xq\000~\000Yq\000~\000Zsq\000~\000\021\000\000\000\242q\000~\000Xq\000~\000Yq\000~\000\sq\000~\000\021\000\000\000oq\000~\000^q\000~\000_q\000~\000q\000~\000dxt\000)Fatal exception while executing the clockuq\000~\000\017\000\000\000\003sq\000~\000\021\000\000\000\266q\000~\000Xq\000~\000Yt\000\004failsq\000~\000\021\000\000\000\244q\000~\000Xq\000~\000Yq\000~\000\\sq\000~\000\021\000\000\000oq\000~\000^q\000~\000_q\000~\000
q\000~\000dx"
identifier: "K-means Clustering"
2014-11-06 20:12:00,240 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.consumeQueue org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1 | RemoteEvent localAddr=/192.168.0.187:12125 remoteAddr=/192.168.0.187:10424 sourceName= sinkName=default seq=0 event=name: "reef"
message: "Unable to instantiate the clock"
exception: "\254\355\000\005sr\000\023java.lang.Exception\320\375\037>\032;\034\304\002\000\000xr\000\023java.lang.Throwable\325\3065\'9w\270\313\003\000\004L\000\005causet\000\025Ljava/lang/Throwable;L\000\rdetailMessaget\000\022Ljava/lang/String;[\000\nstackTracet\000\036[Ljava/lang/StackTraceElement;L\000\024suppressedExceptionst\000\020Ljava/util/List;xpsr\000\032java.lang.RuntimeException\236\006G\n4\203\345\002\000\000xq\000~\000\000sr\0002org.apache.reef.tang.exceptions.InjectionException\000\000\000\000\000\000\000\001\002\000\000xq\000~\000\000sr\000\"java.lang.IllegalArgumentException\265\211s\323}f\217\274\002\000\000xq\000~\000\aq\000~\000\ft\000OWrong FS: file://home/jwpark/woong/reef-tutorial/bin/sample, expected: file:///ur\000\036[Ljava.lang.StackTraceElement;\002F<<\375\"9\002\000\000xp\000\000\000!sr\000\033java.lang.StackTraceElementa\t\305\232&6\335\205\002\000\004I\000\nlineNumberL\000\016declaringClassq\000~\000\003L\000\bfileNameq\000~\000\003L\000\nmethodNameq\000~\000\003xp\000\000\002\203t\000\037org.apache.hadoop.fs.FileSystemt\000\017FileSystem.javat\000\tcheckPathsq\000~\000\020\000\000\000Ot\000\'org.apache.hadoop.fs.RawLocalFileSystemt\000\027RawLocalFileSystem.javat\000\npathToFilesq\000~\000\020\000\000\001\372q\000~\000\026q\000~\000\027t\000\027deprecatedGetFileStatussq\000~\000\020\000\000\002\324q\000~\000\026q\000~\000\027t\000\031getFileLinkStatusInternalsq\000~\000\020\000\000\001\365q\000~\000\026q\000~\000\027t\000\rgetFileStatussq\000~\000\020\000\000\001\215t\000%org.apache.hadoop.fs.FilterFileSystemt\000\025FilterFileSystem.javaq\000~\000\036sq\000~\000\020\000\000\0009t\000\034org.apache.hadoop.fs.Globbert\000\fGlobber.javaq\000~\000\036sq\000~\000\020\000\000\000\370q\000~\000#q\000~\000$t\000\004globsq\000~\000\020\000\000\006jq\000~\000\022q\000~\000\023t\000\nglobStatussq\000~\000\020\000\000\001\001t\000(org.apache.hadoop.mapred.FileInputFormatt\000\024FileInputFormat.javat\000\030singleThreadedListStatussq\000~\000\020\000\000\000\344q\000~\000_q\000~\000+t\000\nlistStatussq\000~\000\020\000\000\0010q\000~\000*q\000~\000+t\000\tgetSplitssq\000~\000\020\000\000\000Yt\000>org.apache.reef.io.data.loading.impl.InputFormatLoadingServicet\000\036InputFormatLoadingService.javat\000\006
2014-11-06 20:12:00,278 FINEST reef.wake.remote.transport.netty.NettyLink.write org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1 | write [id: 0x688d5c38, /192.168.0.187:43098 => /192.168.0.187:10424] [B@5e386a0f
2014-11-06 20:12:00,280 FINEST reef.wake.remote.transport.netty.NettyLink.write org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2 | write [id: 0x688d5c38, /192.168.0.187:43098 => /192.168.0.187:10424] [B@49bb2f1c
2014-11-06 20:12:00,282 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closed the remote sender stage
2014-11-06 20:12:00,282 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closing transport socket://192.168.0.187:12125
2014-11-06 20:12:00,283 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.close pool-4-thread-1 | Closing netty transport socket address: /192.168.0.187:12125
2014-11-06 20:12:00,292 FINER reef.wake.remote.transport.netty.AbstractNettyEventListener.closeChannel org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-1 | Channel closed: [id: 0x688d5c38, /192.168.0.187:43098 :> /192.168.0.187:10424]. Link ref found and removed: true
2014-11-06 20:12:00,306 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.close pool-4-thread-1 | Closing netty transport socket address: /192.168.0.187:12125 done
2014-11-06 20:12:00,307 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closed the transport
2014-11-06 20:12:00,308 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closing receiver stage socket://192.168.0.187:12125
2014-11-06 20:12:00,308 FINE reef.wake.remote.impl.OrderedRemoteReceiverStage.close pool-4-thread-1 | close
2014-11-06 20:12:00,310 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closed the remote receiver stage
2014-11-06 20:12:00,311 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.close main | Close executor terminated properly.
2014-11-06 20:12:00,311 FINER reef.runtime.common.launch.LaunchClass.close main | RETURN
2014-11-06 20:12:00,312 INFO reef.runtime.common.Launcher.main main | Exiting Launcher.main()
2014-11-06 20:12:00,315 FINEST reef.runtime.common.Launcher.main main | Threads running after Launcher.close():
Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-20':
Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-10':
java.lang.Thread.sleep(Native Method)
io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362)
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
java.lang.Thread.run(Thread.java:745)
Thread 'main':
java.lang.Thread.dumpThreads(Native Method)
java.lang.Thread.getAllStackTraces(Thread.java:1640)
org.apache.reef.util.ThreadLogger.getFormattedThreadList(ThreadLogger.java:70)
org.apache.reef.util.ThreadLogger.getFormattedThreadList(ThreadLogger.java:83)
org.apache.reef.runtime.common.Launcher.main(Launcher.java:119)
Thread 'pool-4-thread-1':
java.lang.System.arraycopy(Native Method)
java.lang.ThreadGroup.remove(ThreadGroup.java:969)
java.lang.ThreadGroup.threadTerminated(ThreadGroup.java:942)
java.lang.Thread.exit(Thread.java:755)
Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-10':
java.lang.Thread.sleep(Native Method)
io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362)
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
java.lang.Thread.run(Thread.java:745)
Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-2':
java.lang.Thread.sleep(Native Method)
io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362)
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
java.lang.Thread.run(Thread.java:745)
Thread 'SingleThreadStage
@pjbear1215 Found the line Caused by: java.lang.IllegalArgumentException: Wrong FS: file://home/jwpark/woong/reef-tutorial/bin/sample, expected: file:///
in your STDERR.txt
.
Try three slashes instead of two.
@jsjason Thanks a lot! It solves my error. It finally worked! Sorry for my careless mistake.
Having built REEF, shimoga, reef-examples(k-means) successfully, I tried to run the code with './run.sh -input sample -local true' in the 'bin/' directory. Unfortunately, my REEF jobs failed to be completed showing messages such as "Unable to instantiate the clock" and "Fatal exception while executing the clock". Is there anyone who has any suggestions? Detailed error logs are as follows.
2014-11-05 17:28:36,299 FINE reef.runtime.common.Launcher.main main | Launcher started with user name [jwpark] 2014-11-05 17:28:36,380 FINE reef.runtime.common.Launcher.main main | Launcher started. Assertions are DISABLED in this process. 2014-11-05 17:28:36,614 FINE reef.wake.impl.StageManager. main | StageManager adds a shutdown hook
2014-11-05 17:28:36,616 FINEST reef.wake.impl.StageManager.register main | StageManager adds stage org.apache.reef.wake.impl.ThreadPoolStage@4ee6d1d6
2014-11-05 17:28:36,626 FINEST reef.wake.impl.StageManager.register main | StageManager adds stage org.apache.reef.wake.impl.ThreadPoolStage@5d2b7e11
2014-11-05 17:28:36,643 FINE reef.wake.remote.NetUtils.getLocalAddress main | Local address is 192.168.0.187
2014-11-05 17:28:36,997 FINE reef.wake.remote.transport.netty.NettyMessagingTransport. main | Binding to 0
2014-11-05 17:28:36,998 FINEST reef.wake.remote.transport.netty.NettyMessagingTransport. main | Try port 18,559
2014-11-05 17:28:37,108 FINE reef.wake.remote.transport.netty.NettyMessagingTransport. main | Starting netty transport socket address: /192.168.0.187:18559
2014-11-05 17:28:37,110 FINEST reef.wake.impl.StageManager.register main | StageManager adds stage org.apache.reef.wake.remote.impl.DefaultRemoteManagerImplementation@5505aa49
2014-11-05 17:28:37,111 FINEST reef.wake.remote.impl.DefaultRemoteManagerImplementation. main | RemoteManager REEF_LAUNCHER instantiated id socket://192.168.0.187:18559 counter 1 listening on /192.168.0.187:18559:18,559
2014-11-05 17:28:37,112 FINE reef.runtime.common.utils.RemoteManager. main | Instantiated RemoteManager with remoteId: socket://192.168.0.187:18559
2014-11-05 17:28:37,114 FINE reef.runtime.common.Launcher.main main | Launcher starting
2014-11-05 17:28:37,115 FINER reef.runtime.common.launch.LaunchClass.run main | ENTRY Starting the clock
2014-11-05 17:28:37,115 FINEST reef.runtime.common.launch.LaunchClass.readConfigurationFromDisk main | Loading configuration file: reef/local/driver.conf
2014-11-05 17:28:37,742 FINE reef.wake.time.runtime.RuntimeClock. main | RuntimeClock instantiated.
2014-11-05 17:28:37,747 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.getHandler main | RemoteManager: REEF_LAUNCHER destinationIdentifier: socket://192.168.0.187:17053 messageType: org.apache.reef.proto.ReefServiceProtos$JobStatusProto
2014-11-05 17:28:37,749 FINE reef.wake.remote.impl.ProxyEventHandler. main | ProxyEventHandler myId: socket://192.168.0.187:18559 remoteId: socket://192.168.0.187:17053 remoteSink: default handler: org.apache.reef.wake.remote.impl.RemoteSenderEventHandler@62b78623
2014-11-05 17:28:37,750 FINE reef.runtime.common.driver.client.ClientConnection. main | Instantiated 'ClientConnection'
2014-11-05 17:28:37,752 FINER reef.runtime.common.driver.DriverStatusManager. main | ENTRY
2014-11-05 17:28:37,752 FINE reef.runtime.common.driver.DriverStatusManager. main | Instantiated 'DriverStatusManager'
2014-11-05 17:28:37,753 FINER reef.runtime.common.driver.DriverStatusManager. main | RETURN
2014-11-05 17:28:37,753 FINE reef.runtime.common.driver.evaluator.Evaluators. main | Instantiated 'Evaluators'
2014-11-05 17:28:37,763 FINE reef.runtime.common.driver.catalog.ResourceCatalogImpl. main | Instantiated 'ResourceCatalogImpl'
2014-11-05 17:28:37,765 FINEST reef.runtime.local.driver.ContainerManager. main | Initializing Container Manager with 5 containers
2014-11-05 17:28:37,766 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.registerHandler main | RemoteManager: REEF_LAUNCHER messageType: org.apache.reef.proto.ReefServiceProtos$RuntimeErrorProto handler: org.apache.reef.runtime.local.driver.ContainerManager$1
2014-11-05 17:28:37,767 FINER reef.wake.remote.impl.HandlerContainer.registerHandler main | class org.apache.reef.proto.ReefServiceProtos$RuntimeErrorProto
2014-11-05 17:28:37,770 FINE reef.runtime.local.driver.ContainerManager. main | Initialized Container Manager with 5 containers
2014-11-05 17:28:37,786 FINE reef.runtime.local.driver.ResourceManager. main | Instantiated 'ResourceManager'
2014-11-05 17:28:38,274 FINE hadoop.metrics2.lib.MutableMetricsFactory.newForField main | field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.loginSuccess with annotation @org.apache.hadoop.metrics2.annotation.Metric(value=[Rate of successful kerberos logins and latency (milliseconds)], about=, valueName=Time, type=DEFAULT, always=false, sampleName=Ops)
2014-11-05 17:28:38,283 FINE hadoop.metrics2.lib.MutableMetricsFactory.newForField main | field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.loginFailure with annotation @org.apache.hadoop.metrics2.annotation.Metric(value=[Rate of failed kerberos logins and latency (milliseconds)], about=, valueName=Time, type=DEFAULT, always=false, sampleName=Ops)
2014-11-05 17:28:38,284 FINE hadoop.metrics2.lib.MutableMetricsFactory.newForField main | field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.getGroups with annotation @org.apache.hadoop.metrics2.annotation.Metric(value=[GetGroups], about=, valueName=Time, type=DEFAULT, always=false, sampleName=Ops)
2014-11-05 17:28:38,286 FINE hadoop.metrics2.impl.MetricsSystemImpl.register main | UgiMetrics, User and group related metrics
2014-11-05 17:28:38,645 FINE hadoop.security.Groups.getUserToGroupsMappingService main | Creating new Groups object
2014-11-05 17:28:38,654 FINE hadoop.util.NativeCodeLoader. main | Trying to load the custom-built native-hadoop library...
2014-11-05 17:28:38,656 FINE hadoop.util.NativeCodeLoader. main | Failed to load native-hadoop with error: java.lang.UnsatisfiedLinkError: no hadoop in java.library.path
2014-11-05 17:28:38,656 FINE hadoop.util.NativeCodeLoader. main | java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
2014-11-05 17:28:38,657 WARNING hadoop.util.NativeCodeLoader. main | Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2014-11-05 17:28:38,658 FINE hadoop.security.JniBasedUnixGroupsMappingWithFallback. main | Falling back to shell based
2014-11-05 17:28:38,669 FINE hadoop.security.JniBasedUnixGroupsMappingWithFallback. main | Group mapping impl=org.apache.hadoop.security.ShellBasedUnixGroupsMapping
2014-11-05 17:28:38,705 FINE hadoop.util.Shell.isSetsidSupported main | setsid exited with exit code 0
2014-11-05 17:28:38,705 FINE hadoop.security.Groups. main | Group mapping impl=org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback; cacheTimeout=300000; warningDeltaMs=5000
2014-11-05 17:28:38,713 FINE hadoop.security.UserGroupInformation.login main | hadoop login
2014-11-05 17:28:38,717 FINE hadoop.security.UserGroupInformation.commit main | hadoop login commit
2014-11-05 17:28:38,723 FINE hadoop.security.UserGroupInformation.commit main | using local user:UnixPrincipal: jwpark
2014-11-05 17:28:38,730 FINE hadoop.security.UserGroupInformation.loginUserFromSubject main | UGI loginUser:jwpark (auth:SIMPLE)
2014-11-05 17:28:39,014 FINE hadoop.hdfs.BlockReaderLocal. main | dfs.client.use.legacy.blockreader.local = false
2014-11-05 17:28:39,015 FINE hadoop.hdfs.BlockReaderLocal. main | dfs.client.read.shortcircuit = false
2014-11-05 17:28:39,015 FINE hadoop.hdfs.BlockReaderLocal. main | dfs.client.domain.socket.data.traffic = false
2014-11-05 17:28:39,016 FINE hadoop.hdfs.BlockReaderLocal. main | dfs.domain.socket.path =
2014-11-05 17:28:39,095 FINE hadoop.io.retry.RetryUtils.getDefaultRetryPolicy main | multipleLinearRandomRetry = null
2014-11-05 17:28:39,123 FINE hadoop.ipc.Server.registerProtocolEngine main | rpcKind=RPC_PROTOCOL_BUFFER, rpcRequestWrapperClass=class org.apache.hadoop.ipc.ProtobufRpcEngine$RpcRequestWrapper, rpcInvoker=org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker@42ee68b1
2014-11-05 17:28:39,132 FINE hadoop.ipc.Client.getClient main | getting client out of cache: org.apache.hadoop.ipc.Client@62aa77f2
2014-11-05 17:28:39,598 FINE hadoop.hdfs.BlockReaderLocal. main | Both short-circuit local reads and UNIX domain socket are disabled.
2014-11-05 17:28:39,778 FINEST hadoop.ipc.ProtobufRpcEngine.invoke main | 1: Call -> localhost/127.0.0.1:9000: getFileInfo {src: "/user/jwpark/sample"}
2014-11-05 17:28:39,792 FINE hadoop.ipc.Client. main | The ping interval is 60000 ms.
2014-11-05 17:28:39,793 FINE hadoop.ipc.Client.setupIOstreams main | Connecting to localhost/127.0.0.1:9000
2014-11-05 17:28:39,811 FINE hadoop.ipc.Client.run IPC Client (1249106906) connection to localhost/127.0.0.1:9000 from jwpark | IPC Client (1249106906) connection to localhost/127.0.0.1:9000 from jwpark: starting, having connections 1
2014-11-05 17:28:39,815 FINE hadoop.ipc.Client.run IPC Parameter Sending Thread #0 | IPC Client (1249106906) connection to localhost/127.0.0.1:9000 from jwpark sending #0
2014-11-05 17:28:39,823 FINE hadoop.ipc.Client.receiveRpcResponse IPC Client (1249106906) connection to localhost/127.0.0.1:9000 from jwpark | IPC Client (1249106906) connection to localhost/127.0.0.1:9000 from jwpark got value #0
2014-11-05 17:28:39,824 FINE hadoop.ipc.ProtobufRpcEngine.invoke main | Call: getFileInfo took 193ms
2014-11-05 17:28:39,845 FINEST hadoop.ipc.ProtobufRpcEngine.invoke main | 1: Response <- localhost/127.0.0.1:9000: getFileInfo {}
2014-11-05 17:28:39,846 SEVERE reef.runtime.common.launch.REEFErrorHandler.onNext main | Uncaught exception.
java.lang.Exception: Unable to instantiate the clock
at org.apache.reef.runtime.common.launch.LaunchClass.fail(LaunchClass.java:182)
at org.apache.reef.runtime.common.launch.LaunchClass.getClock(LaunchClass.java:149)
at org.apache.reef.runtime.common.launch.LaunchClass.run(LaunchClass.java:162)
at org.apache.reef.runtime.common.Launcher.main(Launcher.java:111)
Caused by: java.lang.RuntimeException: org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:127)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519)
at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519)
at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:531)
at org.apache.reef.runtime.common.launch.LaunchClass.getClock(LaunchClass.java:147)
... 2 more
Caused by: org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:651)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:657)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:662)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:657)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:662)
at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:513)
at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544)
at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116)
... 11 more
Caused by: java.lang.RuntimeException: Unable to get InputSplits using the specified InputFormat
at org.apache.reef.io.data.loading.impl.InputFormatLoadingService.(InputFormatLoadingService.java:100)
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:635)
... 21 more
Caused by: org.apache.hadoop.mapred.InvalidInputException: Input path does not exist: hdfs://localhost:9000/user/jwpark/sample
at org.apache.hadoop.mapred.FileInputFormat.singleThreadedListStatus(FileInputFormat.java:285)
at org.apache.hadoop.mapred.FileInputFormat.listStatus(FileInputFormat.java:228)
at org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:304)
at org.apache.reef.io.data.loading.impl.InputFormatLoadingService.(InputFormatLoadingService.java:89)
... 26 more
2014-11-05 17:28:39,848 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.getHandler main | RemoteManager: REEFLAUNCHER destinationIdentifier: socket://192.168.0.187:17053 messageType: org.apache.reef.proto.ReefServiceProtos$RuntimeErrorProto 2014-11-05 17:28:39,848 FINE reef.wake.remote.impl.ProxyEventHandler. main | ProxyEventHandler myId: socket://192.168.0.187:18559 remoteId: socket://192.168.0.187:17053 remoteSink: default handler: org.apache.reef.wake.remote.impl.RemoteSenderEventHandler@393a0262
2014-11-05 17:28:39,903 FINE reef.wake.remote.impl.ProxyEventHandler.onNext main | remoteid: /192.168.0.187:17053
name: "reef"
message: "Unable to instantiate the clock"
exception: "\254\355\000\005sr\000\023java.lang.Exception\320\375\037>\032;\034\304\002\000\000xr\000\023java.lang.Throwable\325\3065\'9w\270\313\003\000\004L\000\005causet\000\025Ljava/lang/Throwable;L\000\rdetailMessaget\000\022Ljava/lang/String;[\000\nstackTracet\000\036[Ljava/lang/StackTraceElement;L\000\024suppressedExceptionst\000\020Ljava/util/List;xpsr\000\032java.lang.RuntimeException\236 \006G\n4\203\345\002\000\000xq\000~\000\000sr\0002org.apache.reef.tang.exceptions.InjectionException\000\000\000\000\000\000\000\001\002\000\000xq\000~\000\000sq\000~\000\asr\000.org.apache.hadoop.mapred.InvalidInputException\000\000\000\000\000\000\000\001\002\000\001L\000\bproblemsq\000~\000\005xr\000\023java.io.IOExceptionl\200sde%\360\253\002\000\000xq\000~\000\000q\000~\000\016pur\000\036[Ljava.lang.StackTraceElement;\002F*<<\375\"9\002\000\000xp\000\000\000\036sr\000\033java.lang.StackTraceElementa\t\305\232&6\335\205\002\000\004I\000\nlineNumberL\000\016declaringClassq\000~\000\003L\000\bfileNameq\000~\000\003L\000\nmethodNameq\000~\000\003xp\000\000\001\035t\000(org.apache.hadoop.mapred.FileInputFormatt\000\024FileInputFormat.javat\000\030singleThreadedListStatussq\000~\000\021\000\000\000\344q\000~\000\023q\000~\000\024t\000\nlistStatussq\000~\000\021\000\000\0010q\000~\000\023q\000~\000\024t\000\tgetSplitssq\000~\000\021\000\000\000Yt\000>org.apache.reef.io.data.loading.impl.InputFormatLoadingServicet\000\036InputFormatLoadingService.javat\000\006sq\000~\000\021\377\377\377\376t\000)sun.reflect.NativeConstructorAccessorImplt\000\"NativeConstructorAccessorImpl.javat\000\fnewInstance0sq\000~\000\021\000\000\0009q\000~\000\037q\000~\000 t\000\vnewInstancesq\000~\000\021\000\000\000-t\000-sun.reflect.DelegatingConstructorAccessorImplt\000&DelegatingConstructorAccessorImpl.javaq\000~\000#sq\000~\000\021\000\000\002\016t\000\035java.lang.reflect.Constructort\000\020Constructor.javaq\000~\000#sq\000~\000\021\000\000\002{t\0005org.apache.reef.tang.implementation.java.InjectorImplt\000\021InjectorImpl.javat\000\016injectFromPlansq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\001q\000~\000+q\000~\000,t\000\vgetInstancesq\000~\000\021\000\000\002 q\000~\000+q\000~\000,t\000\020getNamedInstancesq\000~\000\021\000\000\000tt\000$org.apache.reef.tang.InjectionFuturet\000\024InjectionFuture.javat\000\003getsq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002\023q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\000\223t\0001org.apache.reef.runtime.common.launch.LaunchClasst\000\020LaunchClass.javat\000\bgetClocksq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gt\000\003runsq\000~\000\021\000\000\000ot\000\'org.apache.reef.runtime.common.Launchert\000\rLauncher.javat\000\004mainsr\000&java.util.Collections$UnmodifiableList\374\017%1\265\354\216\020\002\000\001L\000\004listq\000~\000\005xr\000,java.util.Collections$UnmodifiableCollection\031B\000\200\313^\367\036\002\000\001L\000\001ct\000\026Ljava/util/Collection;xpsr\000\023java.util.ArrayListx\201\322\035\231\307a\235\003\000\001I\000\004sizexp\000\000\000\000w\004\000\000\000\000xq\000~\000Txsq\000~\000S\000\000\000\001w\004\000\000\000\001sq\000~\000\rq\000~\000Vt\000CInput path does not exist: hdfs://localhost:9000/user/jwpark/sampleuq\000~\000\017\000\000\000\036sq\000~\000\021\000\000\001\003q\000~\000\023q\000~\000\024q\000~\000\025sq\000~\000\021\000\000\000\344q\000~\000\023q\000~\000\024q\000~\000\027sq\000~\000\021\000\000\0010q\000~\000\023q\000~\000\024q\000~\000\031sq\000~\000\021\000\000\000Yq\000~\000\033q\000~\000\034q\000~\000\035sq\000~\000\021\377\377\377\376q\000~\000\037q\000~\000 q\000~\000!sq\000~\000\021\000\000\0009q\000~\000\037q\000~\000 q\000~\000#sq\000~\000\021\000\000\000-q\000~\000%q\000~\000&q\000~\000#sq\000~\000\021\000\000\002\016q\000~\000(q\000~\000)q\000~\000#sq\000~\000\021\000\000\002{q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\001q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002\023q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\000\223q\000~\000Fq\000~\000Gq\000~\000Hsq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gq\000~\000Jsq\000~\000\021\000\000\000oq\000~\000Lq\000~\000Mq\000~\000Nq\000~\000Rxxt\0009Unable to get InputSplits using the specified InputFormatuq\000~\000\017\000\000\000\033sq\000~\000\021\000\000\000dq\000~\000\033q\000~\000\034q\000~\000\035sq\000~\000\021\377\377\377\376q\000~\000\037q\000~\000 q\000~\000!sq\000~\000\021\000\000\0009q\000~\000\037q\000~\000 q\000~\000#sq\000~\000\021\000\000\000-q\000~\000%q\000~\000&q\000~\000#sq\000~\000\021\000\000\002\016q\000~\000(q\000~\000)q\000~\000#sq\000~\000\021\000\000\002{q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\001q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002\023q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\000\223q\000~\000Fq\000~\000Gq\000~\000Hsq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gq\000~\000Jsq\000~\000\021\000\000\000oq\000~\000Lq\000~\000Mq\000~\000Nq\000~\000Rxt\002%Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\017\000\000\000\026sq\000~\000\021\000\000\002\213q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\001q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002\023q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\000\223q\000~\000Fq\000~\000Gq\000~\000Hsq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gq\000~\000Jsq\000~\000\021\000\000\000oq\000~\000Lq\000~\000Mq\000~\000Nq\000~\000Rxt\002Yorg.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\017\000\000\000\fsq\000~\000\021\000\000\000q\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002\023q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\000\223q\000~\000Fq\000~\000Gq\000~\000Hsq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gq\000~\000Jsq\000~\000\021\000\000\000oq\000~\000Lq\000~\000Mq\000~\000Nq\000~\000Rxt\000\037Unable to instantiate the clockuq\000~\000\017\000\000\000\004sq\000~\000\021\000\000\000\266q\000~\000Fq\000~\000Gt\000\004failsq\000~\000\021\000\000\000\225q\000~\000Fq\000~\000Gq\000~\000Hsq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gq\000~\000Jsq\000~\000\021\000\000\000oq\000~\000Lq\000~\000Mq\000~\000Nq\000~\000Rx"
identifier: "K-means Clustering"
2014-11-05 17:28:39,906 SEVERE reef.runtime.common.launch.REEFErrorHandler.onNext main | Uncaught exception. java.lang.Exception: Fatal exception while executing the clock at org.apache.reef.runtime.common.launch.LaunchClass.fail(LaunchClass.java:182) at org.apache.reef.runtime.common.launch.LaunchClass.run(LaunchClass.java:164) at org.apache.reef.runtime.common.Launcher.main(Launcher.java:111) Caused by: java.lang.RuntimeException: Unable to instantiate the clock at org.apache.reef.runtime.common.launch.LaunchClass.getClock(LaunchClass.java:150) at org.apache.reef.runtime.common.launch.LaunchClass.run(LaunchClass.java:162) ... 1 more Caused by: java.lang.RuntimeException: org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample) at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:127) at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519) at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544) at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116) at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519) at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544) at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116) at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:519) at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:531) at org.apache.reef.runtime.common.launch.LaunchClass.getClock(LaunchClass.java:147) ... 2 more Caused by: org.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample) at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:651) at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:657) at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623) at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623) at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:662) at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:623) at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:657) at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:662) at org.apache.reef.tang.implementation.java.InjectorImpl.getInstance(InjectorImpl.java:513) at org.apache.reef.tang.implementation.java.InjectorImpl.getNamedInstance(InjectorImpl.java:544) at org.apache.reef.tang.InjectionFuture.get(InjectionFuture.java:116) ... 11 more Caused by: java.lang.RuntimeException: Unable to get InputSplits using the specified InputFormat at org.apache.reef.io.data.loading.impl.InputFormatLoadingService.(InputFormatLoadingService.java:100)
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
at org.apache.reef.tang.implementation.java.InjectorImpl.injectFromPlan(InjectorImpl.java:635)
... 21 more
Caused by: org.apache.hadoop.mapred.InvalidInputException: Input path does not exist: hdfs://localhost:9000/user/jwpark/sample
at org.apache.hadoop.mapred.FileInputFormat.singleThreadedListStatus(FileInputFormat.java:285)
at org.apache.hadoop.mapred.FileInputFormat.listStatus(FileInputFormat.java:228)
at org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:304)
at org.apache.reef.io.data.loading.impl.InputFormatLoadingService.(InputFormatLoadingService.java:89)
... 26 more
2014-11-05 17:28:39,908 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.getHandler main | RemoteManager: REEFLAUNCHER destinationIdentifier: socket://192.168.0.187:17053 messageType: org.apache.reef.proto.ReefServiceProtos$RuntimeErrorProto 2014-11-05 17:28:39,908 FINE reef.wake.remote.impl.ProxyEventHandler. main | ProxyEventHandler myId: socket://192.168.0.187:18559 remoteId: socket://192.168.0.187:17053 remoteSink: default handler: org.apache.reef.wake.remote.impl.RemoteSenderEventHandler@7a27d8b4
2014-11-05 17:28:39,911 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.open org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1 | No cached link for /192.168.0.187:17053 thread Thread[org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1,5,main]
2014-11-05 17:28:39,917 FINE reef.wake.remote.impl.ProxyEventHandler.onNext main | remoteid: /192.168.0.187:17053
name: "reef"
message: "Fatal exception while executing the clock"
exception: "\254\355\000\005sr\000\023java.lang.Exception\320\375\037>\032;\034\304\002\000\000xr\000\023java.lang.Throwable\325\3065\'9w\270\313\003\000\004L\000\005causet\000\025Ljava/lang/Throwable;L\000\rdetailMessaget\000\022Ljava/lang/String;[\000\nstackTracet\000\036[Ljava/lang/StackTraceElement;L\000\024suppressedExceptionst\000\020Ljava/util/List;xpsr\000\032java.lang.RuntimeException\236 \006G\n4\203\345\002\000\000xq\000~\000\000sq\000~\000\asr\0002org.apache.reef.tang.exceptions.InjectionException\000\000\000\000\000\000\000\001\002\000\000xq\000~\000\000sq\000~\000\asr\000.org.apache.hadoop.mapred.InvalidInputException\000\000\000\000\000\000\000\001\002\000\001L\000\bproblemsq\000~\000\005xr\000\023java.io.IOExceptionl\200sde%\360\253\002\000\000xq\000~\000\000q\000~\000\017pur\000\036[Ljava.lang.StackTraceElement;\002F_<<\375\"9\002\000\000xp\000\000\000\036sr\000\033java.lang.StackTraceElementa\t\305\232&6\335\205\002\000\004I\000\nlineNumberL\000\016declaringClassq\000~\000\003L\000\bfileNameq\000~\000\003L\000\nmethodNameq\000~\000\003xp\000\000\001\035t\000(org.apache.hadoop.mapred.FileInputFormatt\000\024FileInputFormat.javat\000\030singleThreadedListStatussq\000~\000\022\000\000\000\344q\000~\000\024q\000~\000\025t\000\nlistStatussq\000~\000\022\000\000\0010q\000~\000\024q\000~\000\025t\000\tgetSplitssq\000~\000\022\000\000\000Yt\000>org.apache.reef.io.data.loading.impl.InputFormatLoadingServicet\000\036InputFormatLoadingService.javat\000\006sq\000~\000\022\377\377\377\376t\000)sun.reflect.NativeConstructorAccessorImplt\000\"NativeConstructorAccessorImpl.javat\000\fnewInstance0sq\000~\000\022\000\000\0009q\000~\000 q\000~\000!t\000\vnewInstancesq\000~\000\022\000\000\000-t\000-sun.reflect.DelegatingConstructorAccessorImplt\000&DelegatingConstructorAccessorImpl.javaq\000~\000$sq\000~\000\022\000\000\002\016t\000\035java.lang.reflect.Constructort\000\020Constructor.javaq\000~\000$sq\000~\000\022\000\000\002{t\0005org.apache.reef.tang.implementation.java.InjectorImplt\000\021InjectorImpl.javat\000\016injectFromPlansq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\001q\000~\000,q\000~\000-t\000\vgetInstancesq\000~\000\022\000\000\002 q\000~\000,q\000~\000-t\000\020getNamedInstancesq\000~\000\022\000\000\000tt\000$org.apache.reef.tang.InjectionFuturet\000\024InjectionFuture.javat\000\003getsq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002\023q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\000\223t\0001org.apache.reef.runtime.common.launch.LaunchClasst\000\020LaunchClass.javat\000\bgetClocksq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Ht\000\003runsq\000~\000\022\000\000\000ot\000\'org.apache.reef.runtime.common.Launchert\000\rLauncher.javat\000\004mainsr\000&java.util.Collections$UnmodifiableList\374\017%1\265\354\216\020\002\000\001L\000\004listq\000~\000\005xr\000,java.util.Collections$UnmodifiableCollection\031B\000\200\313^\367\036\002\000\001L\000\001ct\000\026Ljava/util/Collection;xpsr\000\023java.util.ArrayListx\201\322\035\231\307a\235\003\000\001I\000\004sizexp\000\000\000\000w\004\000\000\000\000xq\000~\000Uxsq\000~\000T\000\000\000\001w\004\000\000\000\001sq\000~\000\016q\000~\000Wt\000CInput path does not exist: hdfs://localhost:9000/user/jwpark/sampleuq\000~\000\020\000\000\000\036sq\000~\000\022\000\000\001\003q\000~\000\024q\000~\000\025q\000~\000\026sq\000~\000\022\000\000\000\344q\000~\000\024q\000~\000\025q\000~\000\030sq\000~\000\022\000\000\0010q\000~\000\024q\000~\000\025q\000~\000\032sq\000~\000\022\000\000\000Yq\000~\000\034q\000~\000\035q\000~\000\036sq\000~\000\022\377\377\377\376q\000~\000 q\000~\000!q\000~\000\"sq\000~\000\022\000\000\0009q\000~\000 q\000~\000!q\000~\000$sq\000~\000\022\000\000\000-q\000~\000&q\000~\000\'q\000~\000$sq\000~\000\022\000\000\002\016q\000~\000)q\000~\000_q\000~\000$sq\000~\000\022\000\000\002{q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\001q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002\023q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\000\223q\000~\000Gq\000~\000Hq\000~\000Isq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sxxt\0009Unable to get InputSplits using the specified InputFormatuq\000~\000\020\000\000\000\033sq\000~\000\022\000\000\000dq\000~\000\034q\000~\000\035q\000~\000\036sq\000~\000\022\377\377\377\376q\000~\000 q\000~\000!q\000~\000\"sq\000~\000\022\000\000\0009q\000~\000 q\000~\000!q\000~\000$sq\000~\000\022\000\000\000-q\000~\000&q\000~\000\'q\000~\000$sq\000~\000\022\000\000\002\016q\000~\000)q\000~\000*q\000~\000$sq\000~\000\022\000\000\002{q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\001q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002\023q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\000\223q\000~\000Gq\000~\000Hq\000~\000Isq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sxt\002%Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\020\000\000\000\026sq\000~\000\022\000\000\002\213q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\001q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002\023q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\000\223q\000~\000Gq\000~\000Hq\000~\000Isq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sxt\002Yorg.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\020\000\000\000\fsq\000~\000\022\000\000\000q\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002\023q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\000\223q\000~\000Gq\000~\000Hq\000~\000Isq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sxt\000\037Unable to instantiate the clockuq\000~\000\020\000\000\000\003sq\000~\000\022\000\000\000\226q\000~\000Gq\000~\000Hq\000~\000Isq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sxt\000)Fatal exception while executing the clockuq\000~\000\020\000\000\000\003sq\000~\000\022\000\000\000\266q\000~\000Gq\000~\000Ht\000\004failsq\000~\000\022\000\000\000\244q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sx"
identifier: "K-means Clustering"
2014-11-05 17:28:39,918 FINER reef.runtime.common.launch.LaunchClass.run main | RETURN Clock terminated 2014-11-05 17:28:39,919 FINE reef.runtime.common.Launcher.main main | Launcher exiting 2014-11-05 17:28:39,919 FINER reef.runtime.common.launch.LaunchClass.close main | ENTRY 2014-11-05 17:28:39,920 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.close main | RemoteManager: REEFLAUNCHER Closing remote manager id: socket://192.168.0.187:18559 2014-11-05 17:28:39,922 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.open org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2 | Link null for /192.168.0.187:17053 found 2014-11-05 17:28:39,922 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.open org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2 | No cached link for /192.168.0.187:17053 thread Thread[org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2,5,main] 2014-11-05 17:28:39,923 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closing sender stage socket://192.168.0.187:18559 2014-11-05 17:28:39,924 FINE reef.wake.remote.impl.RemoteSenderStage.close pool-4-thread-1 | close org.apache.reef.wake.remote.transport.netty.NettyMessagingTransport@4042122d 2014-11-05 17:28:39,980 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.setLink org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1 | thread Thread[org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1,5,main] link localAddr: /192.168.0.187:37914 remoteAddr: /192.168.0.187:17053 2014-11-05 17:28:39,981 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.consumeQueue org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1 | RemoteEvent localAddr=/192.168.0.187:18559 remoteAddr=/192.168.0.187:17053 sourceName= sinkName=default seq=0 event=name: "reef" message: "Unable to instantiate the clock" exception: "\254\355\000\005sr\000\023java.lang.Exception\320\375\037>\032;\034\304\002\000\000xr\000\023java.lang.Throwable\325\3065\'9w\270\313\003\000\004L\000\005causet\000\025Ljava/lang/Throwable;L\000\rdetailMessaget\000\022Ljava/lang/String;[\000\nstackTracet\000\036[Ljava/lang/StackTraceElement;L\000\024suppressedExceptionst\000\020Ljava/util/List;xpsr\000\032java.lang.RuntimeException\236\006G\n4\203\345\002\000\000xq\000~\000\000sr\0002org.apache.reef.tang.exceptions.InjectionException\000\000\000\000\000\000\000\001\002\000\000xq\000~\000\000sq\000~\000\asr\000.org.apache.hadoop.mapred.InvalidInputException\000\000\000\000\000\000\000\001\002\000\001L\000\bproblemsq\000~\000\005xr\000\023java.io.IOExceptionl\200sde%\360\253\002\000\000xq\000~\000\000q\000~\000\016pur\000\036[Ljava.lang.StackTraceElement;\002F*<<\375\"9\002\000\000xp\000\000\000\036sr\000\033java.lang.StackTraceElementa\t\305\232&6\335\205\002\000\004I\000\nlineNumberL\000\016declaringClassq\000~\000\003L\000\bfileNameq\000~\000\003L\000\nmethodNameq\000~\000\003xp\000\000\001\035t\000(org.apache.hadoop.mapred.FileInputFormatt\000\024FileInputFormat.javat\000\030singleThreadedListStatussq\000~\000\021\000\000\000\344q\000~\000\023q\000~\000\024t\000\nlistStatussq\000~\000\021\000\000\0010q\000~\000\023q\000~\000\024t\000\tgetSplitssq\000~\000\021\000\000\000Yt\000>org.apache.reef.io.data.loading.impl.InputFormatLoadingServicet\000\036InputFormatLoadingService.javat\000\006sq\000~\000\021\377\377\377\376t\000)sun.reflect.NativeConstructorAccessorImplt\000\"NativeConstructorAccessorImpl.javat\000\fnewInstance0sq\000~\000\021\000\000\0009q\000~\000\037q\000~\000 t\000\vnewInstancesq\000~\000\021\000\000\000-t\000-sun.reflect.DelegatingConstructorAccessorImplt\000&DelegatingConstructorAccessorImpl.javaq\000~\000#sq\000~\000\021\000\000\002\016t\000\035java.lang.reflect.Constructort\000\020Constructor.javaq\000~\000#sq\000~\000\021\000\000\002{t\0005org.apache.reef.tang.implementation.java.InjectorImplt\000\021InjectorImpl.javat\000\016injectFromPlansq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\001q\000~\000+q\000~\000,t\000\vgetInstancesq\000~\000\021\000\000\002 q\000~\000+q\000~\000,t\000\020getNamedInstancesq\000~\000\021\000\000\000tt\000$org.apache.reef.tang.InjectionFuturet\000\024InjectionFuture.javat\000\003getsq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002\023q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\000\223t\0001org.apache.reef.runtime.common.launch.LaunchClasst\000\020LaunchClass.javat\000\bgetClocksq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gt\000\003runsq\000~\000\021\000\000\000ot\000\'org.apache.reef.runtime.common.Launchert\000\rLauncher.javat\000\004mainsr\000&java.util.Collections$UnmodifiableList\374\017%1\265\354\216\020\002\000\001L\000\004listq\000~\000\005xr\000,java.util.Collections$UnmodifiableCollection\031B\000\200\313^\367\036\002\000\001L\000\001ct\000\026Ljava/util/Collection;xpsr\000\023java.util.ArrayListx\201\322\035\231\307a\235\003\000\001I\000\004sizexp\000\000\000\000w\004\000\000\000\000xq\000~\000Txsq\000~\000S\000\000\000\001w\004\000\000\000\001sq\000~\000\rq\000~\000Vt\000CInput path does not exist: hdfs://localhost:9000/user/jwpark/sampleuq\000~\000\017\000\000\000\036sq\000~\000\021\000\000\001\003q\000~\000\023q\000~\000\024q\000~\000\025sq\000~\000\021\000\000\000\344q\000~\000\023q\000~\000\024q\000~\000\027sq\000~\000\021\000\000\0010q\000~\000\023q\000~\000\024q\000~\000\031sq\000~\000\021\000\000\000Yq\000~\000\033q\000~\000\034q\000~\000\035sq\000~\000\021\377\377\377\376q\000~\000\037q\000~\000 q\000~\000!sq\000~\000\021\000\000\0009q\000~\000\037q\000~\000 q\000~\000#sq\000~\000\021\000\000\000-q\000~\000%q\000~\000&q\000~\000#sq\000~\000\021\000\000\002\016q\000~\000(q\000~\000)q\000~\000#sq\000~\000\021\000\000\002{q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\001q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002\023q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\000\223q\000~\000Fq\000~\000Gq\000~\000Hsq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gq\000~\000Jsq\000~\000\021\000\000\000oq\000~\000Lq\000~\000Mq\000~\000Nq\000~\000Rxxt\0009Unable to get InputSplits using the specified InputFormatuq\000~\000\017\000\000\000\033sq\000~\000\021\000\000\000dq\000~\000\033q\000~\000\034q\000~\000\035sq\000~\000\021\377\377\377\376q\000~\000\037q\000~\000 q\000~\000!sq\000~\000\021\000\000\0009q\000~\000\037q\000~\000 q\000~\000#sq\000~\000\021\000\000\000-q\000~\000%q\000~\000&q\000~\000#sq\000~\000\021\000\000\002\016q\000~\000(q\000~\000)q\000~\000#sq\000~\000\021\000\000\002{q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\001q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002\023q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\000\223q\000~\000Fq\000~\000Gq\000~\000Hsq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gq\000~\000Jsq\000~\000\021\000\000\000oq\000~\000Lq\000~\000Mq\000~\000Nq\000~\000Rxt\002%Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\017\000\000\000\026sq\000~\000\021\000\000\002\213q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002oq\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\221q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\226q\000~\000+q\000~\000,q\000~\000-sq\000~\000\021\000\000\002\001q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002\023q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\000\223q\000~\000Fq\000~\000Gq\000~\000Hsq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gq\000~\000Jsq\000~\000\021\000\000\000oq\000~\000Lq\000~\000Mq\000~\000Nq\000~\000Rxt\002Yorg.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\017\000\000\000\fsq\000~\000\021\000\000\000q\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002 q\000~\000+q\000~\000,q\000~\0008sq\000~\000\021\000\000\000tq\000~\000:q\000~\000;q\000~\000<sq\000~\000\021\000\000\002\aq\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\002\023q\000~\000+q\000~\000,q\000~\0006sq\000~\000\021\000\000\000\223q\000~\000Fq\000~\000Gq\000~\000Hsq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gq\000~\000Jsq\000~\000\021\000\000\000oq\000~\000Lq\000~\000Mq\000~\000Nq\000~\000Rxt\000\037Unable to instantiate the clockuq\000~\000\017\000\000\000\004sq\000~\000\021\000\000\000\266q\000~\000Fq\000~\000Gt\000\004failsq\000~\000\021\000\000\000\225q\000~\000Fq\000~\000Gq\000~\000Hsq\000~\000\021\000\000\000\242q\000~\000Fq\000~\000Gq\000~\000Jsq\000~\000\021\000\000\000oq\000~\000Lq\000~\000Mq\000~\000Nq\000~\000Rx"
identifier: "K-means Clustering"
2014-11-05 17:28:39,984 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.setLink org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2 | thread Thread[org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2,5,main] link localAddr: /192.168.0.187:37914 remoteAddr: /192.168.0.187:17053 2014-11-05 17:28:39,985 FINEST reef.wake.remote.impl.RemoteSenderEventHandler.consumeQueue org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2 | RemoteEvent localAddr=/192.168.0.187:18559 remoteAddr=/192.168.0.187:17053 sourceName= sinkName=default seq=1 event=name: "reef" message: "Fatal exception while executing the clock" exception: "\254\355\000\005sr\000\023java.lang.Exception\320\375\037>\032;\034\304\002\000\000xr\000\023java.lang.Throwable\325\3065\'9w\270\313\003\000\004L\000\005causet\000\025Ljava/lang/Throwable;L\000\rdetailMessaget\000\022Ljava/lang/String;[\000\nstackTracet\000\036[Ljava/lang/StackTraceElement;L\000\024suppressedExceptionst\000\020Ljava/util/List;xpsr\000\032java.lang.RuntimeException\236\006G\n4\203\345\002\000\000xq\000~\000\000sq\000~\000\asr\0002org.apache.reef.tang.exceptions.InjectionException\000\000\000\000\000\000\000\001\002\000\000xq\000~\000\000sq\000~\000\asr\000.org.apache.hadoop.mapred.InvalidInputException\000\000\000\000\000\000\000\001\002\000\001L\000\bproblemsq\000~\000\005xr\000\023java.io.IOExceptionl\200sde%\360\253\002\000\000xq\000~\000\000q\000~\000\017pur\000\036[Ljava.lang.StackTraceElement;\002F<<\375\"9\002\000\000xp\000\000\000\036sr\000\033java.lang.StackTraceElementa\t\305\232&6\335\205\002\000\004I\000\nlineNumberL\000\016declaringClassq\000~\000\003L\000\bfileNameq\000~\000\003L\000\nmethodNameq\000~\000\003xp\000\000\001\035t\000(org.apache.hadoop.mapred.FileInputFormatt\000\024FileInputFormat.javat\000\030singleThreadedListStatussq\000~\000\022\000\000\000\344q\000~\000\024q\000~\000\025t\000\nlistStatussq\000~\000\022\000\000\0010q\000~\000\024q\000~\000\025t\000\tgetSplitssq\000~\000\022\000\000\000Yt\000>org.apache.reef.io.data.loading.impl.InputFormatLoadingServicet\000\036InputFormatLoadingService.javat\000\006sq\000~\000\022\377\377\377\376t\000)sun.reflect.NativeConstructorAccessorImplt\000\"NativeConstructorAccessorImpl.javat\000\fnewInstance0sq\000~\000\022\000\000\0009q\000~\000 q\000~\000!t\000\vnewInstancesq\000~\000\022\000\000\000-t\000-sun.reflect.DelegatingConstructorAccessorImplt\000&DelegatingConstructorAccessorImpl.javaq\000~\000$sq\000~\000\022\000\000\002\016t\000\035java.lang.reflect.Constructort\000\020Constructor.javaq\000~\000$sq\000~\000\022\000\000\002{t\0005org.apache.reef.tang.implementation.java.InjectorImplt\000\021InjectorImpl.javat\000\016injectFromPlansq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\001q\000~\000,q\000~\000-t\000\vgetInstancesq\000~\000\022\000\000\002 q\000~\000,q\000~\000-t\000\020getNamedInstancesq\000~\000\022\000\000\000tt\000$org.apache.reef.tang.InjectionFuturet\000\024InjectionFuture.javat\000\003getsq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002\023q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\000\223t\0001org.apache.reef.runtime.common.launch.LaunchClasst\000\020LaunchClass.javat\000\bgetClocksq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Ht\000\003runsq\000~\000\022\000\000\000ot\000\'org.apache.reef.runtime.common.Launchert\000\rLauncher.javat\000\004mainsr\000&java.util.Collections$UnmodifiableList\374\017%1\265\354\216\020\002\000\001L\000\004listq\000~\000\005xr\000,java.util.Collections$UnmodifiableCollection\031B\000\200\313^\367\036\002\000\001L\000\001ct\000\026Ljava/util/Collection;xpsr\000\023java.util.ArrayListx\201\322\035\231\307a\235\003\000\001I\000\004sizexp\000\000\000\000w\004\000\000\000\000xq\000~\000Uxsq\000~\000T\000\000\000\001w\004\000\000\000\001sq\000~\000\016q\000~\000Wt\000CInput path does not exist: hdfs://localhost:9000/user/jwpark/sampleuq\000~\000\020\000\000\000\036sq\000~\000\022\000\000\001\003q\000~\000\024q\000~\000\025q\000~\000\026sq\000~\000\022\000\000\000\344q\000~\000\024q\000~\000\025q\000~\000\030sq\000~\000\022\000\000\0010q\000~\000\024q\000~\000\025q\000~\000\032sq\000~\000\022\000\000\000Yq\000~\000\034q\000~\000\035q\000~\000\036sq\000~\000\022\377\377\377\376q\000~\000 q\000~\000!q\000~\000\"sq\000~\000\022\000\000\0009q\000~\000 q\000~\000!q\000~\000$sq\000~\000\022\000\000\000-q\000~\000&q\000~\000\'q\000~\000$sq\000~\000\022\000\000\002\016q\000~\000)q\000~\000_q\000~\000$sq\000~\000\022\000\000\002{q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\001q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002\023q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\000\223q\000~\000Gq\000~\000Hq\000~\000Isq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sxxt\0009Unable to get InputSplits using the specified InputFormatuq\000~\000\020\000\000\000\033sq\000~\000\022\000\000\000dq\000~\000\034q\000~\000\035q\000~\000\036sq\000~\000\022\377\377\377\376q\000~\000 q\000~\000!q\000~\000\"sq\000~\000\022\000\000\0009q\000~\000 q\000~\000!q\000~\000$sq\000~\000\022\000\000\000-q\000~\000&q\000~\000\'q\000~\000$sq\000~\000\022\000\000\002\016q\000~\000)q\000~\000*q\000~\000$sq\000~\000\022\000\000\002{q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\001q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002\023q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\000\223q\000~\000Gq\000~\000Hq\000~\000Isq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sxt\002%Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\020\000\000\000\026sq\000~\000\022\000\000\002\213q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002oq\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\221q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\226q\000~\000,q\000~\000-q\000~\000.sq\000~\000\022\000\000\002\001q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002\023q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\000\223q\000~\000Gq\000~\000Hq\000~\000Isq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sxt\002Yorg.apache.reef.tang.exceptions.InjectionException: Could not invoke constructor: new InputFormatLoadingService(InputFormat = new InputFormatExternalConstructor(JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)), JobConf = new JobConfExternalConstructor(String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample), Integer NumberOfDesiredSplits = 4, Boolean LoadDataIntoMemory = false, String InputFormatClass = org.apache.hadoop.mapred.TextInputFormat, String InputPath = sample)uq\000~\000\020\000\000\000\fsq\000~\000\022\000\000\000q\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002 q\000~\000,q\000~\000-q\000~\0009sq\000~\000\022\000\000\000tq\000~\000;q\000~\000<q\000~\000=sq\000~\000\022\000\000\002\aq\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\002\023q\000~\000,q\000~\000-q\000~\0007sq\000~\000\022\000\000\000\223q\000~\000Gq\000~\000Hq\000~\000Isq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sxt\000\037Unable to instantiate the clockuq\000~\000\020\000\000\000\003sq\000~\000\022\000\000\000\226q\000~\000Gq\000~\000Hq\000~\000Isq\000~\000\022\000\000\000\242q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sxt\000)Fatal exception while executing the clockuq\000~\000\020\000\000\000\003sq\000~\000\022\000\000\000\266q\000~\000Gq\000~\000Ht\000\004failsq\000~\000\022\000\000\000\244q\000~\000Gq\000~\000Hq\000~\000Ksq\000~\000\022\000\000\000oq\000~\000Mq\000~\000Nq\000~\000Oq\000~\000Sx"
identifier: "K-means Clustering"
2014-11-05 17:28:39,987 FINEST reef.wake.remote.transport.netty.NettyClientEventListener.channelActive org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-1 | io.netty.channel.DefaultChannelHandlerContext@5c24a0b 2014-11-05 17:28:40,074 FINEST reef.wake.remote.transport.netty.NettyLink.write org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-1 | write [id: 0x5787a928, /192.168.0.187:37914 => /192.168.0.187:17053] [B@36b6447b 2014-11-05 17:28:40,076 FINEST reef.wake.remote.transport.netty.NettyLink.write org.apache.reef.wake.remote.impl.RemoteSenderStage-pool-6-thread-2 | write [id: 0x5787a928, /192.168.0.187:37914 => /192.168.0.187:17053] [B@431eb046 2014-11-05 17:28:40,101 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closed the remote sender stage 2014-11-05 17:28:40,102 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closing transport socket://192.168.0.187:18559 2014-11-05 17:28:40,102 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.close pool-4-thread-1 | Closing netty transport socket address: /192.168.0.187:18559 2014-11-05 17:28:40,122 FINER reef.wake.remote.transport.netty.AbstractNettyEventListener.closeChannel org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-1 | Channel closed: [id: 0x5787a928, /192.168.0.187:37914 :> /192.168.0.187:17053]. Link ref found and removed: true 2014-11-05 17:28:40,137 FINE reef.wake.remote.transport.netty.NettyMessagingTransport.close pool-4-thread-1 | Closing netty transport socket address: /192.168.0.187:18559 done 2014-11-05 17:28:40,137 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closed the transport 2014-11-05 17:28:40,138 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closing receiver stage socket://192.168.0.187:18559 2014-11-05 17:28:40,139 FINE reef.wake.remote.impl.OrderedRemoteReceiverStage.close pool-4-thread-1 | close 2014-11-05 17:28:40,140 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation$1.run pool-4-thread-1 | Closed the remote receiver stage 2014-11-05 17:28:40,141 FINE reef.wake.remote.impl.DefaultRemoteManagerImplementation.close main | Close executor terminated properly. 2014-11-05 17:28:40,142 FINER reef.runtime.common.launch.LaunchClass.close main | RETURN 2014-11-05 17:28:40,142 INFO reef.runtime.common.Launcher.main main | Exiting Launcher.main() 2014-11-05 17:28:40,149 FINEST reef.runtime.common.Launcher.main main | Threads running after Launcher.close(): Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-4': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-7': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'pool-4-thread-1': sun.misc.Unsafe.unpark(Native Method) java.util.concurrent.locks.LockSupport.unpark(LockSupport.java:152) java.util.concurrent.locks.AbstractQueuedSynchronizer.unparkSuccessor(AbstractQueuedSynchronizer.java:662) java.util.concurrent.locks.AbstractQueuedSynchronizer.release(AbstractQueuedSynchronizer.java:1263) java.util.concurrent.locks.ReentrantLock.unlock(ReentrantLock.java:460) java.util.concurrent.ThreadPoolExecutor.tryTerminate(ThreadPoolExecutor.java:712) java.util.concurrent.ThreadPoolExecutor.processWorkerExit(ThreadPoolExecutor.java:1006) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1163) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-6': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'Finalizer': java.lang.Object.wait(Native Method) java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:135) java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:151) java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-12': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-4': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-5': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-17': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-10': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-11': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-6': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'IPC Parameter Sending Thread #0': sun.misc.Unsafe.park(Native Method) java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226) java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460) java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359) java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942) java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-16': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-19': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerBoss-pool-3-thread-3': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'Reference Handler': java.lang.Object.wait(Native Method) java.lang.Object.wait(Object.java:503) java.lang.ref.Reference$ReferenceHandler.run(Reference.java:133) Thread 'IPC Client (1249106906) connection to localhost/127.0.0.1:9000 from jwpark': java.lang.Object.wait(Native Method) org.apache.hadoop.ipc.Client$Connection.waitForWork(Client.java:903) org.apache.hadoop.ipc.Client$Connection.run(Client.java:948) Thread 'Signal Dispatcher': Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerBoss-pool-3-thread-1': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-8': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-20': Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-18': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-13': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-7': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'process reaper': sun.misc.Unsafe.park(Native Method) java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226) java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460) java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359) java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942) java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-3': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-15': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-5': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-10': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-2': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-14': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-1': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-3': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-8': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerBoss-pool-3-thread-2': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'main': java.lang.Thread.dumpThreads(Native Method) java.lang.Thread.getAllStackTraces(Thread.java:1640) org.apache.reef.util.ThreadLogger.getFormattedThreadList(ThreadLogger.java:70) org.apache.reef.util.ThreadLogger.getFormattedThreadList(ThreadLogger.java:83) org.apache.reef.runtime.common.Launcher.main(Launcher.java:119) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-2': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportServerWorker-pool-4-thread-9': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-9': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) Thread 'org.apache.reef.wake.remote.transport.netty.NettyMessagingTransportClientWorker-pool-5-thread-1': java.lang.Thread.sleep(Native Method) io.netty.util.concurrent.SingleThreadEventExecutor.confirmShutdown(SingleThreadEventExecutor.java:662) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:362) io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) java.lang.Thread.run(Thread.java:745) 2014-11-05 17:28:40,151 FINEST reef.wake.impl.StageManager$1.run Thread-1 | Shutdown hook : closing stages 2014-11-05 17:28:40,152 FINEST reef.wake.impl.StageManager.close Thread-1 | Closing org.apache.reef.wake.impl.ThreadPoolStage@4ee6d1d6 2014-11-05 17:28:40,152 FINEST reef.wake.impl.StageManager.close Thread-1 | Closing org.apache.reef.wake.impl.ThreadPoolStage@5d2b7e11 2014-11-05 17:28:40,153 FINEST reef.wake.impl.StageManager.close Thread-1 | Closing org.apache.reef.wake.remote.impl.DefaultRemoteManagerImplementation@5505aa49 2014-11-05 17:28:40,153 FINEST reef.wake.impl.StageManager$1.run Thread-1 | Shutdown hook : closed stages