Flink Yarn-Session模式写入hbase报错NoClassDefFoundError: org/apache/htrace/Trace的解决(基于CDH6.3)

版本:Flink1.11.1

版本：Flink1.11.1  CDH:6.3.2

已知该Hbase对应的Htrace版本:

htrace-core-3.2.0-incubating.jar

htrace-core4-4.1.0-incubating.jar

htrace-core4-4.2.0-incubating.jar
 

解决方法：

1.拷贝JAR

所有节点执行：

cp /opt/cloudera/parcels/CDH/jars/htrace-core* /opt/cloudera/parcels/CDH/lib/hbase/lib/

Flink启动节点执行:

cp /opt/cloudera/parcels/CDH/lib/hbase/lib/htrace-core*   $FLINK_HOME/lib/

2.重启hbase

3.重启Yarn-Session

4.提交job

flink run  \
-yid application_XXXXXX_XXXX \
XXXX.jar -d