This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 1c4927eac3 [fix](core)fix bug for status not init(#11730)
1c4927eac3 is described below
commit 1c4927eac30d53e57f1ed43e57c1adc5262c0b64
Author: pengxiangyu <[email protected]>
AuthorDate: Fri Aug 12 17:42:37 2022 +0800
[fix](core)fix bug for status not init(#11730)
---
be/src/vec/exec/file_arrow_scanner.cpp | 2 +-
be/src/vec/exec/varrow_scanner.cpp | 2 +-
be/src/vec/exec/vexcept_node.cpp | 2 +-
be/src/vec/exec/vintersect_node.cpp | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/be/src/vec/exec/file_arrow_scanner.cpp
b/be/src/vec/exec/file_arrow_scanner.cpp
index c8ce603f89..998d40ea6f 100644
--- a/be/src/vec/exec/file_arrow_scanner.cpp
+++ b/be/src/vec/exec/file_arrow_scanner.cpp
@@ -127,7 +127,7 @@ Status FileArrowScanner::_next_arrow_batch() {
Status FileArrowScanner::_init_arrow_batch_if_necessary() {
// 1. init batch if first time
// 2. reset reader if end of file
- Status status;
+ Status status = Status::OK();
if (_scanner_eof) {
return Status::EndOfFile("EOF");
}
diff --git a/be/src/vec/exec/varrow_scanner.cpp
b/be/src/vec/exec/varrow_scanner.cpp
index 200e467810..1e5597f9a0 100644
--- a/be/src/vec/exec/varrow_scanner.cpp
+++ b/be/src/vec/exec/varrow_scanner.cpp
@@ -140,7 +140,7 @@ Status VArrowScanner::_next_arrow_batch() {
Status VArrowScanner::_init_arrow_batch_if_necessary() {
// 1. init batch if first time
// 2. reset reader if end of file
- Status status;
+ Status status = Status::OK();
if (_scanner_eof) {
return Status::EndOfFile("EOF");
}
diff --git a/be/src/vec/exec/vexcept_node.cpp b/be/src/vec/exec/vexcept_node.cpp
index 1a97359921..ee38702fbf 100644
--- a/be/src/vec/exec/vexcept_node.cpp
+++ b/be/src/vec/exec/vexcept_node.cpp
@@ -45,7 +45,7 @@ Status VExceptNode::open(RuntimeState* state) {
START_AND_SCOPE_SPAN(state->get_tracer(), span, "VExceptNode::open");
RETURN_IF_ERROR(VSetOperationNode::open(state));
bool eos = false;
- Status st;
+ Status st = Status::OK();
for (int i = 1; i < _children.size(); ++i) {
if (i > 1) {
refresh_hash_table<false>();
diff --git a/be/src/vec/exec/vintersect_node.cpp
b/be/src/vec/exec/vintersect_node.cpp
index f8f083ced1..5fcc5f10fa 100644
--- a/be/src/vec/exec/vintersect_node.cpp
+++ b/be/src/vec/exec/vintersect_node.cpp
@@ -45,7 +45,7 @@ Status VIntersectNode::open(RuntimeState* state) {
START_AND_SCOPE_SPAN(state->get_tracer(), span, "VIntersectNode::open");
RETURN_IF_ERROR(VSetOperationNode::open(state));
bool eos = false;
- Status st;
+ Status st = Status::OK();
for (int i = 1; i < _children.size(); ++i) {
if (i > 1) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
