老師,storm寫入hdfs為啥不成功?
參考/github的例子:
HdfsBolt bolt = new HdfsBolt()
? ? ? ?.withFsUrl("hdfs://localhost:54310")
? ? ? ?.withFileNameFormat(fileNameFormat)
? ? ? ?.withRecordFormat(format)
? ? ? ?.withRotationPolicy(rotationPolicy)
? ? ? ?.withSyncPolicy(syncPolicy);
我把“localhost:54310”換成自己的集群名字,就不能正常訪問,會報錯,提示不識別我的集群名,像例子中的用主機名或者ip是可以的。請問知道原因嗎?
2017-03-29
用storm-hdfs