鱼之吻
2016-09-18 18:48
参考/github的例子:
HdfsBolt bolt = new HdfsBolt()
.withFsUrl("hdfs://localhost:54310")
.withFileNameFormat(fileNameFormat)
.withRecordFormat(format)
.withRotationPolicy(rotationPolicy)
.withSyncPolicy(syncPolicy);
我把“localhost:54310”换成自己的集群名字,就不能正常访问,会报错,提示不识别我的集群名,像例子中的用主机名或者ip是可以的。请问知道原因吗?
用storm-hdfs
走进大数据之storm流式计算基础
26624 学习 · 22 问题
相似问题