|
@@ -1,8 +1,6 @@
|
|
|
<?xml version="1.0"?>
|
|
|
-<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>
|
|
|
<!--
|
|
|
-/**
|
|
|
- * Licensed to the Apache Software Foundation (ASF) under one
|
|
|
+ censed to the Apache Software Foundation (ASF) under one
|
|
|
* or more contributor license agreements. See the NOTICE file
|
|
|
* distributed with this work for additional information
|
|
|
* regarding copyright ownership. The ASF licenses this file
|
|
@@ -19,49 +17,42 @@
|
|
|
* limitations under the License.
|
|
|
*/
|
|
|
-->
|
|
|
-<configuration supports_final="true">
|
|
|
- <property>
|
|
|
- <name>storm.thrift.transport</name>
|
|
|
- <value>org.apache.storm.security.auth.SimpleTransportPlugin</value>
|
|
|
- <description>The transport plug-in for Thrift client/server communication.</description>
|
|
|
- </property>
|
|
|
- <property>
|
|
|
- <name>storm.messaging.transport</name>
|
|
|
- <value>org.apache.storm.messaging.netty.Context</value>
|
|
|
- <description>The transporter for communication among Storm tasks.</description>
|
|
|
- </property>
|
|
|
+
|
|
|
+<configuration supports_final="true" xmlns:xi="http://www.w3.org/2001/XInclude">
|
|
|
<property>
|
|
|
- <name>nimbus.topology.validator</name>
|
|
|
- <value>org.apache.storm.nimbus.DefaultTopologyValidator</value>
|
|
|
- <description>A custom class that implements ITopologyValidator that is run whenever a
|
|
|
- topology is submitted. Can be used to provide business-specific logic for
|
|
|
- whether topologies are allowed to run or not.</description>
|
|
|
+ <name>java.library.path</name>
|
|
|
+ <value>/usr/local/lib:/opt/local/lib:/usr/lib:/usr/hdp/current/storm-client/lib</value>
|
|
|
+ <description>This value is passed to spawned JVMs (e.g., Nimbus, Supervisor, and Workers)
|
|
|
+ for the java.library.path value. java.library.path tells the JVM where
|
|
|
+ to look for native libraries. It is necessary to set this config correctly since
|
|
|
+ Storm uses the ZeroMQ and JZMQ native libs. </description>
|
|
|
</property>
|
|
|
- <property>
|
|
|
- <name>topology.spout.wait.strategy</name>
|
|
|
- <value>org.apache.storm.spout.SleepSpoutWaitStrategy</value>
|
|
|
- <description>A class that implements a strategy for what to do when a spout needs to wait. Waiting is
|
|
|
- triggered in one of two conditions:
|
|
|
|
|
|
- 1. nextTuple emits no tuples
|
|
|
- 2. The spout has hit maxSpoutPending and can't emit any more tuples</description>
|
|
|
- </property>
|
|
|
<property>
|
|
|
- <name>topology.kryo.factory</name>
|
|
|
- <value>org.apache.storm.serialization.DefaultKryoFactory</value>
|
|
|
- <description>Class that specifies how to create a Kryo instance for serialization. Storm will then apply
|
|
|
- topology.kryo.register and topology.kryo.decorators on top of this. The default implementation
|
|
|
- implements topology.fall.back.on.java.serialization and turns references off.</description>
|
|
|
+ <name>nimbus.childopts</name>
|
|
|
+ <value>-Xmx1024m _JAAS_PLACEHOLDER -javaagent:/usr/hdp/current/storm-nimbus/contrib/storm-jmxetric/lib/jmxetric-1.0.4.jar=host=localhost,port=8649,wireformat31x=true,mode=multicast,config=/usr/hdp/current/storm-nimbus/contrib/storm-jmxetric/conf/jmxetric-conf.xml,process=Nimbus_JVM</value>
|
|
|
+ <description>This parameter is used by the storm-deploy project to configure the jvm options for the nimbus daemon.</description>
|
|
|
+ <value-attributes>
|
|
|
+ <overridable>false</overridable>
|
|
|
+ </value-attributes>
|
|
|
</property>
|
|
|
+
|
|
|
<property>
|
|
|
- <name>topology.tuple.serializer</name>
|
|
|
- <value>org.apache.storm.serialization.types.ListDelegateSerializer</value>
|
|
|
- <description>The serializer class for ListDelegate (tuple payload).
|
|
|
- The default serializer will be ListDelegateSerializer</description>
|
|
|
+ <name>worker.childopts</name>
|
|
|
+ <value>-Xmx768m _JAAS_PLACEHOLDER -javaagent:/usr/hdp/current/storm-client/contrib/storm-jmxetric/lib/jmxetric-1.0.4.jar=host=localhost,port=8650,wireformat31x=true,mode=multicast,config=/usr/hdp/current/storm-client/contrib/storm-jmxetric/conf/jmxetric-conf.xml,process=Worker_%ID%_JVM</value>
|
|
|
+ <description>The jvm opts provided to workers launched by this supervisor. All \"%ID%\" substrings are replaced with an identifier for this worker.</description>
|
|
|
+ <value-attributes>
|
|
|
+ <type>multiLine</type>
|
|
|
+ </value-attributes>
|
|
|
</property>
|
|
|
+
|
|
|
<property>
|
|
|
- <name>client.jartransformer.class</name>
|
|
|
- <description>Storm Topology backward comptability transformer</description>
|
|
|
- <value>org.apache.storm.hack.StormShadeTransformer</value>
|
|
|
+ <name>supervisor.childopts</name>
|
|
|
+ <value>-Xmx256m _JAAS_PLACEHOLDER -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.port={{jmxremote_port}} -javaagent:/usr/hdp/current/storm-supervisor/contrib/storm-jmxetric/lib/jmxetric-1.0.4.jar=host=localhost,port=8650,wireformat31x=true,mode=multicast,config=/usr/hdp/current/storm-supervisor/contrib/storm-jmxetric/conf/jmxetric-conf.xml,process=Supervisor_JVM</value>
|
|
|
+ <description>This parameter is used by the storm-deploy project to configure the jvm options for the supervisor daemon.</description>
|
|
|
+ <value-attributes>
|
|
|
+ <overridable>false</overridable>
|
|
|
+ </value-attributes>
|
|
|
</property>
|
|
|
+
|
|
|
</configuration>
|