[kudu] branch master updated: [tool] allow customizing parallelism for local_replica copy_from_remote

[al...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

alexey pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kudu.git


The following commit(s) were added to refs/heads/master by this push:
     new 0df4eaa  [tool] allow customizing parallelism for local_replica copy_from_remote
0df4eaa is described below

commit 0df4eaaa6590aabfc212c2faa5c73db00c9452fb
Author: ningw <19...@gmail.com>
AuthorDate: Tue Nov 17 11:53:39 2020 +0800

    [tool] allow customizing parallelism for local_replica copy_from_remote
    
    Allow passiing --tablet_copy_download_threads_nums_per_session to
    specify the parallelism of local_replica copy_from_remote tool.
    
    Change-Id: I17a5937b259ed22c987f6560ca5008afcb161f20
    Reviewed-on: http://gerrit.cloudera.org:8080/16738
    Tested-by: Kudu Jenkins
    Reviewed-by: Alexey Serbin <as...@cloudera.com>
---
 src/kudu/tools/tool_action_local_replica.cc | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/kudu/tools/tool_action_local_replica.cc b/src/kudu/tools/tool_action_local_replica.cc
index ae7f2de..e3691fa 100644
--- a/src/kudu/tools/tool_action_local_replica.cc
+++ b/src/kudu/tools/tool_action_local_replica.cc
@@ -109,6 +109,8 @@ DEFINE_bool(ignore_nonexistent, false,
             "set to 'true', the tool does not report an error if the requested "
             "tablet replica to remove is not found");
 
+DECLARE_int32(tablet_copy_download_threads_nums_per_session);
+
 namespace kudu {
 namespace tools {
 
@@ -121,7 +123,6 @@ using fs::IOContext;
 using fs::ReadableBlock;
 using log::LogEntryPB;
 using log::LogEntryReader;
-using log::LogIndex;
 using log::LogReader;
 using log::ReadableLogSegment;
 using log::SegmentSequence;
@@ -925,6 +926,7 @@ unique_ptr<Mode> BuildLocalReplicaMode() {
       .AddOptionalParameter("fs_data_dirs")
       .AddOptionalParameter("fs_metadata_dir")
       .AddOptionalParameter("fs_wal_dir")
+      .AddOptionalParameter("tablet_copy_download_threads_nums_per_session")
       .Build();
 
   unique_ptr<Action> list =