使用spring xd执行Pig脚本时出错

Question

我正在尝试使用spring xd执行pig代码段，但不能这样做。我使用以下命令创建了一个作业

job create --name Pig_job --definition "PigTest" --deploy

PigTest作业定义在spring xd模块/作业目录中定义如下

<?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>

已成功创建作业,但部署失败。日志文件如下所示：

null

Answer 1

原因：java.lang.ClassNotFoundException：org.apache.pig.backend.ExecutionEngine.ExecJob

是否将pig添加到模块的/lib中？