Ok thans Stephan! On 23 Dec 2016 21:16, "Stephan Ewen" <[email protected]> wrote:
> 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 >>>> >>> >>> >
