diff --git a/be/src/io/fs/hdfs_file_writer.cpp b/be/src/io/fs/hdfs_file_writer.cpp index 7efb4bfb073d6a..22f951b6669200 100644 --- a/be/src/io/fs/hdfs_file_writer.cpp +++ b/be/src/io/fs/hdfs_file_writer.cpp @@ -60,7 +60,7 @@ Status HdfsFileWriter::close() { _closed = true; if (_sync_file_data) { - int ret = hdfsHSync(_hdfs_handler->hdfs_fs, _hdfs_file); + int ret = hdfsSync(_hdfs_handler->hdfs_fs, _hdfs_file); if (ret != 0) { return Status::InternalError("failed to sync hdfs file. fs_name={} path={} : {}", _fs_name, _path.native(), hdfs_error());