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

2017-04-28 Thread Vincent Wang 
Hi Yanghua, can you describe a little about how to reproduce this exception?

yanghua (JIRA) 于2017年4月28日周五 上午8:45写道：

>
> [
> https://issues.apache.org/jira/browse/GEARPUMP-300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15987957#comment-15987957
> ]
>
> yanghua commented on GEARPUMP-300:
> --
>
> I try to find the problem, in source code :
> https://github.com/apache/incubator-gearpump/blob/master/streaming/src/main/scala/org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.scala#L94
>  here need a Iterator and will be serialized.
> And in JavaStreamApp it seams if pass a ArrayList‘s instance it will use
> ArrayList's inner Itr(Iterator's implementation),
>
> https://github.com/apache/incubator-gearpump/blob/master/streaming/src/main/scala/org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.scala#L36
>  but Itr is not serializable.
>
> > 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
>

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

2017-04-27 Thread yanghua (JIRA) 

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

yanghua commented on GEARPUMP-300:
--

I try to find the problem, in source code : 
https://github.com/apache/incubator-gearpump/blob/master/streaming/src/main/scala/org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.scala#L94
 here need a Iterator and will be serialized.
And in JavaStreamApp it seams if pass a ArrayList‘s instance it will use 
ArrayList's inner Itr(Iterator's implementation),
https://github.com/apache/incubator-gearpump/blob/master/streaming/src/main/scala/org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.scala#L36
 but Itr is not serializable.

> 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)
>

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

2017-04-27 Thread yanghua (JIRA) 

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

yanghua commented on GEARPUMP-300:
--

hi the exception happens in gearpump version 0.8.2 and I used the same version 
dependencies to write the demo. And I just test gearpump 0.8.3 and the 
exception always exists.

> 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

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

2017-04-27 Thread Karol Brejna (JIRA) 

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

Karol Brejna commented on GEARPUMP-300:
---

[~yanghua] Actually, we are right now in a process of publishing new release 
(0.8.3) that should have the fix.

For now, you can find a binary of new version here: 
https://dist.apache.org/repos/dist/dev/incubator/gearpump/0.8.3-incubating/RC1/
(https://dist.apache.org/repos/dist/dev/incubator/gearpump/0.8.3-incubating/RC1/gearpump_2.11-0.8.3-incubating-bin.tgz)

Hopefully, very soon it will be published "officially"...

> 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 
>

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

2017-04-27 Thread Karol Brejna (JIRA) 

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

Karol Brejna commented on GEARPUMP-300:
---

Probably something similar to https://issues.apache.org/jira/browse/GEARPUMP-247

> 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)