Configuração de Ambiente de Cluster Storm

Pré-requisitos

Antes de começar a instalação do Apache Storm, é necessário ter o Java e o ZooKeeper previamente instalados. Este guia não aborda detalhes sobre a instalação desses componentes.

Passo 1: Baixar o Storm

Acesse o site oficial do Apache Storm (http://storm.apache.org/downloads.html) e baixe a versão desejada. Neste exemplo, utilizamos a versão 1.1.0.

Passo 2: Extrair o Arquivo

Transfira o arquivo apache-storm-1.1.0.tar.gz para o diretório /opt/softwares no nó centos01 e extraia-o no diretório /opt/modules com o seguinte comando:

[hadoop@centos01 softwares]$ tar -zxvf apache-storm-1.1.0.tar.gz -C /opt/modules/

Renomeie a pasta extraída:

[hadoop@centos01 modules]$ mv apache-storm-1.1.0/ storm-1.1.0

Passo 3: Configurações do Storm

  1. Atualize as variáveis de ambiente editando o arquivo /etc/profile e adicionendo as seguintes linhas:

    export STORM_HOME=/opt/modules/storm-1.1.0
    export PATH=$PATH:$STORM_HOME/bin
    
    

    Recarregue as variáveis:

    [hadoop@centos01 ~]$ source /etc/profile
    
    
  2. No arquivo storm-env.sh dentro do diretório $STORM_HOME/conf, configure o caminho do JDK:

    export JAVA_HOME=/opt/modules/jdk1.8.0_101
    export STORM_CONF_DIR="/opt/modules/storm-1.1.0/conf"
    
    
  3. Edite o arquivo storm.yaml e adicione as seguintes propriedades:

    storm.zookeeper.servers:
        - "centos01"
        - "centos02"
        - "centos03"
    supervisor.slots.ports:
        - 6700
        - 6701
        - 6702
        - 6703
    storm.zookeeper.port: 2181
    storm.local.dir: "/opt/modules/storm-1.1.0/data"
    nimbus.seeds: ["centos01"]
    
    
    • storm.zookeeper.servers: lista de servidores ZooKeeper.
    • supervisor.slots.ports: portas disponíveis para execução dos workers no Supervisor.
    • storm.zookeeper.port: porta padrão do ZooKeeper (2181).
    • storm.local.dir: diretório local para armazenar arquivos temporários.
    • nimbus.seeds: lista de candidatos Nimbus.

Passo 4: Distribuir o Storm para os Outros Nós

Copie a pasta do Storm para os demais servidores do cluster:

[hadoop@centos01 modules]$ scp -r storm-1.1.0/ centos02:/opt/modules/
[hadoop@centos01 modules]$ scp -r storm-1.1.0/ centos03:/opt/modules/

Passo 5: Iniciar os Serviços

  1. No nó centos01, inicie os serviços Nimbus e UI:

    storm nimbus >/dev/null 2>&1 &
    storm ui >/dev/null 2>&1 &
    
    

    Verifique os processos Java com o comendo jps. O processo core indica que a interface web está ativa. Acesse http://centos01:8080 para visualizar o status do cluster.

  2. No nó centos02, execute:

    [hadoop@centos02 bin]$ ./storm supervisor >/dev/null 2>&1 &
    
    

    Use jps até que o processo Supervisor apareça, indicando que o serviço foi iniciado corretamente.

  3. No nó centos03, execute o mesmo comando:

    [hadoop@centos03 bin]$ ./storm supervisor >/dev/null 2>&1 &
    
    

Tags: storm apache-storm cluster zookeeper java

Publicado em 8-8 00:20