oracle模式的ob库数据通过sqoop同步到hive中,sqoop脚本使用-m参数报错怎么处理

【 使用环境 】生产环境 or 测试环境
【 OB or 其他组件 】
【 使用版本 】
【问题描述】oracle模式的ob库数据通过sqoop同步到hive中,sqoop脚本使用-m参数报错(sqoop脚本为附件1,报错信息为附件2)
【复现路径】问题出现前后相关操作
【脚本代码】sqoop import “-Dorg.apache.sqoop.splitter.allow_text_splitter=true”
–connect jdbc:oceanbase://xcdb.edhic.com:2883/nclaimuser?dontTrackOpenResources=true&defaultFetchSize=10000&useCursorFetch=true
–username sjzl@xc_ora_zh01
–password xxxxxx
–query “select id
,datatype
,datacode
,dataname
,pretype
,precode
,inserttimeforhis
,operatetimeforhis
,validstatus
,olddatacode
,olddataname
,enumid
,sysdate as inputdate
from nclaimuser.commondata
where 1 = 1
and $CONDITIONS”
–m 4
–hive-table ods_edw.ods_ncl_commondata
–hive-drop-import-delims
–fields-terminated-by ‘\001’
–delete-target-dir
–null-non-string ‘\N’
–null-string ‘\N’
–fetch-size 10000
–driver com.alipay.oceanbase.jdbc.Driver
–target-dir /user/hive/warehouse/ods_edw.db/ods_ncl_commondata_tmp
–hive-overwrite
–split-by id
–map-column-java ID=String,DATATYPE=String,DATACODE=String,DATANAME=String,PRETYPE=String,PRECODE=String,INSERTTIMEFORHIS=String,OPERATETIMEFORHIS=String,VALIDSTATUS=String,OLDDATACODE=String,OLDDATANAME=String,ENUMID=String
–hive-import


你这个企业版, 建议你找企业版的技术support 咨询一下, 他们处理会更快

你好,oracle模式的建议咨询企业版小助手

oracle模式的ob库数据通过sqoop同步到hive中,sqoop脚本使用-m参数报错 - 社区问答- OceanBase社区-分布式数据库 可以看这个 ,一个问题。