从mysql到hive使用sqoop命令动态创建分区密钥

z9ju0rcb  于 2021-06-03  发布在  Sqoop
关注(0)|答案(0)|浏览(265)

我想通过从mysql导入数据来创建一个配置单元表。以下命令可以创建表-

sqoop import \
-D mapred.job.name=name \
-Dorg.apache.sqoop.splitter.allow_text_splitter=true \
-connect "connection_detail" \
-username "username" \
-password "pwd" \
-query "SELECT * FROM schema.tablename WHERE  \$CONDITIONS " \
-null-string '' \
-null-non-string '' \
-fields-terminated-by ',' \
-m 1 \
-hive-overwrite \
--hive-import \
--hive-table tablename \
-map-column-hive z_column=bigint,y_column=int,x_column=int \
-delete-target-dir \
-target-dir  "path_dir"

我现在想在表中创建动态分区列-我尝试了以下命令。但是,它给出了下面提到的错误-

sqoop import \
-D mapred.job.name=name \
-Dorg.apache.sqoop.splitter.allow_text_splitter=true \
-connect "connection_detail" \
-username "username" \
-password "pwd" \
-query "SELECT * FROM schema.tablename WHERE  \$CONDITIONS " \
-null-string '' \
-null-non-string '' \
-fields-terminated-by ',' \
-m 1 \
-hive-overwrite \
--hive-import \
--hive-table tablename \
-map-column-hive z_column=bigint,y_column=int,x_column=int \
--hive-partition-key a_column,b_column,c_column \
--hive-partition-value 'a_data','b_data','c_data' \
-delete-target-dir \
-target-dir  "path_dir"

失败:parseexception行1:367无法识别列类型中“,”b\u列“,”附近的输入
错误到底在哪里?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题