java .lang.NoClassDefFoundError: org / apache / hadoop / hbase / client / Put - PullRequest
Новая
       142

java .lang.NoClassDefFoundError: org / apache / hadoop / hbase / client / Put

0 голосов
/ 06 мая 2020

Я выполняю задание по извлечению данных из Kafka в HBase с помощью Spark / Scala. Jar создается без ошибок, но возникает ошибка при запуске задания искровой отправки, пожалуйста, помогите мне.

Исключение в потоке «main» java .lang.NoClassDefFoundError: org / apache / hadoop / hbase / client / Ставим 

  def load(gigi: DigiTbl, recordNum: Int, logEvery: Int): Put = {
    val rowKey = String.format("%s:%s", c1 c2)
    val put = new Put(Bytes.toBytes(rowKey))
    put.addColumn(columnFamily, Bytes.toBytes("c1"), Bytes.toBytes(digi.channel))
    if (recordNum % logEvery == 0) {
      LOG.info("Digital input: " + digi.toString)
      LOG.info("Put output: " + put.toJSON)
    }
    put
  }
...