This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-4.0-preview
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0-preview by this
push:
new df2a48bfc38 [chore](HDFS) Remove hdfs writer's injection point code #
(#34539)
df2a48bfc38 is described below
commit df2a48bfc381e7da6812a159e43b448c9a284ef1
Author: AlexYue <[email protected]>
AuthorDate: Wed May 8 17:26:41 2024 +0800
[chore](HDFS) Remove hdfs writer's injection point code # (#34539)
---
be/src/io/fs/hdfs_file_writer.cpp | 14 --------------
1 file changed, 14 deletions(-)
diff --git a/be/src/io/fs/hdfs_file_writer.cpp
b/be/src/io/fs/hdfs_file_writer.cpp
index 9ea66ca4da1..344609d382e 100644
--- a/be/src/io/fs/hdfs_file_writer.cpp
+++ b/be/src/io/fs/hdfs_file_writer.cpp
@@ -92,8 +92,6 @@ Status HdfsFileWriter::close() {
ret = hdfsHSync(_hdfs_handler->hdfs_fs, _hdfs_file);
#endif
}
- TEST_INJECTION_POINT_RETURN_WITH_VALUE("HdfsFileWriter::hdfeSync",
- Status::InternalError("failed
to sync hdfs file"));
if (ret != 0) {
return Status::InternalError(
@@ -109,8 +107,6 @@ Status HdfsFileWriter::close() {
ret = hdfsCloseFile(_hdfs_handler->hdfs_fs, _hdfs_file);
}
_hdfs_file = nullptr;
- TEST_INJECTION_POINT_RETURN_WITH_VALUE("HdfsFileWriter::hdfsCloseFile",
- Status::InternalError("failed to
close hdfs file"));
if (ret != 0) {
std::string err_msg = hdfs_error();
return Status::InternalError(
@@ -180,17 +176,9 @@ Status HdfsFileWriter::append_hdfs_file(std::string_view
content) {
while (!content.empty()) {
int64_t written_bytes;
{
-
TEST_INJECTION_POINT_CALLBACK("HdfsFileWriter::append_hdfs_file_delay");
SCOPED_BVAR_LATENCY(hdfs_bvar::hdfs_write_latency);
written_bytes =
hdfsWrite(_hdfs_handler->hdfs_fs, _hdfs_file,
content.data(), content.size());
- {
- [[maybe_unused]] Status error_ret = Status::InternalError(
- "write hdfs failed. fs_name: {}, path: {}, error: size
exceeds", _fs_name,
- _path.native());
-
TEST_INJECTION_POINT_RETURN_WITH_VALUE("HdfsFileWriter::append_hdfs_file_error",
- error_ret);
- }
}
if (written_bytes < 0) {
return Status::InternalError(
@@ -263,8 +251,6 @@ Status HdfsFileWriter::finalize() {
// Flush buffered data to HDFS without waiting for HDFS response
int ret = hdfsFlush(_hdfs_handler->hdfs_fs, _hdfs_file);
- TEST_INJECTION_POINT_RETURN_WITH_VALUE("HdfsFileWriter::hdfsFlush",
- Status::InternalError("failed to
flush hdfs file"));
if (ret != 0) {
return Status::InternalError(
"failed to flush hdfs file. fs_name={} path={} : {},
file_size={}", _fs_name,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
