[
https://issues.apache.org/jira/browse/GEARPUMP-249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15747278#comment-15747278
]
ASF GitHub Bot commented on GEARPUMP-249:
-----------------------------------------
Github user codecov-io commented on the issue:
https://github.com/apache/incubator-gearpump/pull/123
## [Current
coverage](https://codecov.io/gh/apache/incubator-gearpump/pull/123?src=pr) is
70.72% (diff: 100%)
> Merging
[#123](https://codecov.io/gh/apache/incubator-gearpump/pull/123?src=pr) into
[master](https://codecov.io/gh/apache/incubator-gearpump/branch/master?src=pr)
will increase coverage by **0.40%**
```diff
@@ master #123 diff @@
==========================================
Files 186 186
Lines 5984 5985 +1
Methods 5472 5475 +3
Messages 0 0
Branches 510 508 -2
==========================================
+ Hits 4208 4233 +25
+ Misses 1776 1752 -24
Partials 0 0
```
> Powered by [Codecov](https://codecov.io?src=pr). Last update
[914eb90...29c730e](https://codecov.io/gh/apache/incubator-gearpump/compare/914eb9008882835fbafd126085f3ebe73bd87c9f...29c730e6df064894798c763a45f45ffbd97c7f8a?src=pr)
> reduce is not executed when following flatMap in Stream DSL
> -----------------------------------------------------------
>
> Key: GEARPUMP-249
> URL: https://issues.apache.org/jira/browse/GEARPUMP-249
> Project: Apache Gearpump
> Issue Type: Bug
> Components: streaming
> Affects Versions: 0.8.2
> Reporter: Manu Zhang
> Assignee: Manu Zhang
>
> The issue can be reproduced if a redundant {{map}} is added between
> {{groupBy}} and {{sum}}
> {code}
> app.source(data.lines.toList, 1, "source").
> // word => (word, count)
> flatMap(line => line.split("[\\s]+")).map((_, 1)).
> // (word, count1), (word, count2) => (word, count1 + count2)
> groupByKey().sum.log
> {code}
> The problem is with {{AndThen#process}} method, where {{flatMap}} is lazily/
> never executed.
> {code}
> override def process(value: IN): TraversableOnce[OUT] = {
> first.process(value).flatMap(second.process)
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
