You have the classical guava version conflict. Flink itself shades Guava away, but there may be multiple conflicting dependencies in your case (HBase / Solr).
I would try to see which of the tool/libraries (HBase, Solr, ...) depend on Guava and create a shaded version of one of them On Fri, Dec 23, 2016 at 6:33 PM, Flavio Pompermaier <pomperma...@okkam.it> wrote: > Hi to all, > > I have a source HBase table and I have to write to a Solr index. > Unfortunately when I try to run the program on the cluster (Flink 1.1.1) I > think I have some problem with dependencies. Can someone suggest me some > fix? > > This is the error I have just after launching the job: > > Caused by: org.apache.hadoop.hbase.DoNotRetryIOException: > java.lang.IllegalAccessError: tried to access method > com.google.common.base.Stopwatch.<init>()V from class > org.apache.hadoop.hbase.zookeeper.MetaTableLocator > at org.apache.hadoop.hbase.client.RpcRetryingCaller.translateEx > ception(RpcRetryingCaller.java:229) > at org.apache.hadoop.hbase.client.RpcRetryingCaller.callWithout > Retries(RpcRetryingCaller.java:202) > at org.apache.hadoop.hbase.client.ClientScanner.call(ClientScan > ner.java:314) > at org.apache.hadoop.hbase.client.ClientScanner.nextScanner( > ClientScanner.java:289) > at org.apache.hadoop.hbase.client.ClientScanner.initializeScann > erInConstruction(ClientScanner.java:161) > at org.apache.hadoop.hbase.client.ClientScanner.<init>(ClientSc > anner.java:156) > at org.apache.hadoop.hbase.client.HTable.getScanner(HTable.java:888) > at org.apache.hadoop.hbase.client.MetaScanner.metaScan(MetaScan > ner.java:187) > at org.apache.hadoop.hbase.client.MetaScanner.metaScan(MetaScan > ner.java:89) > at org.apache.hadoop.hbase.client.MetaScanner.listTableRegionLo > cations(MetaScanner.java:334) > at org.apache.hadoop.hbase.client.HTable.listRegionLocations( > HTable.java:702) > at org.apache.hadoop.hbase.client.HTable.getStartEndKeys(HTable > .java:685) > at org.apache.flink.addons.hbase.TableInputFormat.createInputSp > lits(TableInputFormat.java:170) > at org.apache.flink.addons.hbase.TableInputFormat.createInputSp > lits(TableInputFormat.java:45) > at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.< > init>(ExecutionJobVertex.java:156) > ... 25 more > Caused by: java.lang.IllegalAccessError: tried to access method > com.google.common.base.Stopwatch.<init>()V from class > org.apache.hadoop.hbase.zookeeper.MetaTableLocator > at org.apache.hadoop.hbase.zookeeper.MetaTableLocator.blockUnti > lAvailable(MetaTableLocator.java:434) > at org.apache.hadoop.hbase.client.ZooKeeperRegistry.getMetaRegi > onLocation(ZooKeeperRegistry.java:60) > at org.apache.hadoop.hbase.client.ConnectionManager$HConnection > Implementation.locateRegion(ConnectionManager.java:1122) > at org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadRepl > icas.getRegionLocations(RpcRetryingCallerWithReadReplicas.java:299) > at org.apache.hadoop.hbase.client.ScannerCallableWithReplicas.c > all(ScannerCallableWithReplicas.java:155) > at org.apache.hadoop.hbase.client.ScannerCallableWithReplicas.c > all(ScannerCallableWithReplicas.java:63) > at org.apache.hadoop.hbase.client.RpcRetryingCaller.callWithout > Retries(RpcRetryingCaller.java:200) > ... 38 more > > > Best, > Flavio >
