This is an automated email from the ASF dual-hosted git repository.
yuchenhe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
The following commit(s) were added to refs/heads/master by this push:
new 5aedbbc feat(bulk_load): adapt to modification in meta server (#858)
5aedbbc is described below
commit 5aedbbc2315c1e2301119da529ea831bc260ef44
Author: GiantKing <[email protected]>
AuthorDate: Wed Dec 29 10:46:01 2021 +0800
feat(bulk_load): adapt to modification in meta server (#858)
---
rdsn | 2 +-
src/shell/commands/bulk_load.cpp | 8 ++++++++
2 files changed, 9 insertions(+), 1 deletion(-)
diff --git a/rdsn b/rdsn
index 24bf381..982c2bd 160000
--- a/rdsn
+++ b/rdsn
@@ -1 +1 @@
-Subproject commit 24bf38117d6e3076ee5910a8a0b1d3f368592516
+Subproject commit 982c2bd180a081fe2c772191cad0ea279e0e2685
diff --git a/src/shell/commands/bulk_load.cpp b/src/shell/commands/bulk_load.cpp
index dd8fc93..c55a150 100644
--- a/src/shell/commands/bulk_load.cpp
+++ b/src/shell/commands/bulk_load.cpp
@@ -264,6 +264,10 @@ bool query_bulk_load_status(command_executor *e,
shell_context *sc, arguments ar
auto err_resp = sc->ddl_client->query_bulk_load(app_name);
dsn::error_s err = err_resp.get_error();
+ if (!err.is_ok()) {
+ fmt::print(stderr, "query bulk load failed, error={}\n", err);
+ return true;
+ }
auto resp = err_resp.get_value();
std::string hint_msg;
@@ -394,7 +398,11 @@ bool query_bulk_load_status(command_executor *e,
shell_context *sc, arguments ar
tp_summary.add_row_name_and_data("partition_bulk_load_status",
get_short_status(resp.partitions_status[pidx]));
}
+ tp_summary.add_row_name_and_data("is_bulk_loading", resp.is_bulk_loading ?
"YES" : "NO");
tp_summary.add_row_name_and_data("app_bulk_load_status",
get_short_status(resp.app_status));
+ if (bulk_load_status::BLS_FAILED == resp.app_status) {
+ tp_summary.add_row_name_and_data("bulk_load_err",
resp.err.to_string());
+ }
if (print_progress) {
tp_summary.add_row_name_and_data("app_total_download_progress",
total_progress);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
