[GitHub] incubator-gearpump pull request #227: [GEARPUMP-350] Fix the not started app...

[manuzhang]

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


---