Repository: ambari Updated Branches: refs/heads/trunk 3043933b0 -> 9a8d5d992
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/9a8d5d99 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/9a8d5d99 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/9a8d5d99 Branch: refs/heads/trunk Commit: 9a8d5d9928b1b4ebfa7a57753f735282cafe9e03 Parents: 3043933 Author: Dmytro Sen <[email protected]> Authored: Wed Aug 19 14:58:06 2015 +0300 Committer: Dmytro Sen <[email protected]> Committed: Wed Aug 19 14:58:06 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/9a8d5d99/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/9a8d5d99/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/9a8d5d99/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",
