2016-04-24 3 views
0

私はhadoopマルチノードクラスタでwordcount Javaプログラムを実行しようとしていました(シングルノードクラスタではうまくいきましたが、マルチノードでは動作しません)。次の情報に戻ります。マルチノードクラスタでmapreduce wordcount(Javaコード)を実行しています

INFO ipc.Client:サーバーに接続する再試行:localhost/127.0.0.1:54310。既に0回試しました。再試行ポリシーはRetryUpToMaximumCountWithFixedSleep(maxRetries = 10、sleepTime = 1 SECONDS)です。 16/04/24 21:30:46情報ipc.Client:サーバーへの再接続:localhost/127.0.0.1:54310。すでに1回試しました。ポリシーを再試行してください、私はパスに何か問題があると思いRetryUpToMaximumCountWithFixedSleep(MaxRetriesの= 10、= 1 SECONDS SLEEPTIME)

public static void main(String[] args) throws Exception 
{ 
Configuration conf = new Configuration(); 

    Job job = new Job(conf, "wordcount"); 

job.setOutputKeyClass(Text.class); 
job.setOutputValueClass(IntWritable.class); 

job.setMapperClass(Map.class); 
job.setReducerClass(Reduce.class); 

job.setInputFormatClass(TextInputFormat.class); 
job.setOutputFormatClass(TextOutputFormat.class); 

FileInputFormat.addInputPath(job, new Path("hdfs://localhost:54310/user/hduser/sam/")); 
FileOutputFormat.setOutputPath(job, new Path("hdfs://localhost:54310/user/hduser/wc-output")); 

job.waitForCompletion(true); 

}

*

}

です。 私はマスターエンド

答えて

0

でこのコードを実行しているコマンド

hdfs dfs -ls hdfs://localhost:54310/user/hduser/sam/ 

仕事をしていますか?

+0

同じ情報が表示されていません。 –

+0

お試しください hdfs dfs -ls/user/hduser/sam/ もし問題がなければ、おそらく間違ったポートを指定しています。 ノード上でnamenodeプロセスが実行されていることを確認します。 – deba

関連する問題