This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 7fc850f9ca4 [improvement](stream load) display the time of receiving
network data (#40735)
7fc850f9ca4 is described below
commit 7fc850f9ca4ad64ac583fa4010bbcb985781dd29
Author: hui lai <[email protected]>
AuthorDate: Sat Sep 14 16:17:12 2024 +0800
[improvement](stream load) display the time of receiving network data
(#40735)
Display the time of receiving network data.
For example:
```
Stream load result: {
"TxnId": 19,
"Label": "c10ee032-c19c-484f-80b2-16f6c1d0c209",
"Comment": "",
"TwoPhaseCommit": "false",
"Status": "Success",
"Message": "OK",
"NumberTotalRows": 6,
"NumberLoadedRows": 6,
"NumberFilteredRows": 0,
"NumberUnselectedRows": 0,
"LoadBytes": 60,
"LoadTimeMs": 32,
"BeginTxnTimeMs": 0,
"StreamLoadPutTimeMs": 4,
"ReadDataTimeMs": 0,
"WriteDataTimeMs": 4,
"ReceiveDataTimeMs": 6,
"CommitAndPublishTimeMs": 22
}
```
---
be/src/runtime/stream_load/stream_load_context.cpp | 2 ++
1 file changed, 2 insertions(+)
diff --git a/be/src/runtime/stream_load/stream_load_context.cpp
b/be/src/runtime/stream_load/stream_load_context.cpp
index cec015fe92c..dbabf7fa421 100644
--- a/be/src/runtime/stream_load/stream_load_context.cpp
+++ b/be/src/runtime/stream_load/stream_load_context.cpp
@@ -107,6 +107,8 @@ std::string StreamLoadContext::to_json() const {
writer.Int64(read_data_cost_nanos / 1000000);
writer.Key("WriteDataTimeMs");
writer.Int(write_data_cost_nanos / 1000000);
+ writer.Key("ReceiveDataTimeMs");
+ writer.Int((receive_and_read_data_cost_nanos - read_data_cost_nanos) /
1000000);
if (!group_commit) {
writer.Key("CommitAndPublishTimeMs");
writer.Int64(commit_and_publish_txn_cost_nanos / 1000000);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
