Я пытаюсь выполнить фрагмент кода свиньи с помощью Spring xd, но не могу этого сделать. Я создал задание, используя следующую команду
job create --name Pig_job --definition "PigTest" --deploy
Определение задания PigTest определяется следующим образом в каталоге Spring xd modules/job.
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:hdp="http://www.springframework.org/schema/hadoop"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:util="http://www.springframework.org/schema/util"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd
http://www.springframework.org/schema/hadoop http://www.springframework.org/schema/hadoop/spring-hadoop.xsd">
<hdp:pig-runner id="pigRunner" run-at-startup="true">
<hdp:script>
student = LOAD '/user/KhiTest/Test123/student' AS (Id:int,Name:chararray,Year:int);
DUMP student;
</hdp:script>
</hdp:pig-runner>
</beans>
Задание создается успешно, но развертывание завершается сбоем. Файл журнала приведен ниже:
Вызвано: java.lang.ClassNotFoundException: org.apache.pig.backend.executionengine.ExecJob
