我正在使用webhdfs库将文件移动到hdfs(hadoop文件系统),如:
var hdfsConnector = WebHDFS.createClient(this.config());
var localFileStream = fs.createReadStream(sourcePath);
var remoteFileStream = hdfsConnector.createWriteStream(destinationPath);
localFileStream.pipe(remoteFileStream);
remoteFileStream.on('error', function onError (err) {
//On error
});
remoteFileStream.on('finish', function onFinish () {
//On finish
});
问题是每次都会触发finish回调,即出错时和成功时,因此如何识别成功。
暂无答案!
目前还没有任何答案,快来回答吧!