Свинья Работа зависает при использовании Elephant Bird jsonLoader

Это в продолжение этого

Мой новый сценарий свиньи:

register /usr/hdp/current/pig-client/lib/piggybank.jar
register /opt/elephantbird-jars/elephant-bird-core-4.5.jar
register /opt/elephantbird-jars/elephant-bird-hadoop-compat-4.5.jar
register /opt/elephantbird-jars/elephant-bird-pig-4.5.jar
register /opt/elephantbird-jars/json-simple-1.1.1.jar

data_input = LOAD 'local/path/for/hdfs/files' USING com.twitter.elephantbird.pig.load.JsonLoader() AS (json:map[]);

x = FOREACH data_input GENERATE json#'actor__id' AS actor_id,    json#'actor__image__url' AS actor_image_url, json#'actor__displayName' AS actor_displayname, json#'actor__verification__adHocVerified' AS actor_verification, json#'actor__url' AS actor_url;

STORE x INTO '/tmp/user_posts' USING JsonStorage();

Этот код работает в локальном режиме: pig -x local user_posts.pig

Но он не работает в режиме mapreduce: pig -x mapreduce user_posts.pig

Я переместил банки на все узлы данных в одном месте. Я не уверен, где еще проверить. Может кто-нибудь, пожалуйста, дать несколько указателей?

Источник

2 ответа

Решение

Это была какая-то проблема с моей машиной, а не проблема со свиньей. Я перезагрузил машину, и все прошло хорошо.

Источник

Вам не хватает ; везде

REGISTER '/me/home/elephant-bird-core-4.12.jar';
REGISTER '/me/home/elephant-bird-pig-4.12.jar';
REGISTER '/me/home/elephant-bird-hadoop-compat-4.12.jar';
Источник
Другие вопросы по тегам