You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@gearpump.apache.org by "yanghua (JIRA)" <ji...@apache.org> on 2017/05/09 03:36:04 UTC

[jira] [Closed] (GEARPUMP-300) java.io.NotSerializableException official DSL version for Wordcount in java

     [ https://issues.apache.org/jira/browse/GEARPUMP-300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

yanghua closed GEARPUMP-300.
----------------------------
    Resolution: Not A Problem

> java.io.NotSerializableException official DSL version for Wordcount in java
> ---------------------------------------------------------------------------
>
>                 Key: GEARPUMP-300
>                 URL: https://issues.apache.org/jira/browse/GEARPUMP-300
>             Project: Apache Gearpump
>          Issue Type: Bug
>            Reporter: yanghua
>
> java.io.NotSerializableException: java.util.ArrayList$Itr
> 	at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184)
> 	at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1548)
> 	at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1509)
> 	at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1432)
> 	at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1178)
> 	at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1548)
> 	at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1509)
> 	at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1432)
> 	at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1178)
> 	at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1548)
> 	at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1509)
> 	at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1432)
> 	at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1178)
> 	at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1548)
> 	at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1509)
> 	at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1432)
> 	at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1178)
> 	at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348)
> 	at akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply$mcV$sp(Serializer.scala:235)
> 	at akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply(Serializer.scala:235)
> 	at akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply(Serializer.scala:235)
> 	at scala.util.DynamicVariable.withValue(DynamicVariable.scala:58)
> 	at akka.serialization.JavaSerializer.toBinary(Serializer.scala:235)
> 	at org.apache.gearpump.cluster.UserConfig.withValue(UserConfig.scala:139)
> 	at org.apache.gearpump.streaming.dsl.plan.DataSourceOp.getProcessor(OP.scala:98)
> 	at org.apache.gearpump.streaming.dsl.plan.Planner$$anonfun$plan$2.apply(Planner.scala:50)
> 	at org.apache.gearpump.streaming.dsl.plan.Planner$$anonfun$plan$2.apply(Planner.scala:50)
> 	at org.apache.gearpump.util.Graph$$anonfun$1.apply(Graph.scala:143)
> 	at org.apache.gearpump.util.Graph$$anonfun$1.apply(Graph.scala:143)
> 	at scala.collection.immutable.List.map(List.scala:277)
> 	at org.apache.gearpump.util.Graph.mapVertex(Graph.scala:143)
> 	at org.apache.gearpump.streaming.dsl.plan.Planner.plan(Planner.scala:50)
> 	at org.apache.gearpump.streaming.dsl.StreamApp.plan(StreamApp.scala:62)
> 	at org.apache.gearpump.streaming.dsl.StreamApp$.streamAppToApplication(StreamApp.scala:74)
> 	at org.apache.gearpump.streaming.dsl.javaapi.JavaStreamApp.run(JavaStreamApp.scala:45)
> 	at com.github.gearpump.demo.WordCount.main(WordCount.java:119)
> 	at com.github.gearpump.demo.WordCount.main(WordCount.java:25)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:498)
> 	at org.apache.gearpump.cluster.main.AppSubmitter$.main(AppSubmitter.scala:87)
> 	at org.apache.gearpump.util.AkkaApp$$anonfun$main$1.apply(AkkaApp.scala:42)
> 	at org.apache.gearpump.util.AkkaApp$$anonfun$main$1.apply(AkkaApp.scala:42)
> 	at scala.util.Try$.apply(Try.scala:192)
> 	at org.apache.gearpump.util.AkkaApp$class.main(AkkaApp.scala:41)
> 	at org.apache.gearpump.cluster.main.AppSubmitter$.main(AppSubmitter.scala:28)
> 	at org.apache.gearpump.cluster.main.Gear$.executeCommand(Gear.scala:40)
> 	at org.apache.gearpump.cluster.main.Gear$.main(Gear.scala:59)
> 	at org.apache.gearpump.cluster.main.Gear.main(Gear.scala)



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)