3 回答

TA貢獻(xiàn)1828條經(jīng)驗(yàn) 獲得超6個(gè)贊
HADOOP_CONF_DIR在您的Hadoop配置文件夾中定義環(huán)境變量,或者在代碼中添加以下兩行:
config.addResource(new Path("/HADOOP_HOME/conf/core-site.xml"));
config.addResource(new Path("/HADOOP_HOME/conf/hdfs-site.xml"));
如果不添加它,則客戶端將嘗試寫(xiě)入本地FS,從而導(dǎo)致權(quán)限被拒絕的異常。

TA貢獻(xiàn)1806條經(jīng)驗(yàn) 獲得超8個(gè)贊
請(qǐng)嘗試以下方法。
FileSystem fs = path.getFileSystem(conf);
SequenceFile.Writer inputWriter = new SequenceFile.Writer(fs, conf, path, LongWritable.class, MyWritable.class);
inputWriter.append(new LongWritable(uniqueId++), new MyWritable(data));
inputWriter.close();
添加回答
舉報(bào)