From 7cd62bedac81ce078ba0933722026f260ed2eedd Mon Sep 17 00:00:00 2001
From: lingjinjiang <lingjinjiang@gmail.com>
Date: Mon, 10 Apr 2017 18:50:50 +0800
Subject: [PATCH] [FLINK-6286] Fix the hbase command not found error

---
 flink-dist/src/main/flink-bin/bin/config.sh | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/flink-dist/src/main/flink-bin/bin/config.sh b/flink-dist/src/main/flink-bin/bin/config.sh
index a0c755011e5e8..c6f72ac4babeb 100755
--- a/flink-dist/src/main/flink-bin/bin/config.sh
+++ b/flink-dist/src/main/flink-bin/bin/config.sh
@@ -311,7 +311,12 @@ INTERNAL_HADOOP_CLASSPATHS="${HADOOP_CLASSPATH}:${HADOOP_CONF_DIR}:${YARN_CONF_D
 
 if [ -n "${HBASE_CONF_DIR}" ]; then
     # Setup the HBase classpath.
-    INTERNAL_HADOOP_CLASSPATHS="${INTERNAL_HADOOP_CLASSPATHS}:`hbase classpath`"
+    HBASE_IN_PATH=$(PATH="${HBASE_HOME}/bin:$PATH" \
+        which hbase 2>/dev/null)
+    if [ -f "${HBASE_IN_PATH}" ]; then
+        INTERNAL_HADOOP_CLASSPATHS="${INTERNAL_HADOOP_CLASSPATHS}:`${HBASE_IN_PATH} classpath`"
+        echo $INTERNAL_HADOOP_CLASSPATHS
+    fi
 
     # We add the HBASE_CONF_DIR last to ensure the right config directory is used.
     INTERNAL_HADOOP_CLASSPATHS="${INTERNAL_HADOOP_CLASSPATHS}:${HBASE_CONF_DIR}"