You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2022/10/26 04:33:07 UTC
[doris] branch branch-1.1-lts updated: [Fix](Load) fix bug that last line of data lost for stream load #13673
This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-1.1-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.1-lts by this push:
new 54193561cc [Fix](Load) fix bug that last line of data lost for stream load #13673
54193561cc is described below
commit 54193561cc2837b9e1f761dce8e4623368afd4f8
Author: weizuo93 <we...@apache.org>
AuthorDate: Wed Oct 26 12:33:00 2022 +0800
[Fix](Load) fix bug that last line of data lost for stream load #13673
---
be/src/exec/plain_text_line_reader.cpp | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/be/src/exec/plain_text_line_reader.cpp b/be/src/exec/plain_text_line_reader.cpp
index 8932e1c492..8b24b487a5 100644
--- a/be/src/exec/plain_text_line_reader.cpp
+++ b/be/src/exec/plain_text_line_reader.cpp
@@ -200,9 +200,7 @@ Status PlainTextLineReader::read_line(const uint8_t** ptr, size_t* size, bool* e
// for multi bytes delimiter we cannot set offset to avoid incomplete
// delimiter
// read from file reader
- if (_line_delimiter_length == 1) {
- offset = output_buf_read_remaining();
- }
+ offset = output_buf_read_remaining();
extend_output_buf();
if ((_input_buf_limit > _input_buf_pos) && _more_input_bytes == 0) {
// we still have data in input which is not decompressed.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org