Repository: hive Updated Branches: refs/heads/master b8aad3602 -> 11beadff3
HIVE-17625: Replication: update hive.repl.partitions.dump.parallelism to 100 (Vaibhav Gumashta reviewed by Thejas Nair) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/11beadff Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/11beadff Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/11beadff Branch: refs/heads/master Commit: 11beadff376dbb30058dba1672909ddb14b47df1 Parents: b8aad36 Author: Vaibhav Gumashta <vgumas...@hortonworks.com> Authored: Fri Sep 29 01:40:08 2017 -0700 Committer: Vaibhav Gumashta <vgumas...@hortonworks.com> Committed: Fri Sep 29 01:40:08 2017 -0700 ---------------------------------------------------------------------- common/src/java/org/apache/hadoop/hive/conf/HiveConf.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/11beadff/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java ---------------------------------------------------------------------- diff --git a/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java b/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java index 5bec15e..cd6998e 100644 --- a/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java +++ b/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java @@ -447,7 +447,7 @@ public class HiveConf extends Configuration { + "dynamically generating the next set of tasks. The number is approximate as Hive \n" + "will stop at a slightly higher number, the reason being some events might lead to a \n" + "task increment that would cross the specified limit."), - REPL_PARTITIONS_DUMP_PARALLELISM("hive.repl.partitions.dump.parallelism",5, + REPL_PARTITIONS_DUMP_PARALLELISM("hive.repl.partitions.dump.parallelism",100, "Number of threads that will be used to dump partition data information during repl dump."), REPL_DUMPDIR_CLEAN_FREQ("hive.repl.dumpdir.clean.freq", "0s", new TimeValidator(TimeUnit.SECONDS),