today,i use flink-1.2.0,and run a job on yarn,the commend is:
flink-1.2.0/bin/flink run \
-m yarn-cluster \
-yn 2 \
-ys 4 \
-yjm 3072 \
-ytm 2048 \
--class statics.ComputevecSim \
--classpath file:///opt/cloudera/parcels/CDH/lib/hbase/hbase-client.jar \
--classpath file:///opt/cloudera/parcels/CDH/lib/hbase/hbase-server.jar \
--classpath file:///opt/cloudera/parcels/CDH/lib/hbase/hbase-protocol.jar \
--classpath file:///opt/cloudera/parcels/CDH/lib/hbase/hbase-common.jar \
--classpath file:///opt/cloudera/parcels/CDH/jars/htrace-core-3.1.0-incubating.jar \
--classpath file:///opt/cloudera/parcels/CDH/lib/hbase/lib/guava-12.0.1.jar \
/home/.../text-assembly-0.1.0.jar hdfs:///user/hadoop/wenhao/xj/wenda_search_aggregate_page.txt
and have a error:
Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.hbase.filter.Filter
but use flink-1.1.1 it can run success,some one can tell me how to solve this problem.
Locked
