目前,我正在尝试导入一个带有sqoop的sap hana表。在这里,我遇到了一个问题,即表名和列名都包含正斜杠"/“。
对于表名,我可以使用查询选项和转义表名作为解决办法。但是,如果我想用不同的映射程序导入表,我想将-m选项与-拆分结合使用。在这里,我不能在列名中指定"/“,除非得到以下错误。
20/06/26 08:05:02 ERROR tool.ImportTool: Encountered IOException running import job: java.io.IOException: com.sap.db.jdbc.exceptions.JDBCDriverException: SAP DBTech JDBC: [257] (at 12): sql syntax error: incorrect syntax near "/": line 1 col 12 (at pos 12)
由sqoop生成的查询如下所示
SELECT MIN(/SOMETHING/KEY_COLUMN), MAX(/SOMETHING/KEY_COLUMN) FROM (select * from SCHEMA."/SOMETHING/TABLE_NAME") AS t1
声明:
sqoop import -D org.apache.sqoop.splitter.allow_text_splitter=true \
--driver com.sap.db.jdbc.Driver \
--connect jdbc:sap://alias:port/ \
--split-by "/SOMETHING/KEY_COLUMN" \
--target-dir /target-dir \
--delete-target-dir \
--query "select * from SCHEMA.\"/SOMETHING/TABLE_NAME\" where 1=1 AND \$CONDITIONS" \
--as-parquetfile \
--username username \
--password pw \
--num-mappers 4 \
--verbose
我怎样才能正确地避开--拆分列?
发布于 2020-06-29 08:06:58
它与使用
-拆分-被“(”/SOMETHING/KEY_COLUMN“)”“\
sqoop
import -D org.apache.sqoop.splitter.allow_text_splitter = true\
--driver com.sap.db.jdbc.Driver\
--connect jdbc: sap: //alias:port/ \
--split - by "(\"/SOMETHING/KEY_COLUMN\")"\
--target - dir / target - dir\
--delete - target - dir\
--query "select * from SCHEMA.\"/SOMETHING/TABLE_NAME\" where 1=1 AND \$CONDITIONS"\
--as - parquetfile\
--username username\
--password pw\
--num - mappers 4\
--verbose
https://stackoverflow.com/questions/62589008
复制相似问题