GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/227
[GEARPUMP-350] Fix the not started app clock
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the commit mess
Github user manuzhang commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/227#discussion_r141988691
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/task/TaskActor.scala ---
@@ -254,6 +254,7 @@ class TaskActor(
c
Github user manuzhang commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/227#discussion_r147024559
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/task/TaskUtil.scala ---
@@ -53,6 +53,10 @@ object TaskUtil {
else t1
Github user manuzhang commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/227#discussion_r147024731
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/task/TaskActor.scala ---
@@ -361,10 +358,11 @@ class TaskActor(
}
Github user manuzhang commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/227#discussion_r147024506
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/task/WatermarkProducer.scala
---
@@ -0,0 +1,21 @@
+/*
+ * Licensed to
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
Github user manuzhang commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/227#discussion_r147024843
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/dsl/task/GroupByTask.scala
---
@@ -27,15 +27,15 @@ import org.apache.gearpump
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(
}
Github user huafengw closed the pull request at:
https://github.com/apache/incubator-gearpump/pull/227
---
