Я пытаюсь импортировать данные mongodb в улей.
Используемые мной версии jar
ADD JAR /root/HDL/mongo-java-driver-3.4.2.jar;
ADD JAR /root/HDL/mongo-hadoop-hive-2.0.2.jar;
ADD JAR /root/HDL/mongo-hadoop-core-2.0.2.jar;
И мои версии кластера
Ambari - Версия 2.6.0.0, HDFS 2.7.3, Hive 1.2.1000, HBase 1.1.2, Tez 0.7.0 Версия MongoDB Server: - 3.6.5
Скрипт Hive: -
CREATE TABLE sampletable
( ID STRING,
EmpID STRING,
BeginDate DATE,
EndDate DATE,
Time TIMESTAMP,
Type STRING,
Location STRING,
Terminal STRING)
STORED BY 'com.mongodb.hadoop.hive.MongoStorageHandler'
WITH SERDEPROPERTIES('mongo.columns.mapping'='{"ID":"_id","EmpID":"emp_id","BeginDate":"begin_date","EndDate":"end_date","Time":"time","Type":"time_event_type","Location":"location","Terminal":"terminal"}')
TBLPROPERTIES('mongo.uri'='mongodb://username:password@10.10.170.43:27017/testdb.testtable');
Вывод: -
hive> select * from sampletable;
OK
Сбой с исключением java.io.IOException: java.io.IOException: не удалось объединить образцы документов.Обратите внимание, что эта реализация Splitter несовместима с версиями MongoDB до 3.2.
Пожалуйста, подскажите, как я могу решить эту проблему.
Спасибо,
Mohan V