问答详情
源自:-

老师,storm写入hdfs为啥不成功?

参考/github的例子:

HdfsBolt bolt = new HdfsBolt()
       .withFsUrl("hdfs://localhost:54310")
       .withFileNameFormat(fileNameFormat)
       .withRecordFormat(format)
       .withRotationPolicy(rotationPolicy)
       .withSyncPolicy(syncPolicy);

我把“localhost:54310”换成自己的集群名字,就不能正常访问,会报错,提示不识别我的集群名,像例子中的用主机名或者ip是可以的。请问知道原因吗?

提问者:鱼之吻 2016-09-18 18:48

个回答

  • 慕粉232556429
    2017-03-29 23:22:10

    用storm-hdfs