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 <[email protected]> Authored: Wed Aug 19 14:58:06 2015 +0300 Committer: Dmytro Sen <[email protected]> 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",
