ambari-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject ambari git commit: AMBARI-12815 Change the default of topology.max.spout.pending from null to 1000 for Storm to prevent failures for Spout (dsen)
Date Wed, 19 Aug 2015 12:01:09 GMT
Repository: ambari
Updated Branches:
  refs/heads/branch-2.1 6e3e328e2 -> 8aa706c8b


AMBARI-12815 Change the default of topology.max.spout.pending from null to 1000 for Storm
to prevent failures for Spout (dsen)


Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/8aa706c8
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/8aa706c8
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/8aa706c8

Branch: refs/heads/branch-2.1
Commit: 8aa706c8bdf777c03e646a3c3950e62b064ea08e
Parents: 6e3e328
Author: Dmytro Sen <dsen@apache.org>
Authored: Wed Aug 19 14:58:06 2015 +0300
Committer: Dmytro Sen <dsen@apache.org>
Committed: Wed Aug 19 15:00:59 2015 +0300

----------------------------------------------------------------------
 .../common-services/STORM/0.9.1.2.1/configuration/storm-site.xml   | 2 +-
 .../HDP/2.1.GlusterFS/services/STORM/configuration/storm-site.xml  | 2 +-
 .../test/python/stacks/2.1/configs/secured-storm-start.json.orig   | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/8aa706c8/ambari-server/src/main/resources/common-services/STORM/0.9.1.2.1/configuration/storm-site.xml
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/STORM/0.9.1.2.1/configuration/storm-site.xml
b/ambari-server/src/main/resources/common-services/STORM/0.9.1.2.1/configuration/storm-site.xml
index b1cf129..49d3f04 100644
--- a/ambari-server/src/main/resources/common-services/STORM/0.9.1.2.1/configuration/storm-site.xml
+++ b/ambari-server/src/main/resources/common-services/STORM/0.9.1.2.1/configuration/storm-site.xml
@@ -423,7 +423,7 @@
   </property>
   <property>
     <name>topology.max.spout.pending</name>
-    <value>null</value>
+    <value>1000</value>
     <description>The maximum number of tuples that can be pending on a spout task at
any given time.
        This config applies to individual tasks, not to spouts or topologies as a whole.
 

http://git-wip-us.apache.org/repos/asf/ambari/blob/8aa706c8/ambari-server/src/main/resources/stacks/HDP/2.1.GlusterFS/services/STORM/configuration/storm-site.xml
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/stacks/HDP/2.1.GlusterFS/services/STORM/configuration/storm-site.xml
b/ambari-server/src/main/resources/stacks/HDP/2.1.GlusterFS/services/STORM/configuration/storm-site.xml
index b02d23a..73ea7ca 100644
--- a/ambari-server/src/main/resources/stacks/HDP/2.1.GlusterFS/services/STORM/configuration/storm-site.xml
+++ b/ambari-server/src/main/resources/stacks/HDP/2.1.GlusterFS/services/STORM/configuration/storm-site.xml
@@ -423,7 +423,7 @@
   </property>
   <property>
     <name>topology.max.spout.pending</name>
-    <value>null</value>
+    <value>1000</value>
     <description>The maximum number of tuples that can be pending on a spout task at
any given time.
        This config applies to individual tasks, not to spouts or topologies as a whole.
 

http://git-wip-us.apache.org/repos/asf/ambari/blob/8aa706c8/ambari-server/src/test/python/stacks/2.1/configs/secured-storm-start.json.orig
----------------------------------------------------------------------
diff --git a/ambari-server/src/test/python/stacks/2.1/configs/secured-storm-start.json.orig
b/ambari-server/src/test/python/stacks/2.1/configs/secured-storm-start.json.orig
index 118520d..9dad8e1 100644
--- a/ambari-server/src/test/python/stacks/2.1/configs/secured-storm-start.json.orig
+++ b/ambari-server/src/test/python/stacks/2.1/configs/secured-storm-start.json.orig
@@ -98,7 +98,7 @@
             "logviewer.childopts": "-Xmx128m", 
             "transactional.zookeeper.port": "null", 
             "topology.worker.childopts": "null", 
-            "topology.max.spout.pending": "null", 
+            "topology.max.spout.pending": "1000",
             "nimbus.cleanup.inbox.freq.secs": "600", 
             "storm.messaging.netty.min_wait_ms": "100", 
             "nimbus.task.timeout.secs": "30", 


Mime
View raw message