Не удается найти класс 'org.apache.hadoop.hive.kafka.KafkaStorageHandler'

Question

СБОЙ: SemanticException Не удается найти класс 'org.apache.hadoop.hive.kafka.KafkaStorageHandler'

Я уже добавил / KAFKA_HOME / libs / * в classpath

Это мойТестовый код:

(ID_code string, 
target int ,
var_0 FLOAT, 
var_1 FLOAT,
var_2 FLOAT,
var_3 FLOAT,
var_4 FLOAT)

STORED BY 'org.apache.hadoop.hive.kafka.KafkaStorageHandler'

TBLPROPERTIES(
"kafka.topic" = "test_steam",
"kafka.bootstrap.servers" = "lcoal:8778");

Я полагаю, мне не хватает файла JAR.Но у меня проблемы с поиском KafkaStorageHandler.

Answer 1

Я обнаружил, что есть jar, который я должен загрузить и поместить в папку $ HIVE_HOME / lib: kafka-handler-3.1.0.jar После этого hive работал с kafka.