[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)
[GitHub] incubator-gearpump pull request #178: [GEARPUMP-303] add a RabbitMQ sink to ...
Github user yanghua closed the pull request at: https://github.com/apache/incubator-gearpump/pull/178 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] incubator-gearpump pull request #181: [GEARPUMP-305] Add Internals section t...
GitHub user manuzhang opened a pull request: https://github.com/apache/incubator-gearpump/pull/181 [GEARPUMP-305] Add Internals section to docs Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the commit message is formatted like: `[GEARPUMP-] Meaningful description of pull request` - [ ] Make sure tests pass via `sbt clean test`. - [ ] Make sure old documentation affected by the pull request has been updated and new documentation added for new functionality. You can merge this pull request into a Git repository by running: $ git pull https://github.com/manuzhang/incubator-gearpump doc Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-gearpump/pull/181.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #181 commit 6edd7a241ed3edec3f6acc0073e4586895753e46 Author: manuzhang Date: 2017-05-08T05:35:13Z [GEARPUMP-305] Add Internals section to docs --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] incubator-gearpump issue #181: [GEARPUMP-305] Add Internals section to docs
Github user huafengw commented on the issue: https://github.com/apache/incubator-gearpump/pull/181 +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] incubator-gearpump issue #181: [GEARPUMP-305] Add Internals section to docs
Github user codecov-io commented on the issue: https://github.com/apache/incubator-gearpump/pull/181 # [Codecov](https://codecov.io/gh/apache/incubator-gearpump/pull/181?src=pr&el=h1) Report > Merging [#181](https://codecov.io/gh/apache/incubator-gearpump/pull/181?src=pr&el=desc) into [master](https://codecov.io/gh/apache/incubator-gearpump/commit/9798863753dac06077ce23bef5f451bf7fdca619?src=pr&el=desc) will **decrease** coverage by `0.01%`. > The diff coverage is `n/a`. ```diff @@Coverage Diff @@ ## master #181 +/- ## == - Coverage 71.63% 71.62% -0.02% == Files 191 191 Lines6086 6086 Branches 527 527 == - Hits 4360 4359 -1 - Misses 1726 1727 +1 ``` --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] incubator-gearpump pull request #181: [GEARPUMP-305] Add Internals section t...
Github user asfgit closed the pull request at: https://github.com/apache/incubator-gearpump/pull/181 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] incubator-gearpump pull request #180: [GEARPUMP-303] add a RabbitMQ sink to ...
Github user asfgit closed the pull request at: https://github.com/apache/incubator-gearpump/pull/180 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] incubator-gearpump issue #180: [GEARPUMP-303] add a RabbitMQ sink to integra...
Github user huafengw commented on the issue: https://github.com/apache/incubator-gearpump/pull/180 +1, merging, thanks @yanghua for contributing! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[jira] [Closed] (GEARPUMP-304) add a ElasticSearch sink to integrate with gearpump
[ https://issues.apache.org/jira/browse/GEARPUMP-304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanghua closed GEARPUMP-304. Resolution: Duplicate > add a ElasticSearch sink to integrate with gearpump > --- > > Key: GEARPUMP-304 > URL: https://issues.apache.org/jira/browse/GEARPUMP-304 > Project: Apache Gearpump > Issue Type: Task > Components: connectors >Reporter: yanghua >Assignee: yanghua > > let the sinked messages could be built full-text indices. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (GEARPUMP-304) add a ElasticSearch sink to integrate with gearpump
[ https://issues.apache.org/jira/browse/GEARPUMP-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000874#comment-16000874 ] yanghua commented on GEARPUMP-304: -- [~karol_brejna] sorry, it's my problem. I have not checked your issues exists when I create it. I will close this issue. > add a ElasticSearch sink to integrate with gearpump > --- > > Key: GEARPUMP-304 > URL: https://issues.apache.org/jira/browse/GEARPUMP-304 > Project: Apache Gearpump > Issue Type: Task > Components: connectors >Reporter: yanghua >Assignee: yanghua > > let the sinked messages could be built full-text indices. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Comment Edited] (GEARPUMP-284) Oauth2 tests fail
[ https://issues.apache.org/jira/browse/GEARPUMP-284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000380#comment-16000380 ] Karol Brejna edited comment on GEARPUMP-284 at 5/8/17 8:51 AM: --- [~mauzhang] Let me try to check it. I'll get back with results tomorrow. was (Author: karol_brejna): [~mauzhang] Let me try to fix it. I'll get back with results tomorrow. > Oauth2 tests fail > - > > Key: GEARPUMP-284 > URL: https://issues.apache.org/jira/browse/GEARPUMP-284 > Project: Apache Gearpump > Issue Type: Bug > Components: services >Affects Versions: 0.8.2 >Reporter: Karol Brejna >Assignee: Karol Brejna > Original Estimate: 6h > Remaining Estimate: 6h > > Running tests show that oauth2 tests fail. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (GEARPUMP-304) add a ElasticSearch sink to integrate with gearpump
[ https://issues.apache.org/jira/browse/GEARPUMP-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000389#comment-16000389 ] Karol Brejna commented on GEARPUMP-304: --- [~mauzhang] Yes, I had a working ElasticSearch sink and was a bit stuck with an example (conflicting dependencies). [~yanghua] There is already a ticket for this: https://issues.apache.org/jira/browse/GEARPUMP-167 Please, hold on your work on this for a day or two. I'll dig out my latest code and share with you. We can discuss if we should continue with that or start over. What do you think? > add a ElasticSearch sink to integrate with gearpump > --- > > Key: GEARPUMP-304 > URL: https://issues.apache.org/jira/browse/GEARPUMP-304 > Project: Apache Gearpump > Issue Type: Task > Components: connectors >Reporter: yanghua >Assignee: yanghua > > let the sinked messages could be built full-text indices. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (GEARPUMP-284) Oauth2 tests fail
[ https://issues.apache.org/jira/browse/GEARPUMP-284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000380#comment-16000380 ] Karol Brejna commented on GEARPUMP-284: --- [~mauzhang] Let me try to fix it. I'll get back with results tomorrow. > Oauth2 tests fail > - > > Key: GEARPUMP-284 > URL: https://issues.apache.org/jira/browse/GEARPUMP-284 > Project: Apache Gearpump > Issue Type: Bug > Components: services >Affects Versions: 0.8.2 >Reporter: Karol Brejna >Assignee: Karol Brejna > Original Estimate: 6h > Remaining Estimate: 6h > > Running tests show that oauth2 tests fail. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (GEARPUMP-303) add a RabbitMQ sink to integrate with gearpump
[ https://issues.apache.org/jira/browse/GEARPUMP-303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000359#comment-16000359 ] ASF GitHub Bot commented on GEARPUMP-303: - Github user asfgit closed the pull request at: https://github.com/apache/incubator-gearpump/pull/180 > add a RabbitMQ sink to integrate with gearpump > -- > > Key: GEARPUMP-303 > URL: https://issues.apache.org/jira/browse/GEARPUMP-303 > Project: Apache Gearpump > Issue Type: Task > Components: connectors >Reporter: yanghua >Assignee: yanghua > -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (GEARPUMP-303) add a RabbitMQ sink to integrate with gearpump
[ https://issues.apache.org/jira/browse/GEARPUMP-303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000357#comment-16000357 ] ASF GitHub Bot commented on GEARPUMP-303: - Github user huafengw commented on the issue: https://github.com/apache/incubator-gearpump/pull/180 +1, merging, thanks @yanghua for contributing! > add a RabbitMQ sink to integrate with gearpump > -- > > Key: GEARPUMP-303 > URL: https://issues.apache.org/jira/browse/GEARPUMP-303 > Project: Apache Gearpump > Issue Type: Task > Components: connectors >Reporter: yanghua >Assignee: yanghua > -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (GEARPUMP-305) Documentation Improvement
[ https://issues.apache.org/jira/browse/GEARPUMP-305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000356#comment-16000356 ] ASF GitHub Bot commented on GEARPUMP-305: - Github user asfgit closed the pull request at: https://github.com/apache/incubator-gearpump/pull/181 > Documentation Improvement > - > > Key: GEARPUMP-305 > URL: https://issues.apache.org/jira/browse/GEARPUMP-305 > Project: Apache Gearpump > Issue Type: Improvement > Components: doc >Reporter: Manu Zhang >Assignee: Manu Zhang > -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (GEARPUMP-305) Documentation Improvement
[ https://issues.apache.org/jira/browse/GEARPUMP-305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000353#comment-16000353 ] ASF GitHub Bot commented on GEARPUMP-305: - Github user huafengw commented on the issue: https://github.com/apache/incubator-gearpump/pull/181 +1 > Documentation Improvement > - > > Key: GEARPUMP-305 > URL: https://issues.apache.org/jira/browse/GEARPUMP-305 > Project: Apache Gearpump > Issue Type: Improvement > Components: doc >Reporter: Manu Zhang >Assignee: Manu Zhang > -- This message was sent by Atlassian JIRA (v6.3.15#6346)
