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