Как запустить файл сценария Pig через Java - PullRequest
Новая
       5

Как запустить файл сценария Pig через Java

1 голос
/ 28 февраля 2012

Я пытался заставить Java-процесс запускать сценарий свиньи через PigServer.Однако каждый раз, когда задание запускает отчеты 0%, lzo сообщает о своей обработке входных данных, и задание завершается с ошибкой без ошибок, кроме сообщения PigStats «Не удалось получить задание».

Вот код.Где report - это путь к pigscript, а params - это HashMap для замены params. 

pig = new PigServer("mapreduce");
try {
    pig.registerScript(report, params);
    pig.store("patterns", "patterns");
} finally {
    pig.shutdown();
}

Я также пытался заменить store () на STORE в сценарии pig, но только что получил то же самоерезультаты.

...