I would just google for Guava conflict and "shading". Its a fairly common problem with Guava, there are quite a few guides out there how to address that.
On Fri, Dec 23, 2016 at 9:12 PM, Flavio Pompermaier <[email protected]> wrote: > What do you meab exactly...? do you have a snippet of how I should edit > the pom? > > On 23 Dec 2016 19:31, "Stephan Ewen" <[email protected]> wrote: > >> 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 <[email protected] >> > 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(Cli >>> entScanner.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(HT >>> able.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 >>> >> >>
