DBSource throws ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long
Description
This was using the MySql JDBC jar.
java.lang.Exception: java.lang.ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long
at org.apache.hadoop.mapred.LocalJobRunnerWithFix$Job.runTasks(LocalJobRunnerWithFix.java:465) ~[co.cask.cdap.cdap-app-fabric-3.6.0.jar:na]
at org.apache.hadoop.mapred.LocalJobRunnerWithFix$Job.run(LocalJobRunnerWithFix.java:524) ~[co.cask.cdap.cdap-app-fabric-3.6.0.jar:na]
Caused by: java.lang.ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long
at co.cask.cdap.format.RecordPutTransformer.createPut(RecordPutTransformer.java:156) ~[cdap-formats-3.6.0.jar:na]
at co.cask.cdap.format.RecordPutTransformer.toPut(RecordPutTransformer.java:72) ~[cdap-formats-3.6.0.jar:na]
at co.cask.hydrator.plugin.batch.sink.TableSink.transform(TableSink.java:95) ~[1479409220874-0/:na]
at co.cask.hydrator.plugin.batch.sink.TableSink.transform(TableSink.java:43) ~[1479409220874-0/:na]
at co.cask.cdap.etl.batch.KVTransformations$KVSinkTransformation.transform(KVTransformations.java:123) ~[cdap-etl-batch-3.6.0.jar:na]
at co.cask.cdap.etl.batch.KVTransformations$KVSinkTransformation.transform(KVTransformations.java:111) ~[cdap-etl-batch-3.6.0.jar:na]
at co.cask.cdap.etl.common.TrackedTransform.transform(TrackedTransform.java:58) ~[cdap-etl-core-3.6.0.jar:na]
at co.cask.cdap.etl.common.TransformExecutor.executeTransformation(TransformExecutor.java:88) ~[cdap-etl-core-3.6.0.jar:na]
at co.cask.cdap.etl.common.TransformExecutor.executeTransformation(TransformExecutor.java:93) ~[cdap-etl-core-3.6.0.jar:na]
at co.cask.cdap.etl.common.TransformExecutor.executeTransformation(TransformExecutor.java:93) ~[cdap-etl-core-3.6.0.jar:na]
at co.cask.cdap.etl.common.TransformExecutor.runOneIteration(TransformExecutor.java:50) ~[cdap-etl-core-3.6.0.jar:na]
at co.cask.cdap.etl.batch.mapreduce.TransformRunner.transform(TransformRunner.java:165) ~[cdap-etl-batch-3.6.0.jar:na]
at co.cask.cdap.etl.batch.mapreduce.ETLMapReduce$ETLMapper.map(ETLMapReduce.java:356) ~[cdap-etl-batch-3.6.0.jar:na]
at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:145) ~[org.apache.hadoop.hadoop-mapreduce-client-core-2.3.0.jar:na]
at co.cask.cdap.internal.app.runtime.batch.MapperWrapper.run(MapperWrapper.java:117) ~[co.cask.cdap.cdap-app-fabric-3.6.0.jar:na]
at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:764) ~[org.apache.hadoop.hadoop-mapreduce-client-core-2.3.0.jar:na]
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:340) ~[org.apache.hadoop.hadoop-mapreduce-client-core-2.3.0.jar:na]
at org.apache.hadoop.mapred.LocalJobRunnerWithFix$Job$MapTaskRunnable.run(LocalJobRunnerWithFix.java:243) ~[co.cask.cdap.cdap-app-fabric-3.6.0.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) ~[na:1.7.0_75]
at java.util.concurrent.FutureTask.run(FutureTask.java:262) ~[na:1.7.0_75]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) ~[na:1.7.0_75]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) ~[na:1.7.0_75]
at java.lang.Thread.run(Thread.java:745) ~[na:1.7.0_75]
This was using the MySql JDBC jar.
java.lang.Exception: java.lang.ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long at org.apache.hadoop.mapred.LocalJobRunnerWithFix$Job.runTasks(LocalJobRunnerWithFix.java:465) ~[co.cask.cdap.cdap-app-fabric-3.6.0.jar:na] at org.apache.hadoop.mapred.LocalJobRunnerWithFix$Job.run(LocalJobRunnerWithFix.java:524) ~[co.cask.cdap.cdap-app-fabric-3.6.0.jar:na] Caused by: java.lang.ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long at co.cask.cdap.format.RecordPutTransformer.createPut(RecordPutTransformer.java:156) ~[cdap-formats-3.6.0.jar:na] at co.cask.cdap.format.RecordPutTransformer.toPut(RecordPutTransformer.java:72) ~[cdap-formats-3.6.0.jar:na] at co.cask.hydrator.plugin.batch.sink.TableSink.transform(TableSink.java:95) ~[1479409220874-0/:na] at co.cask.hydrator.plugin.batch.sink.TableSink.transform(TableSink.java:43) ~[1479409220874-0/:na] at co.cask.cdap.etl.batch.KVTransformations$KVSinkTransformation.transform(KVTransformations.java:123) ~[cdap-etl-batch-3.6.0.jar:na] at co.cask.cdap.etl.batch.KVTransformations$KVSinkTransformation.transform(KVTransformations.java:111) ~[cdap-etl-batch-3.6.0.jar:na] at co.cask.cdap.etl.common.TrackedTransform.transform(TrackedTransform.java:58) ~[cdap-etl-core-3.6.0.jar:na] at co.cask.cdap.etl.common.TransformExecutor.executeTransformation(TransformExecutor.java:88) ~[cdap-etl-core-3.6.0.jar:na] at co.cask.cdap.etl.common.TransformExecutor.executeTransformation(TransformExecutor.java:93) ~[cdap-etl-core-3.6.0.jar:na] at co.cask.cdap.etl.common.TransformExecutor.executeTransformation(TransformExecutor.java:93) ~[cdap-etl-core-3.6.0.jar:na] at co.cask.cdap.etl.common.TransformExecutor.runOneIteration(TransformExecutor.java:50) ~[cdap-etl-core-3.6.0.jar:na] at co.cask.cdap.etl.batch.mapreduce.TransformRunner.transform(TransformRunner.java:165) ~[cdap-etl-batch-3.6.0.jar:na] at co.cask.cdap.etl.batch.mapreduce.ETLMapReduce$ETLMapper.map(ETLMapReduce.java:356) ~[cdap-etl-batch-3.6.0.jar:na] at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:145) ~[org.apache.hadoop.hadoop-mapreduce-client-core-2.3.0.jar:na] at co.cask.cdap.internal.app.runtime.batch.MapperWrapper.run(MapperWrapper.java:117) ~[co.cask.cdap.cdap-app-fabric-3.6.0.jar:na] at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:764) ~[org.apache.hadoop.hadoop-mapreduce-client-core-2.3.0.jar:na] at org.apache.hadoop.mapred.MapTask.run(MapTask.java:340) ~[org.apache.hadoop.hadoop-mapreduce-client-core-2.3.0.jar:na] at org.apache.hadoop.mapred.LocalJobRunnerWithFix$Job$MapTaskRunnable.run(LocalJobRunnerWithFix.java:243) ~[co.cask.cdap.cdap-app-fabric-3.6.0.jar:na] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) ~[na:1.7.0_75] at java.util.concurrent.FutureTask.run(FutureTask.java:262) ~[na:1.7.0_75] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) ~[na:1.7.0_75] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) ~[na:1.7.0_75] at java.lang.Thread.run(Thread.java:745) ~[na:1.7.0_75]