Options
Apache Storm and vertica error
I am trying to use Apache Storm inorder to push data onto vertica using VerticaJDBC driver,
but facing the following error as below, ERROR org.apache.zookeeper.server.NIOServerCnxnFactory - Thread Thread[main,5,main] died java.lang.RuntimeException: java.io.NotSerializableException: com.vertica.jdbc.VerticaConnectionImpl at backtype.storm.utils.Utils.serialize(Utils.java:81) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.topology.TopologyBuilder.createTopology(TopologyBuilder.java:106) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at com.wordcount.example.HelloStorm.main(HelloStorm.java:21) ~[bin/:na] Caused by: java.io.NotSerializableException: com.vertica.jdbc.VerticaConnectionImpl at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1183) ~[na:1.7.0_51] at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1547) ~[na:1.7.0_51] at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1508) ~[na:1.7.0_51] at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1431) ~[na:1.7.0_51] at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1177) ~[na:1.7.0_51] at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:347) ~[na:1.7.0_51] at backtype.storm.utils.Utils.serialize(Utils.java:77) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] ... 2 common frames omitted .
Is there any way to change the code of this com.vertica.jdbc.VerticaConnectionImpl to implement Serializable.
or any other work around or have anybody tried to do the same??
but facing the following error as below, ERROR org.apache.zookeeper.server.NIOServerCnxnFactory - Thread Thread[main,5,main] died java.lang.RuntimeException: java.io.NotSerializableException: com.vertica.jdbc.VerticaConnectionImpl at backtype.storm.utils.Utils.serialize(Utils.java:81) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.topology.TopologyBuilder.createTopology(TopologyBuilder.java:106) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at com.wordcount.example.HelloStorm.main(HelloStorm.java:21) ~[bin/:na] Caused by: java.io.NotSerializableException: com.vertica.jdbc.VerticaConnectionImpl at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1183) ~[na:1.7.0_51] at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1547) ~[na:1.7.0_51] at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1508) ~[na:1.7.0_51] at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1431) ~[na:1.7.0_51] at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1177) ~[na:1.7.0_51] at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:347) ~[na:1.7.0_51] at backtype.storm.utils.Utils.serialize(Utils.java:77) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] ... 2 common frames omitted .
Is there any way to change the code of this com.vertica.jdbc.VerticaConnectionImpl to implement Serializable.
or any other work around or have anybody tried to do the same??
0