我试着用 HdfsBolt 将storm拓扑的输出写入支持ha的hdfs。拓扑定义如下：

// Use pipe as record boundary
RecordFormat format = new DelimitedRecordFormat().withFieldDelimiter("|");
//Synchronize data buffer with the filesystem every 1000 tuples
SyncPolicy syncPolicy = new CountSyncPolicy(1000);
// Rotate data files when they reach five MB
FileRotationPolicy rotationPolicy = new FileSizeRotationPolicy(5.0f, FileSizeRotationPolicy.Units.MB);
// Use default, Storm-generated file names
FileNameFormat fileNameFormat = new DefaultFileNameFormat().withPath("/foo");

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

问题是 HdfsBolt 没有意识到 hdfs://devhdfs 这就触发了 java.net.UnknownHostException :

Caused by: java.lang.IllegalArgumentException: java.net.UnknownHostException: prehdfs

我有原始的core-site.xml，其中包含该定义，但我不知道如何将其传递给 HdfsBolt . 有什么提示吗？