私は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);
}
*}
です。 私はマスターエンド
同じ情報が表示されていません。 –
お試しください hdfs dfs -ls/user/hduser/sam/ もし問題がなければ、おそらく間違ったポートを指定しています。 ノード上でnamenodeプロセスが実行されていることを確認します。 – deba