diff --git a/src/java/com/cloudera/sqoop/mapreduce/ExportOutputFormat.java b/src/java/com/cloudera/sqoop/mapreduce/ExportOutputFormat.java
index 48c352b9..2b995520 100644
--- a/src/java/com/cloudera/sqoop/mapreduce/ExportOutputFormat.java
+++ b/src/java/com/cloudera/sqoop/mapreduce/ExportOutputFormat.java
@@ -30,7 +30,7 @@ public class ExportOutputFormat<K extends SqoopRecord, V>
     extends org.apache.sqoop.mapreduce.ExportOutputFormat<K, V> {
 
   /** {@inheritDoc}. **/
-  public class ExportRecordWriter extends
+  public class ExportRecordWriter<K extends SqoopRecord, V> extends
     org.apache.sqoop.mapreduce.ExportOutputFormat<K, V>.ExportRecordWriter {
 
     public ExportRecordWriter(TaskAttemptContext context)
diff --git a/src/java/org/apache/sqoop/mapreduce/ExportBatchOutputFormat.java b/src/java/org/apache/sqoop/mapreduce/ExportBatchOutputFormat.java
index 20fc844b..bc59eb90 100644
--- a/src/java/org/apache/sqoop/mapreduce/ExportBatchOutputFormat.java
+++ b/src/java/org/apache/sqoop/mapreduce/ExportBatchOutputFormat.java
@@ -45,7 +45,7 @@ public class ExportBatchOutputFormat<K extends SqoopRecord, V>
   public RecordWriter<K, V> getRecordWriter(TaskAttemptContext context)
       throws IOException {
     try {
-      return new ExportBatchRecordWriter(context);
+      return new ExportBatchRecordWriter<K, V>(context);
     } catch (Exception e) {
       throw new IOException(e);
     }
@@ -55,7 +55,8 @@ public RecordWriter<K, V> getRecordWriter(TaskAttemptContext context)
    * RecordWriter to write the output to a row in a database table.
    * The actual database updates are executed in a second thread.
    */
-  public class ExportBatchRecordWriter extends ExportRecordWriter {
+  public class ExportBatchRecordWriter<K extends SqoopRecord, V>
+    extends ExportRecordWriter<K, V> {
 
     public ExportBatchRecordWriter(TaskAttemptContext context)
         throws ClassNotFoundException, SQLException {
diff --git a/src/java/org/apache/sqoop/mapreduce/OracleExportOutputFormat.java b/src/java/org/apache/sqoop/mapreduce/OracleExportOutputFormat.java
index 8e9cf1dd..fb667f66 100644
--- a/src/java/org/apache/sqoop/mapreduce/OracleExportOutputFormat.java
+++ b/src/java/org/apache/sqoop/mapreduce/OracleExportOutputFormat.java
@@ -36,7 +36,7 @@ public class OracleExportOutputFormat<K extends SqoopRecord, V>
   public RecordWriter<K, V> getRecordWriter(TaskAttemptContext context)
       throws IOException {
     try {
-      return new OracleExportRecordWriter(context);
+      return new OracleExportRecordWriter<K, V>(context);
     } catch (Exception e) {
       throw new IOException(e);
     }
@@ -46,7 +46,8 @@ public RecordWriter<K, V> getRecordWriter(TaskAttemptContext context)
    * RecordWriter to write the output to a row in a database table.
    * The actual database updates are executed in a second thread.
    */
-  public class OracleExportRecordWriter extends ExportRecordWriter {
+  public class OracleExportRecordWriter<K extends SqoopRecord, V>
+    extends ExportRecordWriter<K, V> {
 
     public OracleExportRecordWriter(TaskAttemptContext context)
         throws ClassNotFoundException, SQLException {
diff --git a/src/java/org/apache/sqoop/mapreduce/SQLServerExportOutputFormat.java b/src/java/org/apache/sqoop/mapreduce/SQLServerExportOutputFormat.java
index 1b395191..ead7fb2f 100644
--- a/src/java/org/apache/sqoop/mapreduce/SQLServerExportOutputFormat.java
+++ b/src/java/org/apache/sqoop/mapreduce/SQLServerExportOutputFormat.java
@@ -36,7 +36,7 @@ public class SQLServerExportOutputFormat<K extends SqoopRecord, V>
   public RecordWriter<K, V> getRecordWriter(TaskAttemptContext context)
       throws IOException {
     try {
-      return new SQLServerExportRecordWriter(context);
+      return new SQLServerExportRecordWriter<K, V>(context);
     } catch (Exception e) {
       throw new IOException(e);
     }
@@ -46,7 +46,8 @@ public RecordWriter<K, V> getRecordWriter(TaskAttemptContext context)
    * RecordWriter to write the output to a row in a database table.
    * The actual database updates are executed in a second thread.
    */
-  public class SQLServerExportRecordWriter extends ExportRecordWriter {
+  public class SQLServerExportRecordWriter<K extends SqoopRecord, V>
+    extends ExportRecordWriter<K, V> {
 
     public SQLServerExportRecordWriter(TaskAttemptContext context)
         throws ClassNotFoundException, SQLException {
diff --git a/src/java/org/apache/sqoop/mapreduce/sqlserver/SqlServerExportBatchOutputFormat.java b/src/java/org/apache/sqoop/mapreduce/sqlserver/SqlServerExportBatchOutputFormat.java
index f47d475e..cc69d77b 100644
--- a/src/java/org/apache/sqoop/mapreduce/sqlserver/SqlServerExportBatchOutputFormat.java
+++ b/src/java/org/apache/sqoop/mapreduce/sqlserver/SqlServerExportBatchOutputFormat.java
@@ -32,7 +32,7 @@
  * Output format specific for Microsoft SQL Connector.
  */
 public class SqlServerExportBatchOutputFormat<K extends SqoopRecord, V>
-  extends ExportBatchOutputFormat {
+  extends ExportBatchOutputFormat<K, V> {
 
   private static final Log LOG =
     LogFactory.getLog(SqlServerExportBatchOutputFormat.class);
@@ -42,14 +42,15 @@ public class SqlServerExportBatchOutputFormat<K extends SqoopRecord, V>
   public RecordWriter<K, V> getRecordWriter(TaskAttemptContext context)
       throws IOException {
     try {
-      return new SqlServerExportBatchRecordWriter(context);
+      return new SqlServerExportBatchRecordWriter<K, V>(context);
     } catch (Exception e) {
       throw new IOException(e);
     }
   }
 
   /** {@inheritDoc}. */
-  public class SqlServerExportBatchRecordWriter extends ExportBatchRecordWriter{
+  public class SqlServerExportBatchRecordWriter<K extends SqoopRecord, V>
+    extends ExportBatchRecordWriter<K, V>{
 
     public SqlServerExportBatchRecordWriter(TaskAttemptContext context)
         throws ClassNotFoundException, SQLException {