hue上workflow之shell-sqoop脚本配置实录
workflow之shell-sqoop脚本实录
前⾯讲解了解决与问题解决，那么这⾥就详细介绍下在hue上配置shell-sqoop脚本时所遇到的问题！这⾥的shell脚本会以上篇的脚本为例！
⼀、配置hue的workflow
⼆、所遇问题
2.1 不能加载mysql驱动
报错如下：
ERROR sqoop.Sqoop: Got exception running Sqoop: java.lang.RuntimeException: Could not load db driver class: sql.jdbc.Driver
java.lang.RuntimeException: Could not load db driver class: sql.jdbc.Driver
at org.apache.sqoop.manager.SqlManager.makeConnection(SqlManager.java:874)
at org.apache.sqoop.Connection(GenericJdbcManager.java:52)
at org.apache.sqoop.ute(SqlManager.java:762)
at org.apache.sqoop.ute(SqlManager.java:785)
at org.apache.sqoop.ColumnInfoForRawQuery(SqlManager.java:288)
at org.apache.sqoop.ColumnTypesForRawQuery(SqlManager.java:259)
at org.apache.sqoop.ColumnTypes(SqlManager.java:245)
at org.apache.sqoop.ColumnTypes(ConnManager.java:333)
at org.ColumnTypes(ClassWriter.java:1858)
at org.ate(ClassWriter.java:1657)
at org.ateORM(CodeGenTool.java:106)
at org.l.ImportTool.importTable(ImportTool.java:494)
at org.l.ImportTool.run(ImportTool.java:621)
at org.apache.sqoop.Sqoop.run(Sqoop.java:147)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70)
at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:183)
at org.apache.sqoop.Sqoop.runTool(Sqoop.java:234)
at org.apache.sqoop.Sqoop.runTool(Sqoop.java:243)
at org.apache.sqoop.Sqoop.main(Sqoop.java:252)
问题解决：由于是使⽤的shell脚本进⾏的导⼊所以回去SQOOP_HOME的lib⽬录下去加载mysql驱动，所以这⾥只需要把mysql驱动拷贝到sqoop的lib⽬录下，然后重启服务就好了。操作过程如下
# 获取驱动
wget sql/get/Downloads/Connector-J/mysql-connector-java-5.1./from/sql/
# 拷贝驱动到SQOOP_HOME的lib⽬录下
cp /usr/share/java/mysql-connector-java-5.1.46.jar /data/cloudera/parcels/CDH-5.14.4-1.cdh5.14.4.p0.3/lib/sqoop/lib
# 分发每台机器，xsync这⾥是⾃定义的分发脚本，参考之前博客hadoop，也可使⽤scp命名去进⾏分发
xsync /data/cloudera/parcels/CDH-5.14.4-1.cdh5.14.4.p0.3/lib/sqoop/lib/mysql-connector-java-5.1.46.jar
2.2 调度时报错⽂件不存在
报错如下：
org.apache.ptions.YarnRuntimeException: java.io.FileNotFoundException: File does not exist: hdfs://nameservice1/user/admin/.staging/j ob_1590901453442_0029/job.splitmetainfo
at org.apache.hadoop.mapreduce.v2.app.job.impl.ateSplits(JobImpl.java:1580)
at org.apache.hadoop.mapreduce.v2.app.job.impl.ansition(JobImpl.java:1444)
at org.apache.hadoop.mapreduce.v2.app.job.impl.ansition(JobImpl.java:1402)
at org.apache.hadoop.yarn.state.StateMachineFactory$MultipleInternalArc.doTransition(StateMachineFactory.java:385)
at org.apache.hadoop.yarn.state.StateMachineFactory.doTransition(StateMachineFactory.java:302)
at org.apache.hadoop.yarn.state.StateMachineFactory.access$300(StateMachineFactory.java:46)
at org.apache.hadoop.yarn.state.StateMachineFactory$InternalStateMachine.doTransition(StateMachineFactory.java:448)
at org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl.handle(JobImpl.java:996)
at org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl.handle(JobImpl.java:138)
at org.apache.hadoop.mapreduce.v2.app.MRAppMaster$JobEventDispatcher.handle(MRAppMaster.java:1366)
at org.apache.hadoop.mapreduce.v2.app.MRAppMaster.serviceStart(MRAppMaster.java:1142)
at org.apache.hadoop.service.AbstractService.start(AbstractService.java:193)
at org.apache.hadoop.mapreduce.v2.app.MRAppMaster$5.run(MRAppMaster.java:1573)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1924)
at org.apache.hadoop.mapreduce.v2.app.MRAppMaster.initAndStartAppMaster(MRAppMaster.java:1569)
mysql下载appat org.apache.hadoop.mapreduce.v2.app.MRAppMaster.main(MRAppMaster.java:1502)
Caused by: java.io.FileNotFoundException: File does not exist: hdfs://nameservice1/user/admin/.staging/job_1590901453442_0029/job.splitmetainfo
at org.apache.hadoop.hdfs.DistributedFileSystem$20.doCall(DistributedFileSystem.java:1269)
at org.apache.hadoop.hdfs.DistributedFileSystem$20.doCall(DistributedFileSystem.java:1261)
at org.apache.hadoop.solve(FileSystemLinkResolver.java:81)
at org.apache.hadoop.FileStatus(DistributedFileSystem.java:1261)
at org.apache.hadoop.mapreduce.adSplitMetaInfo(SplitMetaInfoReader.j
ava:51)
at org.apache.hadoop.mapreduce.v2.app.job.impl.ateSplits(JobImpl.java:1575)
... 17 more
问题解决：由于hue执⾏shell脚本时是随机发往⼀台集中的机器执⾏，⽽当我们运⾏该任务时，任务会在当前hue⽤户下创建job等任务信息，但是在下发⾄集机器执⾏时没有指定执⾏任务的⽤户使其⽆法获取任务信息从⽽提⽰⽂件不存在。具体解决如下:
HADOOP_USER_NAME=${wf:user()}
2.3 oozie调度脚本java.io.IOException: output.properties data exceeds its limit [2048]
shell脚本中⼀次提交的作业量太⼤，其中包含的信息超过oozie launcher⼀次容许的最⼤值2K（2K是默认值）
问题解决：CDH集中修改 l 的 Oozie Server ⾼级配置代码段（安全阀），然后重启，修改如下：
<property>
<name>oozie.action.max.output.data</name>
<value>204800</value>
</property>

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。