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.translateException(
RpcRetryingCaller.java:229)
at org.apache.hadoop.hbase.client.RpcRetryingCaller.callWithoutRetries(
RpcRetryingCaller.java:202)
at org.apache.hadoop.hbase.client.ClientScanner.call(
ClientScanner.java:314)
at org.apache.hadoop.hbase.client.ClientScanner.
nextScanner(ClientScanner.java:289)
at org.apache.hadoop.hbase.client.ClientScanner.
initializeScannerInConstruction(ClientScanner.java:161)
at org.apache.hadoop.hbase.client.ClientScanner.<init>(
ClientScanner.java:156)
at org.apache.hadoop.hbase.client.HTable.getScanner(HTable.java:888)
at org.apache.hadoop.hbase.client.MetaScanner.metaScan(
MetaScanner.java:187)
at org.apache.hadoop.hbase.client.MetaScanner.metaScan(
MetaScanner.java:89)
at org.apache.hadoop.hbase.client.MetaScanner.listTableRegionLocations(
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.createInputSplits(
TableInputFormat.java:170)
at org.apache.flink.addons.hbase.TableInputFormat.createInputSplits(
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.
blockUntilAvailable(MetaTableLocator.java:434)
at org.apache.hadoop.hbase.client.ZooKeeperRegistry.
getMetaRegionLocation(ZooKeeperRegistry.java:60)
at org.apache.hadoop.hbase.client.ConnectionManager$
HConnectionImplementation.locateRegion(ConnectionManager.java:1122)
at org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadRepli
cas.getRegionLocations(RpcRetryingCallerWithReadReplicas.java:299)
at org.apache.hadoop.hbase.client.ScannerCallableWithReplicas.call(
ScannerCallableWithReplicas.java:155)
at org.apache.hadoop.hbase.client.ScannerCallableWithReplicas.call(
ScannerCallableWithReplicas.java:63)
at org.apache.hadoop.hbase.client.RpcRetryingCaller.callWithoutRetries(
RpcRetryingCaller.java:200)
... 38 more
Best,
Flavio
