Hi Sadasiva, could you please provide entire log that sqoop generated with --verbose argument?
Also it seems that your table contains only two columns MESSAGE_ID and EVENT_TIME. Column MESSAGE_ID seems to me as primary key of the table. If so, I would recommend to use this column for splitting by altering your command line with "--split-by MESSAGE_ID". Jarcec On Mon, Sep 10, 2012 at 03:23:46PM -0700, Sadasiva Guntupalli wrote: > I am running the following sqoop command to import data from Oracle 11g to > Hive database. It throws the following exception. I appreciate your help. > * > > Sqoop Command: > * > > sqoop import --connect jdbc:oracle:thin:@//abc-scan:1521/RACMSLT --query > 'SELECT R.MESSAGE_ID, R.EVENT_DATETIME FROM EVENT_CONTENT > PARTITION(CONTENT_P20120826) R WHERE $CONDITIONS' --split-by EVENT_DATETIME > --username ABC --password RMLT01 --target-dir /user/hive/SS/CONTENT > --hive-table EVENT_CONTENT --hive-import --hive-partition-key > HYDRO_PART_DATE --hive-partition-value "2012-08-26" -m 6 --verbose > * > > Oracle database table: > * > > EVENT_CONTENT > > ------------- > > MESSAGE_ID NUMBER > > EVENT_DATETIME TIMESTAMP(3) > > * > > Exception: > * > > java.io.IOException: SQLException in nextKeyValue > > at > org.apache.sqoop.mapreduce.db.DBRecordReader.nextKeyValue(DBRecordReader.java:265) > > at > org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapTask.java:474) > > at org.apache.hadoop.mapreduce.MapContext.nextKeyValue(MapContext.java:67) > > at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:143) > > at > org.apache.sqoop.mapreduce.AutoProgressMapper.run(AutoProgressMapper.java:183) > > at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:668) > > at org.apache.hadoop.mapred.MapTask.run(MapTask.java:334) > > at org.apache.hadoop.mapred.Child$4.run(Child.java:270) > > at java.security.AccessController.doPrivileged(Native Method) > > at javax.security.auth.Subject.doAs(Subject.java:415) > > at > org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1126) > > at org.apache.hadoop.mapred.Child.main(Child.java:264) > > Caused by: java.sql.SQLDataException: ORA-01843: not a valid month > > at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:457) > > at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:400) > > at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:926) > > at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:476) > > at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:200) > > at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:543) > > at > oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:238) > > at > oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1244) > > at > oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:1492) > > at > oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1710) > > at > oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:4372) > > at > oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:4453) > > at > oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:6270) > > at > org.apache.sqoop.mapreduce.db.DBRecordReader.executeQuery(DBRecordReader.java:111) > > at > org.apache.sqoop.mapreduce.db.DBRecordReader.nextKeyValue(DBRecordReader.java:236) > > ... 11 more > > Thanks > Sadasiva
signature.asc
Description: Digital signature
