美文网首页工作生活
大数据------Strom集群安装配置(详细教程)

大数据------Strom集群安装配置(详细教程)

作者: ItStar | 来源:发表于2019-07-04 00:55 被阅读0次

https://www.acfun.cn/a/ac10294589(免费教程)

由于CDH5.12本身不集成Strom,所以需要单独使用Strom + Zookeeper 进行集群安装和搭建。

5个节点,1主4从,分别是node[5,7,8,10,11],zookeeper是node2,node8,node11。

可以从Storm 官网下载对应组件,也可以在本书提供的套件里面下载使用。

将Storm解压到/opt/目录下:

输入命令:tar apache-storm-1.1.1.tar.gz -C /opt/

每个节点修改Storm 配置文件:

输入命令:vi /opt/apache-storm-1.1.1/conf/storm.yaml

会显示如下结果:

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

      - "node2"

      - "node8"

      - "node11"

#

  nimbus.seeds: ["node8"]

#

#

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

      - "node8"

#     - "server2"

## Metrics Consumers

## max.retain.metric.tuples

## - task queue will be unbounded when max.retain.metric.tuples is equal or less than 0.

## whitelist / blacklist

## - when none of configuration for metric filter are specified, it'll be treated as 'pass all'.

## - you need to specify either whitelist or blacklist, or none of them. You can't specify both of them.

## - you can specify multiple whitelist / blacklist with regular expression

## expandMapType: expand metric with map type as value to multiple metrics

## - set to true when you would like to apply filter to expanded metrics

## - default value is false which is backward compatible value

## metricNameSeparator: separator between origin metric name and key of entry from map

## - only effective when expandMapType is set to true

# topology.metrics.consumer.register:

#   - class: "org.apache.storm.metric.LoggingMetricsConsumer"

#     max.retain.metric.tuples: 100

#     parallelism.hint: 1

#   - class: "org.mycompany.MyMetricsConsumer"

#     max.retain.metric.tuples: 100

#     whitelist:

#       - "execute.*"

#       - "^__complete-latency$"

#     parallelism.hint: 1

#     argument:

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

#     expandMapType: true

#     metricNameSeparator: "."

## Cluster Metrics Consumers

# storm.cluster.metrics.consumer.register:

#   - class: "org.apache.storm.metric.LoggingClusterMetricsConsumer"

#   - class: "org.mycompany.MyMetricsConsumer"

#     argument:

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

#

# storm.cluster.metrics.consumer.publish.interval.secs: 60

每个节点修改软连接:

输入命令:ln -s /opt/apache-storm-1.1.1/bin/storm /usr/bin/storm

node8:节点启动:

storm nimbus & ;

storm ui &;

storm supervisor &

其余节点启动:

storm supervisor &

会显示如下图示:

此时,storm环境搭建完毕。

相关文章

网友评论

    本文标题:大数据------Strom集群安装配置(详细教程)

    本文链接:https://www.haomeiwen.com/subject/lcaxhctx.html