Repository: incubator-gearpump Updated Branches: refs/heads/master 69f900614 -> f634aab41
[GEARPUMP-350] Fix app clock not started Author: manuzhang <[email protected]> Closes #238 from manuzhang/fix_app_not_started. Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/f634aab4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/f634aab4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/f634aab4 Branch: refs/heads/master Commit: f634aab41d88615a4f63834d2f9523588b8ddb19 Parents: 69f9006 Author: manuzhang <[email protected]> Authored: Wed Mar 14 21:31:17 2018 +0800 Committer: manuzhang <[email protected]> Committed: Wed Mar 14 21:31:38 2018 +0800 ---------------------------------------------------------------------- .../src/main/scala/org/apache/gearpump/streaming/task/Task.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/f634aab4/streaming/src/main/scala/org/apache/gearpump/streaming/task/Task.scala ---------------------------------------------------------------------- diff --git a/streaming/src/main/scala/org/apache/gearpump/streaming/task/Task.scala b/streaming/src/main/scala/org/apache/gearpump/streaming/task/Task.scala index b587cc7..8f20300 100644 --- a/streaming/src/main/scala/org/apache/gearpump/streaming/task/Task.scala +++ b/streaming/src/main/scala/org/apache/gearpump/streaming/task/Task.scala @@ -201,6 +201,8 @@ abstract class Task(taskContext: TaskContext, userConf: UserConfig) extends Task LOG.error("Failed! Received unknown message " + "taskId: " + taskId + ", " + msg.toString) } - override def onWatermarkProgress(watermark: Instant): Unit = {} + override def onWatermarkProgress(watermark: Instant): Unit = { + taskContext.updateWatermark(watermark) + } } \ No newline at end of file
