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

[huafengw]

Github user huafengw commented on a diff in the pull request:

    https://github.com/apache/incubator-gearpump/pull/227#discussion_r147065810
  
    --- Diff: 
streaming/src/main/scala/org/apache/gearpump/streaming/task/TaskActor.scala ---
    @@ -361,10 +358,11 @@ class TaskActor(
       }
     
       private def getSubscriptionWatermark(subs: List[(Int, Subscription)], 
wmk: Instant): Instant = {
    +    val wmkInMilli = wmk.toEpochMilli
    --- End diff --
    
    To avoid multiple `toEpochMilli` calls


---