You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hbase.apache.org by "ulysses you (JIRA)" <ji...@apache.org> on 2017/09/22 09:42:00 UTC

[jira] [Created] (HBASE-18863) spark over hbase snapshot

ulysses you created HBASE-18863:
-----------------------------------

             Summary: spark over hbase snapshot
                 Key: HBASE-18863
                 URL: https://issues.apache.org/jira/browse/HBASE-18863
             Project: HBase
          Issue Type: Bug
          Components: Client, snapshots, spark
    Affects Versions: 1.2.0
            Reporter: ulysses you


The configuration error in two method. First is ok, and second is wrong.

{code:java}
1.
val hConf = HBaseConfiguration.create()
// ignore some config

val hBaseRDD = sc.newAPIHadoopRDD(hConf,
      classOf[TableSnapshotInputFormat],
      classOf[org.apache.hadoop.hbase.io.ImmutableBytesWritable],
      classOf[org.apache.hadoop.hbase.client.Result])
2.
val hConf = HBaseConfiguration.create()
val job = Job.getInstance(hConf)
val hBaseRDD = sc.newAPIHadoopRDD(job.getConfiguration,
      classOf[TableSnapshotInputFormat],
      classOf[org.apache.hadoop.hbase.io.ImmutableBytesWritable],
      classOf[org.apache.hadoop.hbase.client.Result])

and the log:
Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.hbase.codec.prefixtree.PrefixTreeCodec
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:264)
at org.apache.hadoop.hbase.io.encoding.DataBlockEncoding.createEncoder(DataBlockEncoding.java:186)
... 21 more
{code}


I'm sure that I have upload jar with spark cmd -jars.
Is this a bug?



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)