提交 fb6ffd83 编写于 作者: Q QinZuoyan 提交者: qinzuoyan

shell: fix copy_data bug (#291)

上级 663e7976
......@@ -362,6 +362,8 @@ inline void scan_data_next(scan_data_context *context)
dassert(false, "op = %d", context->op);
break;
}
} else {
scan_data_next(context);
}
} else if (ret == pegasus::PERR_SCAN_COMPLETE) {
context->split_completed.store(true);
......
......@@ -2323,7 +2323,7 @@ static void print_current_scan_state(const std::vector<scan_data_context *> &con
fprintf(stderr, "\n");
}
}
fprintf(stderr, "Count %s, total %ld rows", stop_desc.c_str(), total_rows);
fprintf(stderr, "Count %s, total %ld rows.", stop_desc.c_str(), total_rows);
if (count_hash_key) {
fprintf(stderr, " (%ld hash keys)\n", total_hash_key_count);
} else {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册