Я хочу записать свой набор искровых данных в таблицы фениксов. Кто-нибудь может мне помочь в этом?

Question

Я написал следующий код, но он не работает.

df.write().format("org.apache.phoenix.spark").mode(SaveMode.Overwrite).options(ImmutableMap.of("zkUrl", clientProp.getProperty("zookeeper.url"), "table", "mdr_rec.kafka_offsets")).save();

Я получаю следующую ошибку:

    at org.apache.spark.sql.execution.datasources.SaveIntoDataSourceCommand.run(SaveIntoDataSourceCommand.scala:46)
    at org.apache.spark.sql.execution.command.ExecutedCommandExec.sideEffectResult$lzycompute(commands.scala:70)

Answer 1

Можете ли вы включить всю трассировку стека, которая будет очень полезна