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 cff9ffa0e1 fix the inaccurate comments (#10617)
cff9ffa0e1 is described below
commit cff9ffa0e127f1eb44b02924a39731c15336cf79
Author: carlvinhust2012 <huchengha...@126.com>
AuthorDate: Wed Jul 6 17:54:43 2022 +0800
fix the inaccurate comments (#10617)
Co-authored-by: hucheng01 <huchen...@baidu.com>
---
be/src/exec/broker_scan_node.cpp | 2 +-
be/src/exec/es_http_scan_node.cpp | 2 +-
be/src/vec/exec/file_scan_node.cpp | 2 +-
be/src/vec/exec/vbroker_scan_node.cpp | 2 +-
be/src/vec/exec/ves_http_scan_node.cpp | 2 +-
5 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/be/src/exec/broker_scan_node.cpp b/be/src/exec/broker_scan_node.cpp
index ed9e646397..532a9d7d06 100644
--- a/be/src/exec/broker_scan_node.cpp
+++ b/be/src/exec/broker_scan_node.cpp
@@ -360,7 +360,7 @@ Status BrokerScanNode::scanner_scan(const TBrokerScanRange&
scan_range,
// Queue size Must be smaller than _max_buffered_batches
_batch_queue.push_back(row_batch);
- // Notify reader to
+ // Notify reader to process
_queue_reader_cond.notify_one();
}
}
diff --git a/be/src/exec/es_http_scan_node.cpp
b/be/src/exec/es_http_scan_node.cpp
index 81303b002b..62d219d13d 100644
--- a/be/src/exec/es_http_scan_node.cpp
+++ b/be/src/exec/es_http_scan_node.cpp
@@ -390,7 +390,7 @@ Status
EsHttpScanNode::scanner_scan(std::unique_ptr<EsHttpScanner> scanner,
// Queue size Must be smaller than _max_buffered_batches
_batch_queue.push_back(row_batch);
- // Notify reader to
+ // Notify reader to process
_queue_reader_cond.notify_one();
}
}
diff --git a/be/src/vec/exec/file_scan_node.cpp
b/be/src/vec/exec/file_scan_node.cpp
index 10ecfde835..4105f8dc01 100644
--- a/be/src/vec/exec/file_scan_node.cpp
+++ b/be/src/vec/exec/file_scan_node.cpp
@@ -258,7 +258,7 @@ Status FileScanNode::scanner_scan(const TFileScanRange&
scan_range, ScannerCount
// Queue size Must be smaller than _max_buffered_batches
_block_queue.push_back(block);
- // Notify reader to
+ // Notify reader to process
_queue_reader_cond.notify_one();
}
return Status::OK();
diff --git a/be/src/vec/exec/vbroker_scan_node.cpp
b/be/src/vec/exec/vbroker_scan_node.cpp
index 212c82d157..6f63324e6d 100644
--- a/be/src/vec/exec/vbroker_scan_node.cpp
+++ b/be/src/vec/exec/vbroker_scan_node.cpp
@@ -257,7 +257,7 @@ Status VBrokerScanNode::scanner_scan(const
TBrokerScanRange& scan_range, Scanner
// Queue size Must be smaller than _max_buffered_batches
_block_queue.push_back(block);
- // Notify reader to
+ // Notify reader to process
_queue_reader_cond.notify_one();
}
return Status::OK();
diff --git a/be/src/vec/exec/ves_http_scan_node.cpp
b/be/src/vec/exec/ves_http_scan_node.cpp
index c1c2e79f37..b81511408a 100644
--- a/be/src/vec/exec/ves_http_scan_node.cpp
+++ b/be/src/vec/exec/ves_http_scan_node.cpp
@@ -320,7 +320,7 @@ Status
VEsHttpScanNode::scanner_scan(std::unique_ptr<VEsHttpScanner> scanner) {
}
_block_queue.push_back(block);
- // Notify reader to
+ // Notify reader to process
_queue_reader_cond.notify_one();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
