[
https://issues.apache.org/jira/browse/GEARPUMP-350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16219801#comment-16219801
]
ASF GitHub Bot commented on GEARPUMP-350:
-----------------------------------------
Github user manuzhang commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/227#discussion_r147025062
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/dsl/task/GroupByTask.scala
---
@@ -27,15 +27,15 @@ import org.apache.gearpump.cluster.UserConfig
import
org.apache.gearpump.streaming.Constants.{GEARPUMP_STREAMING_GROUPBY_FUNCTION,
GEARPUMP_STREAMING_OPERATOR}
import org.apache.gearpump.streaming.dsl.window.impl.{TimestampedValue,
WindowRunner}
import org.apache.gearpump.streaming.source.Watermark
-import org.apache.gearpump.streaming.task.{Task, TaskContext, TaskUtil}
+import org.apache.gearpump.streaming.task.{Task, TaskContext, TaskUtil,
WatermarkProducer}
/**
* Processes messages in groups as defined by groupBy function.
*/
class GroupByTask[IN, GROUP, OUT](
groupBy: IN => GROUP,
taskContext: TaskContext,
- userConfig: UserConfig) extends Task(taskContext, userConfig) {
+ userConfig: UserConfig) extends Task(taskContext, userConfig) with
WatermarkProducer {
--- End diff --
And only `GroupByTask` ?
> the app Clock is not started
> ----------------------------
>
> Key: GEARPUMP-350
> URL: https://issues.apache.org/jira/browse/GEARPUMP-350
> Project: Apache Gearpump
> Issue Type: Bug
> Affects Versions: 0.8.4
> Reporter: Pan Xue
> Attachments: gearpump0.8.4.PNG
>
>
> When I submitted an app in the web, in the DAG display page, I found that
> the application clock has been not started, the source processor's color will
> turn red, I use the example is 0.8.4 version of the example / wordcount
> !gearpump0.8.4.PNG|thumbnail!
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
