in loader/stream_loader.go [441:459]
func (s *StreamLoad) showLoadResult(isSuccessful bool, startTime time.Time) {
endTime := time.Now()
elapsed := endTime.Sub(startTime)
s.loadResp.LoadTimeMs = int64(elapsed.Milliseconds())
s.loadResp.FailLoadRows = s.loadResp.TotalRows - s.loadResp.LoadedRows - s.loadResp.FilteredRows - s.loadResp.UnselectedRows
result := "success"
if !isSuccessful {
s.loadResp.Status = "Failed"
result = "fail"
}
jsonData, err := json.MarshalIndent(s.loadResp, "", "\t")
if err != nil {
log.Errorf("Load %s, but parse load result to json error: %v, can not show load result", result, err)
return
}
fmt.Printf("Load Result: %s\n", jsonData)
}