sqoop到mysql导入问题

问题描述 投票:0回答:1

我使用以下命令将数据从mysql表提取到配置单元表:

sqoop import \
--connect jdbc:mysql://xx.xx.xx.xx/orderdbms \
--username=orderuser \
--password=orderpass \
--table=order \
--where="DATE(created)='2015-08-20'" \
--hive-import \
--hive-table=orderstat.order \
--target-dir=/user/ordermanager/sqoopdata/orders \
--direct

在执行上述操作时,我收到以下错误:

从数据库读取时出错:java.sql.SQLException:流结果集com.mysql.jdbc.RowDataDynamic@1f16ebd3仍处于活动状态。当任何流式结果集在给定连接上打开并使用时,不会发出任何语句。在尝试更多查询之前,请确保已在任何活动的流式结果集上调用.close()。 java.sql.SQLException:流结果集com.mysql.jdbc.RowDataDynamic@1f16ebd3仍处于活动状态。当任何流式结果集在给定连接上打开并使用时,不会发出任何语句。在尝试更多查询之前,请确保已在任何活动的流式结果集上调用.close()。 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:914)at com.mysql.jdbc.MysqlIO.checkForOutstandingStreamingData(MysqlIO.java:2181)at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:1542) )com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:1723)com.mysql.jdbc.Connection.execSQL(Connection.java:3277)com.mysql.jdbc.Connection.execSQL(Connection.java: 3206)com.mysql.jdbc.Statement.executeQuery(Statement.java:1232)at com.mysql.jdbc.Connection.getMaxBytesPerChar(Connection.java:3673)at com.mysql.jdbc.Field.getMaxBytesPerCharacter(Field.java) :482)位于org.apache.sqoop.manager.SqlManager的org.apache.sqoop.manager.SqlManager.getColumnInfoForRawQuery(SqlManager.java:286)的com.mysql.jdbc.ResultSetMetaData.getPrecision(ResultSetMetaData.java:443)。位于org.apache的org.apache.sqoop.manager.SqlManager.getColumnTypes(SqlManager.java:227)的orC.apache中的getColumnTypesForRawQuery(SqlManager.java:241)org.apache.sqoop.manager.ConnManager.getColumnTypes(ConnManager.java:295) .sqoop.orm.Cl位于org.apache.sqoop.orm.ClassWriter.generate(ClassWriter.java:1645)的assWriter.getColumnTypes(ClassWriter.java:1833)org.apache.sqoop.tool.CodeGenTool.generateORM(CodeGenTool.java:107)org位于org.apache.sqoop.Sqoop.run的org.apache.sqoop.tool.ImportTool.run(ImportTool.java:605)中的.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:478)(Sqoop.java :143)org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70)org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:179)org.apache.sqoop.Sqoop.runTool( Sqoop.java:218)org.apache.sqoop.Sqoop.runTool(Sqoop.java:227)org.apache.sqoop.Sqoop.main(Sqoop.java:236)15/08/24 11:54:46错误工具.ImportTool:遇到IOException正在运行导入作业:java.io.IOException:org.apache.sqoop.tool中没有为org.apache.sqoop.orm.ClassWriter.generate(ClassWriter.java:1651)中的ClassWriter生成的列.codeGenTool.generateORM(CodeGenTool.java:107)位于org.apache.sqoop.tool的org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:478)。在org.apache上的org.apache.qache.qache.hant.ToolRunner.run(ToolRunner.java:70)的org.apache.sqoop.Sqoop.run(Sqoop.java:143)上的ImportTool.run(ImportTool.java:605) .sqoop.Sqoop.runSqoop(Sqoop.java:179)org.apache.sqoop.Sqoop.runTool(Sqoop.java:218)org.apache.sqoop.Sqoop.runTool(Sqoop.java:227)at org。 apache.sqoop.Sqoop.main(Sqoop.java:236)

任何人都可以解释是什么导致这个?客户端和mysql服务器之间的语法或连接问题是否存在问题。

mysql hive sqoop
1个回答
0
投票

尝试添加该选项

--driver com.mysql.jdbc.Driver
© www.soinside.com 2019 - 2024. All rights reserved.