Storm Caused by: org.apache.thrift7.transport.TTransportException

修改配置文件：

# Licensed 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

# to you under the Apache License, Version 2.0 (the

# "License"); you may not use this file except in compliance

# with the License. You may obtain a copy of the License at

#

# http://www.apache.org/licenses/LICENSE-2.0
#

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.

########### These MUST be filled in for a storm configuration

# storm.zookeeper.servers:

# - "server1"

# - "server2"

storm.zookeeper.servers:

- "192.168.3.161"

storm.zookeeper.port: 2181

#

# nimbus.host: "nimbus"

#

nimbus.host: "192.168.3.160"

nimbus.childopts: -Xmx1024m -Djava.net.preferIPv4Stack=true

ui.childopts: -Xmx768m -Djava.net.preferIPv4Stack=true

ui.host: 0.0.0.0

ui.port: 8080

supervisor.childopts: -Djava.net.preferIPv4Stack=true

worker.childopts: -Xmx768m -Dfile.encoding=utf-8 -Djava.net.preferIPv4Stack=true

supervisor.slots.ports:

- 6700

- 6701

- 6702

- 6703

storm.local.dir: /data/cluster/storm

storm.local.hostname: 192.168.3.160

storm.log.dir: /data/cluster/storm/logs

logviewer.port: 8000

#

# ##### These may optionally be filled in:

#

## List of custom serializations

# topology.kryo.register:

# - org.mycompany.MyType

# - org.mycompany.MyType2: org.mycompany.MyType2Serializer

#

## List of custom kryo decorators

# topology.kryo.decorators:

# - org.mycompany.MyDecorator

#

## Locations of the drpc servers

# drpc.servers:

# - "server1"

# - "server2"

drpc.servers:

- "192.168.3.160"

- "192.168.3.161"

- "192.168.3.162"

- "192.168.3.163"

## Metrics Consumers

# topology.metrics.consumer.register:

# - class: "backtype.storm.metric.LoggingMetricsConsumer"

# parallelism.hint: 1

# - class: "org.mycompany.MyMetricsConsumer"

# parallelism.hint: 1

# argument:

# - endpoint: "metrics-collector.mycompany.org"

storm.messaging.netty.max_retries: 3000

storm.messaging.netty.max_wait_ms: 10000

storm.messaging.netty.min_wait_ms: 1000