Skip to content

Commit

Permalink
[improvement](stream load) display the time of receiving network data (
Browse files Browse the repository at this point in the history
…#40735) (#41139)

pick (#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
}
```
  • Loading branch information
sollhui authored Sep 24, 2024
1 parent c81182a commit 602275d
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions be/src/runtime/stream_load/stream_load_context.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down

0 comments on commit 602275d

Please sign in to comment.