Merge lp:~asanjar/charms/trusty/hadoop/hadoop-elk into lp:charms/hadoop

[amir sanjar]

adding elasticsearch support to hadoop

[Charles Butler (lazypower)]

Amir,

I haven't run a deploy test yet. I've noted the one thing that stood out to me. A possible note here about interface names - since this just relates to elasticsearch and is not hyper specific to the E.lasticsearch L.ogstash K.ibana stack; it may make more sense to name the relationship appropriately, as this relationship would work with any data river associated with Elastic Search.

Otherwise, looks good so far. I'll run a deployment test once you've pushed the modifications.

review: Needs Fixing

[lp:~asanjar/charms/trusty/hadoop/hadoop-elk]

6. By amir sanjar on 2014-07-07

shutdown & elasticsearch changes

[Charles Butler (lazypower)]

+1 LGTM

review: Approve

=== modified file 'README.md'
--- README.md	2014-06-16 17:12:24 +0000
+++ README.md	2014-07-07 14:22:54 +0000
@@ -63,6 +63,7 @@
     juju add-relation hadoop-master:namenode hadoop-slavecluster:datanode
     juju add-relation hadoop-master:resourcemanager hadoop-slavecluster:nodemanager
 
+
 ### Scale Out Usage: Separate HDFS and MapReduce
 
 In this configuration the HDFS and YARN deployments operate on
@@ -85,6 +86,15 @@
 to be deployed onto machines with more processing power and hdfs services
 to be deployed onto machines with larger storage.
 
+### TO deploy a Hadoop service with elasticsearch service::
+    # deploy ElasticSearch locally:
+    juju deploy elasticsearch elasticsearch
+    # elasticsearch-hadoop.jar file will be added to LIBJARS path 
+    # Recommanded to use hadoop -libjars option to included elk jar file
+    juju add-unit -n elasticsearch
+    # deploy hive service by any senarios mentioned above
+    # associate Hive with elasticsearch
+    juju add-relation hadoop-master:elasticsearch elasticsearch:client
 ## Known Limitations and Issues
 
 Note that removing the relation between namenode and datanode is destructive!

=== modified file 'config.yaml'
--- config.yaml	2014-05-13 19:22:12 +0000
+++ config.yaml	2014-07-07 14:22:54 +0000
@@ -152,7 +152,7 @@
       map output fetching.
   hadoop_dir_base:
     type: string
-    default: /home/ubuntu/hadoop/data
+    default: /usr/local/hadoop/data
     description: |
       The directory under which all other hadoop data is stored.  Use this
       to take advantage of extra storage that might be avaliable.
@@ -170,3 +170,16 @@
     default: org.apache.hadoop.mapred.ShuffleHandler
     description: |
       Shuffle service that needs to be set for Map Reduce applications.
+  dfs_heartbeat_interval:
+    type: int
+    default: 3
+    description: |
+       Determines datanode heartbeat interval in seconds.
+  dfs_namenode_heartbeat_recheck_interval:
+    type: int
+    default: 300000
+    description: |
+       Determines datanode recheck heartbeat interval in milliseconds
+       It is used to calculate the final tineout value for namenode. Calcultion process is    
+       as follow: 10.30 minutes = 2 x (dfs.namenode.heartbeat.recheck-interval=5*60*1000)
+                                  + 10 * 1000 * (dfs.heartbeat.interval=3)

=== modified file 'files/upstart/defaults'
--- files/upstart/defaults	2014-05-13 19:22:12 +0000
+++ files/upstart/defaults	2014-07-07 14:22:54 +0000
@@ -1,17 +1,17 @@
 #!/bin/bash
 
 
-echo "export JAVA_HOME=$1" > /etc/profile.d/hadoopenv.sh
-echo "export HADOOP_INSTALL=$2" >> /etc/profile.d/hadoopenv.sh
-echo "export HADOOP_HOME=$2" >> /etc/profile.d/hadoopenv.sh
-echo "export HADOOP_COMMON_HOME=$2" >> /etc/profile.d/hadoopenv.sh
-echo "export HADOOP_HDFS_HOME=$2" >> /etc/profile.d/hadoopenv.sh
-echo "export HADOOP_MAPRED_HOME=$2" >> /etc/profile.d/hadoopenv.sh
-echo "export HADOOP_YARN_HOME=$2" >> /etc/profile.d/hadoopenv.sh
-echo "export PATH=$1/bin:$PATH:$2/bin:$2/sbin" >> /etc/profile.d/hadoopenv.sh
-echo "export YARN_HOME=$2" >> /etc/profile.d/hadoopenv.sh
-echo "export HADOOP_CONF_DIR=$4" >> /etc/profile.d/hadoopenv.sh
-echo "export YARN_CONF_DIR=$4" >> /etc/profile.d/hadoopenv.sh
+#echo "export JAVA_HOME=$1" > /etc/profile.d/hadoopenv.sh
+echo "export HADOOP_INSTALL=$1" >> /etc/profile.d/hadoopenv.sh
+echo "export HADOOP_HOME=$1" >> /etc/profile.d/hadoopenv.sh
+echo "export HADOOP_COMMON_HOME=$1" >> /etc/profile.d/hadoopenv.sh
+echo "export HADOOP_HDFS_HOME=$1" >> /etc/profile.d/hadoopenv.sh
+echo "export HADOOP_MAPRED_HOME=$1" >> /etc/profile.d/hadoopenv.sh
+echo "export HADOOP_YARN_HOME=$1" >> /etc/profile.d/hadoopenv.sh
+echo "export PATH=$PATH:$1/bin:$1/sbin" >> /etc/profile.d/hadoopenv.sh
+echo "export YARN_HOME=$1" >> /etc/profile.d/hadoopenv.sh
+echo "export HADOOP_CONF_DIR=$2" >> /etc/profile.d/hadoopenv.sh
+echo "export YARN_CONF_DIR=$2" >> /etc/profile.d/hadoopenv.sh
 chmod +x /etc/profile.d/hadoopenv.sh
 
 

=== modified file 'hooks/hadoop-common'
--- hooks/hadoop-common	2014-05-13 19:22:12 +0000
+++ hooks/hadoop-common	2014-07-07 14:22:54 +0000
@@ -19,31 +19,32 @@
     sed -i -e "s/^127.0.1.1\(.*$hostname.*\)/$private_address\1/" /etc/hosts
 
 }
+JAVA_VENDOR="openjdk"
+JAVA_VERSION="7"
+HADOOP_VERSION="hadoop-2.2.0"
+PLATFORM_ARCH="amd64"
+HADOOP_DIR="/usr/local/hadoop"
+HADOOP_CONF_DIR="/etc/hadoop/conf.juju"
+HADOOP_INSTALLED=$HADOOP_DIR/$HADOOP_VERSION
+HADOOP_TMP_DIR=$HADOOP_DIR/tmp
 
-set_hadoopenv () {
-	JAVA_VENDOR="openjdk"
-	JAVA_VERSION="7"
-	HADOOP_VERSION="hadoop-2.2.0"
-	PLATFORM_ARCH="amd64"
-	HOME_DIR="/home/ubuntu"
-	HADOOP_DIR="/home/ubuntu/hadoop"
-        HADOOP_CONF_DIR="/etc/hadoop/conf.juju"
-	HADOOP_INSTALLED=$HADOOP_DIR/$HADOOP_VERSION
-	HADOOP_TMP_DIR=$HADOOP_DIR/tmp
-}
 
 configure_systemenv(){
 juju-log "Configuring hadoop system environment"
- JAVA_HOME_PATH=$(sudo find /usr/ -name java-7-openjdk-*)
+ #JAVA_HOME_PATH=$(sudo find /usr/ -name java-7-openjdk-*)
  if [ ! -f /etc/default/hadoop ]
  then
     juju-log "Configuring hadoop system environment - setting up hadoopenv.sh "
     install -o root -g root -m 0644 files/upstart/defaults /etc/default/hadoop
-    . /etc/default/hadoop $JAVA_HOME_PATH $HADOOP_INSTALLED $HOME_DIR $HADOOP_CONF_DIR
+    . /etc/default/hadoop $HADOOP_INSTALLED $HADOOP_CONF_DIR
  fi
  juju-log "Configuring hadoop system environment - execute hadoopenv.sh "
  . /etc/profile.d/hadoopenv.sh
 }
+
+configure_systemenv
+
+
 # Helpers to support conditional restarts based
 # on specific files changing
 
@@ -68,7 +69,7 @@
 configure_sources () {
     source=`config-get source`
     juju-log "Configuring hadoop using the Hadoop Ubuntu Team PPA..."
-  #  add-apt-repository ppa:hadoop-ubuntu/$source
+   #  add-apt-repository ppa:hadoop-ubuntu/$source
    # apt-get update -qqy
 }
 
@@ -94,7 +95,9 @@
      mkdir -p $HADOOP_DIR
      mkdir -p $HADOOP_TMP_DIR
      apt-get install -qqy openjdk-7-jdk
+     
      tar -xzf files/archives/$HADOOP_VERSION.tar.gz -C $HADOOP_DIR
+     chown -R ubuntu:hadoop $HADOOP_DIR
      
 
 }
@@ -194,8 +197,10 @@
     if [ ! -d /etc/hadoop/conf.juju ]
     then
 	mkdir -p /etc/hadoop/conf.juju
+	
         cp $HADOOP_INSTALLED/etc/hadoop/* /etc/hadoop/conf.juju
         #cp -r $HADOOP_INSTALLED/etc/hadoop /etc/hadoop/conf.juju
+        rm /etc/hadoop/conf.juju/slaves
         update-alternatives --install /etc/hadoop/conf hadoop-conf \
             /etc/hadoop/conf.juju 50
 	cp /etc/hadoop/conf.juju/mapred-site.xml.template \
@@ -209,9 +214,10 @@
         dotdee --setup /etc/hadoop/conf.juju/mapred-site.xml
         dotdee --setup /etc/hadoop/conf.juju/hadoop-env.sh
         dotdee --setup /etc/hadoop/conf.juju/yarn-site.xml
-        
+        chown -R ubuntu:hadoop /etc/hadoop/conf.juju
     fi
     # add JAVA_HOME to hadoop-env.sh
+    JAVA_HOME_PATH=$(sudo find /usr/ -name java-7-openjdk-*)
     sed -ir 's|export JAVA_HOME=.*|export JAVA_HOME='$JAVA_HOME_PATH'|' $HADOOP_CONF_DIR/hadoop-env.sh
 # Configure Heap Size
     heap=`config-get heap`
@@ -228,9 +234,6 @@
     config_element "dfs.namenode.handler.count" \
         "`config-get dfs_namenode_handler_count`" > \
         $dir/11-dfs.namenode.handler.count
- #   config_element "dfs.blocksize" \
- #       "`config-get dfs_block_size`" > \
- #       $dir/12-dfs.blocksize
     config_element "dfs.datanode.max.transfer.threads" \
         "`config-get dfs_datanode_max_xcievers`" > \
         $dir/13-dfs.datanode.max.transfer.threads  
@@ -246,6 +249,15 @@
     config_element "dfs.replication" \
         "`config-get dfs_replication`" > \
         $dir/17-dfs.replication
+    config_element "dfs.heartbeat.interval"\
+        "`config-get dfs_heartbeat_interval`" > \
+        $dir/18-dfs.heartbeat.interval
+    config_element "dfs.datanode.data.dir" \
+        "`config-get hadoop_dir_base`/cache/hadoop/dfs/name" > \
+        $dir/19-dfs.datanode.data.dir
+    config_element "dfs.namenode.heartbeat.recheck-interval"\
+       "`config-get dfs_namenode_heartbeat_recheck_interval`" > \
+        $dir/20-dfs.namenode.heartbeat.recheck-interval
     dotdee --update /etc/hadoop/conf.juju/hdfs-site.xml || true
 
     # Configure Hadoop YARN
@@ -290,7 +302,7 @@
     mkdir -p $dir/cache/hadoop
     # We don't want to do this recursively since we may be reinstalling, in which case
     # users have their own cache/<username> directories which shouldn't be stolen
-    groupadd -f hadoop
+    #groupadd -f hadoop
     chown ubuntu:hadoop $dir $dir/cache $dir/cache/hadoop
     # Ensure group write on this directory or we can start namenode/datanode
     chmod 775 $dir/cache/hadoop
@@ -302,6 +314,7 @@
         datanode|secondarynamenode)
             sshkey=`relation-get namenode_sshkey`
             echo $sshkey >> /home/ubuntu/.ssh/authorized_keys
+            chown -R ubuntu:hadoop /home/ubuntu/.ssh
             ;;
         namenode)
             relation-set namenode_sshkey="$(cat /home/ubuntu/.ssh/id_rsa.pub)"
@@ -311,15 +324,13 @@
     juju-log "Configuring service unit relation $1..."
     case $1 in
         datanode|secondarynamenode|mapred-namenode)
-  #          sshkey=`relation-get namenode_sshkey`
-  #          echo $sshkey >> /home/ubuntu/.ssh/authorized_keys
+  
             namenode_address=`relation-get private-address`
             config_element "fs.default.name" "hdfs://$namenode_address:9000" > \
                 $dir/50-fs.default.name
             ;;
         namenode)
             private_address=`unit-get private-address`
-  #          relation-set namenode_sshkey="$(cat /home/ubuntu/.ssh/id_rsa.pub)"
             config_element "fs.default.name" "hdfs://$private_address:9000" > \
                 $dir/50-fs.default.name
             ;;
@@ -384,7 +395,7 @@
 
 format_namenode () {
     juju-log "Formatting namenode filesystem"
-    hdfs namenode -format
+    su ubuntu -c "$HADOOP_INSTALLED/bin/hdfs namenode -format"
     chown -R ubuntu:hadoop $HADOOP_DIR
 }
 
@@ -397,16 +408,18 @@
     juju-log "Restarting hdfs: $hdfs_role"
     case $hdfs_role in
         namenode)
-        hadoop-daemon.sh stop namenode
-        hadoop-daemon.sh start namenode  
+        #hadoop-daemon.sh stop namenode
+        #hadoop-daemon.sh start namenode  
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/hadoop-daemon.sh --config $HADOOP_CONF_DIR --script hdfs stop namenode"
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/hadoop-daemon.sh --config $HADOOP_CONF_DIR --script hdfs start namenode"
             ;;
         datanode)
-        su ubuntu -c "$HADOOP_INSTALLED/sbin/hadoop-daemons.sh stop datanode"
-        su ubuntu -c "$HADOOP_INSTALLED/sbin/hadoop-daemons.sh start datanode"
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/hadoop-daemon.sh --config $HADOOP_CONF_DIR --script hdfs stop datanode"
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/hadoop-daemon.sh --config $HADOOP_CONF_DIR --script hdfs start datanode"
             ;;
         secondarynamenode)
-        hadoop-daemons.sh stop secondarynamenode
-        hadoop-daemons.sh start secondarynamenode   
+    #  will be replace with HA  hadoop-daemons.sh stop secondarynamenode 
+     #   hadoop-daemons.sh start secondarynamenode   
             ;;
     esac
 }
@@ -414,12 +427,14 @@
     juju-log "Restarting yarn: $mapred_role"
     case $mapred_role in
         resourcemanager)
-        yarn-daemon.sh stop resourcemanager
-        yarn-daemon.sh start resourcemanager    
+        #yarn-daemon.sh stop resourcemanager
+        #yarn-daemon.sh start resourcemanager    
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/yarn-daemon.sh --config $HADOOP_CONF_DIR stop resourcemanager"
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/yarn-daemon.sh --config $HADOOP_CONF_DIR start resourcemanager"
             ;;
         nodemanager)
-        su ubuntu -c "$HADOOP_INSTALLED/sbin/yarn-daemons.sh stop nodemanager"
-        su ubuntu -c "$HADOOP_INSTALLED/sbin/yarn-daemons.sh start nodemanager"
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/yarn-daemon.sh --config $HADOOP_CONF_DIR stop nodemanager"
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/yarn-daemon.sh --config $HADOOP_CONF_DIR start nodemanager"
             ;;
     esac
 }
@@ -427,10 +442,7 @@
 
 # Hadoop Service Control Commands
 restart_hadoop () {
- #   [ "$hdfs_role" != "unconfigured" ] && \
- #       _restart_ hadoop-$hdfs_role || :
- #   [ "$mapred_role" != "unconfigured" ] && \
- #       _restart_ hadoop-$mapred_role || :
+ 
    juju-log "restart_hadoop hdfs_role=$hdfs_role and yarn_role=$mapred_role"
    [ "$hdfs_role" != "unconfigured" ] && \
     _restart_hdfs || :
@@ -438,35 +450,32 @@
    [ "$mapred_role" != "unconfigured" ] && \
     _restart_yarn || :
 }
+
 stop_hadoop () {
-  #  [ "$hdfs_role" != "unconfigured" ] && \
-  #      _stop_ hadoop-$hdfs_role || :
-  #  [ "$mapred_role" != "unconfigured" ] && \
-  #      _stop_ hadoop-$mapred_role || :
+ 
    juju-log "Stop_hadoop hdfs_role=$hdfs_role and yarn_role=$mapred_role"
    case $hdfs_role in
         namenode)
-        hadoop-daemon.sh stop namenode    
+         su ubuntu -c "$HADOOP_INSTALLED/sbin/hadoop-daemon.sh --config $HADOOP_CONF_DIR stop namenode"  
             ;;
         datanode)
-        hadoop-daemons.sh stop datanode
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/hadoop-daemon.sh --config $HADOOP_CONF_DIR stop datanode"
             ;;
     esac
+
     case $mapred_role in
         resourcemanager)
-        yarn-daemon.sh stop resourcemanager
+        #yarn-daemon.sh stop resourcemanager
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/yarn-daemon.sh --config $HADOOP_CONF_DIR stop resourcemanager"
             ;;
         nodemanager)
-        yarn-daemons.sh stop nodemanager
+        su ubuntu -c "$HADOOP_INSTALLED/sbin/yarn-daemon.sh --config $HADOOP_CONF_DIR stop nodemanager"
             ;;
     esac
+
+
 }
-#start_hadoop () {
-#    [ "$hdfs_role" != "unconfigured" ] && \
-#        _start_ hadoop-$hdfs_role || :
-#    [ "$mapred_role" != "unconfigured" ] && \
-#        _start_ hadoop-$mapred_role || :
-#}
+
 
 # Restart services only if configuration files
 # have actually changed
@@ -484,22 +493,39 @@
     then
         # Just restart HDFS role
         [ "$hdfs_role" != "unconfigured" ] && \
-#            _restart_ hadoop-$hdfs_role || :
              _restart_hdfs || :
     fi
     if file_changed /etc/hadoop/conf.juju/yarn-site.xml
     then
         # Just restart mapreduce role
         [ "$mapred_role" != "unconfigured" ] && \
-#            _restart_ hadoop-$mapred_role || :
              _restart_yarn || :
     fi
 }
+install_elasticsearch_hadoop () {
+    if [ ! -f "/home/ubuntu/elasticsearch-hadoop-2.0.0/dist/elasticsearch-hadoop-2.0.0.jar" ] ;
+    then
+     apt-get install unzip -y
+     cd /home/ubuntu
+
+     wget http://download.elasticsearch.org/hadoop/elasticsearch-hadoop-2.0.0{.zip,.zip.sha1.txt} 
+     sh1=$(openssl sha1 *.zip | awk '{print $NF}')
+     sh2=$(cat *.sha1.txt | awk '{print $1;}')
+     if [ $sh1 != $sh2 ] ;
+        then
+            juju-log "invalid checksum"
+           exit 1
+        fi
+    
+     unzip elasticsearch-hadoop-2.0.0.zip 
+     elk_jar_path="export LIBJARS=\$LIBJARS:/home/ubuntu/elasticsearch-hadoop-2.0.0/dist/elasticsearch-hadoop-2.0.0.jar"
+     echo $elk_jar_path >> /home/ubuntu/.bashrc
+    
+    fi
+}
 
 install_job () {
-    #HADOOP_HOME=/usr/lib/hadoop
-    set_hadoopenv 
-    configure_systemenv
+   
     juju-log "installing terasort script"
     cp scripts/terasort.sh $HADOOP_DIR
     chown ubuntu.hadoop $HADOOP_DIR/terasort.sh
@@ -535,31 +561,27 @@
     install)
         configure_hosts
         configure_sources
-        set_hadoopenv
+        
         install_base_packages
-        configure_systemenv
+
         install_optional_packages
         configure_hadoop
         configure_tmp_dir_perms
         ;;
+    stop)
+     stop_hadoop
+    ;;
     resourcemanager-relation-joined)
         case $mapred_role in
             unconfigured)
                 juju-log "Configuring this unit as a resourcemanager"
-                mapred_role="resourcemanager"
-                # this is a hack, should be removed with .dep package install 
-                #mkdir -p /usr/share/doc/hadoop-resourcemanager
-                # end of hack 
+                mapred_role="resourcemanager"               
                 configure_role_relation $mapred_role
-                install_packages $mapred_role
-                set_hadoopenv
-                configure_systemenv
+                install_packages $mapred_role               
                 _restart_yarn
                 open_ports
                 install_job
-                # Some hadoop processes take a bit of time to start
-                # we need to let them get to a point where they are
-                # ready to accept connections
+                
                 sleep 10 && relation-set ready="true"
                 ;;
             resourcemanager)
@@ -592,8 +614,7 @@
                     # end of hack 
                     configure_role_relation $mapred_role
                     install_packages $mapred_role
-                    set_hadoopenv
-                    configure_systemenv
+                    
                     _restart_yarn
                     open_ports
                 fi
@@ -632,8 +653,7 @@
                 # this is a hack, should be removed with .dep package install 
                 #mkdir -p /usr/share/doc/hadoop-namenode 
                 # end of hack 
-                set_hadoopenv
-                configure_systemenv
+                
                 configure_role_relation $hdfs_role
                 install_packages $hdfs_role
                 stop_hadoop
@@ -675,8 +695,7 @@
                     # end of hack 
                     configure_role_relation $hdfs_role
                     install_packages $hdfs_role
-                    set_hadoopenv
-                    configure_systemenv
+                    
                     _restart_hdfs
                     open_ports
                 fi
@@ -703,14 +722,14 @@
                     juju-log "Namenode not yet ready"
                     exit 0
                 else
+                    relation-set slave_IP=`unit-get private-address`
                     juju-log "Configuring this unit as a datanode"
                     hdfs_role="datanode"
                     # this is a hack, should be removed with .dep package install 
                     # mkdir -p /usr/share/doc/hadoop-datanode
                     # end of hack
                     configure_role_relation $hdfs_role
-                    set_hadoopenv
-                    configure_systemenv
+                    
                     install_packages $hdfs_role
                     _restart_hdfs
                     open_ports
@@ -729,6 +748,11 @@
                 ;;
         esac
         ;;
+    elasticsearch-relation-joined)
+            juju-log "Reconfiguring this resourcemanager to communicate with elasticsearch cluster"
+            [ mapred_role="resourcemanager" ] && install_elasticsearch_hadoop || :
+
+        ;;
     ganglia-relation-changed)
         # Call generic ganglia install and configure script
         # TODO supercede when subordinates land.
@@ -741,14 +765,26 @@
         conditional_restart # only restart if pertinent config has changed!
         ;;
     upgrade-charm|config-changed)
-        set_hadoopenv
+        
         install_optional_packages
-        configure_systemenv
         configure_hadoop
         configure_tmp_dir_perms
         conditional_restart # only restart if pertinent config has changed!
         open_ports
         ;;
+     namenode-relation-changed)
+        juju-log "Configuring namenode - Changed phase"
+        slave_IP=`relation-get slave_IP`
+        if [ -z "$slave_IP" ]
+        then
+           juju-log "Configuring namenode changed - Changed phase -  NO slave ip"
+           exit 0
+        else
+           juju-log "Configuring namenode - Changed phase -  got slave_ip= $slave_IP"
+           echo $slave_IP>>/etc/hadoop/conf.juju/slaves
+           chown -R ubuntu:hadoop /etc/hadoop/conf.juju
+        fi
+        ;;
     *)
         juju-log "Command not recognised"
         ;;

=== modified file 'metadata.yaml'
--- metadata.yaml	2014-06-13 22:40:33 +0000
+++ metadata.yaml	2014-07-07 14:22:54 +0000
@@ -21,3 +21,5 @@
     interface: mapred
   mapred-namenode:
     interface: dfs
+  elasticsearch:
+    interface: elasticsearch