From f4ebac0210607f1ae41d882e726af59b96e4482d Mon Sep 17 00:00:00 2001 From: stdpain <34912776+stdpain@users.noreply.github.com> Date: Thu, 27 May 2021 22:06:26 +0800 Subject: [PATCH] [BUG] BE core when FE get_stream_load_record (#5913) --- be/src/runtime/stream_load/stream_load_context.cpp | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/be/src/runtime/stream_load/stream_load_context.cpp b/be/src/runtime/stream_load/stream_load_context.cpp index 21cf315966..78bde90947 100644 --- a/be/src/runtime/stream_load/stream_load_context.cpp +++ b/be/src/runtime/stream_load/stream_load_context.cpp @@ -199,31 +199,31 @@ void StreamLoadContext::parse_stream_load_record(const std::string& stream_load_ if (document.HasMember("NumberTotalRows")) { const rapidjson::Value& total_rows = document["NumberTotalRows"]; - stream_load_item.__set_total_rows(total_rows.GetInt()); - ss << ", NumberTotalRows: " << total_rows.GetInt(); + stream_load_item.__set_total_rows(total_rows.GetInt64()); + ss << ", NumberTotalRows: " << total_rows.GetInt64(); } if (document.HasMember("NumberLoadedRows")) { const rapidjson::Value& loaded_rows = document["NumberLoadedRows"]; - stream_load_item.__set_loaded_rows(loaded_rows.GetInt()); - ss << ", NumberLoadedRows: " << loaded_rows.GetInt(); + stream_load_item.__set_loaded_rows(loaded_rows.GetInt64()); + ss << ", NumberLoadedRows: " << loaded_rows.GetInt64(); } if (document.HasMember("NumberFilteredRows")) { const rapidjson::Value& filtered_rows = document["NumberFilteredRows"]; - stream_load_item.__set_filtered_rows(filtered_rows.GetInt()); + stream_load_item.__set_filtered_rows(filtered_rows.GetInt64()); ss << ", NumberFilteredRows: " << filtered_rows.GetInt64(); } if (document.HasMember("NumberUnselectedRows")) { const rapidjson::Value& unselected_rows = document["NumberUnselectedRows"]; - stream_load_item.__set_unselected_rows(unselected_rows.GetInt()); + stream_load_item.__set_unselected_rows(unselected_rows.GetInt64()); ss << ", NumberUnselectedRows: " << unselected_rows.GetInt64(); } if (document.HasMember("LoadBytes")) { const rapidjson::Value& load_bytes = document["LoadBytes"]; - stream_load_item.__set_load_bytes(load_bytes.GetInt()); + stream_load_item.__set_load_bytes(load_bytes.GetInt64()); ss << ", LoadBytes: " << load_bytes.GetInt64(); }