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.

Reply via email to