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