diff --git a/src/jvm/cascading/dbmigrate/hadoop/DBInputFormat.java b/src/jvm/cascading/dbmigrate/hadoop/DBInputFormat.java
index 2fb6748..87b141c 100644
--- a/src/jvm/cascading/dbmigrate/hadoop/DBInputFormat.java
+++ b/src/jvm/cascading/dbmigrate/hadoop/DBInputFormat.java
@@ -8,8 +8,6 @@
 import java.io.DataInput;
 import java.io.DataOutput;
 import java.io.IOException;
-import java.math.BigDecimal;
-import java.math.BigInteger;
 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
@@ -119,7 +117,7 @@ public long getPos() throws IOException {
         /** {@inheritDoc} */
         @Override
         public float getProgress() throws IOException {
-            return (pos / (float) split.getLength());
+            return pos / (float) split.getLength();
         }
 
         /** {@inheritDoc} */
@@ -137,10 +135,6 @@ public boolean next(LongWritable key, TupleWrapper value) throws IOException {
                     Object o = results.getObject(i+1);
                     if(o instanceof byte[]) {
                         o = new BytesWritable((byte[]) o);
-                    } else if(o instanceof BigInteger) {
-                        o = ((BigInteger) o).longValue();
-                    } else if (o instanceof BigDecimal) {
-                        o = ((BigDecimal) o).doubleValue();
                     }
                     try {
                         value.tuple.add(o);