Hi Guys,

    I am using sqoop command to import data from Netezza. Whenever I use
the "sqoop import" command without "--direct" it gives me the
error "SQLException in nextKeyValue".

Here is command(without direct):  *sqoop import --table table1 --connect
jdbc:netezza://<ip>/schema --driver org.netezza.Driver --hive-table
hive_table1 --username '<username>' --password '<password>' --hive-import *
*Works fine if "--direct" is included*

Stacktrace:
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:458)
        at
org.apache.hadoop.mapreduce.task.MapContextImpl.nextKeyValue(MapContextImpl.java:76)
        at
org.apache.hadoop.mapreduce.lib.map.WrappedMapper$Context.nextKeyValue(WrappedMapper.java:85)
        at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:139)
        at
org.apache.sqoop.mapreduce.AutoProgressMapper.run(AutoProgressMapper.java:183)
        at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:645)
        at org.apache.hadoop.mapred.MapTask.run(MapTask.java:325)
        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:396)
        at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1232)
        at org.apache.hadoop.mapred.Child.main(Child.java:264)

Thanks in advance,
Nitin Kak

Hi Nitin,
thank you very much for reaching us for help.

It seems that you're using Cloudera Netezza driver that is not part of Apache Sqoop. It would be better to bring this topic to cdh-user[1] mailing list for proper help. I've noticed that you already cross send this email there, so I've provided my feedback [2].

Jarcec

Links:
1: https://groups.google.com/a/cloudera.org/forum/?fromgroups#!forum/cdh-user
2: https://groups.google.com/a/cloudera.org/forum/#!topic/cdh-user/qfdVcjQo1uo/discussion

On Tue, Sep 25, 2012 at 04:42:08PM -0400, Nitin kak wrote:
> Hi Guys,
>
>     I am using sqoop command to import data from Netezza. Whenever I use
> the "sqoop import" command without "--direct" it gives me the
> error "SQLException in nextKeyValue".
>
> Here is command(without direct):  *sqoop import --table table1 --connect
> jdbc:netezza://<ip>/schema --driver org.netezza.Driver --hive-table
> hive_table1 --username '<username>' --password '<password>' --hive-import *
> *Works fine if "--direct" is included*
>
> Stacktrace:
> 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:458)
>         at
> org.apache.hadoop.mapreduce.task.MapContextImpl.nextKeyValue(MapContextImpl.java:76)
>         at
> org.apache.hadoop.mapreduce.lib.map.WrappedMapper$Context.nextKeyValue(WrappedMapper.java:85)
>         at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:139)
>         at
> org.apache.sqoop.mapreduce.AutoProgressMapper.run(AutoProgressMapper.java:183)
>         at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:645)
>         at org.apache.hadoop.mapred.MapTask.run(MapTask.java:325)
>         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:396)
>         at
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1232)
>         at org.apache.hadoop.mapred.Child.main(Child.java:264)
>
> Thanks in advance,
> Nitin Kak