You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2018/01/22 22:04:27 UTC
samza git commit: upTime should be field not method
Repository: samza
Updated Branches:
refs/heads/master 24d22bb80 -> d6686b0f0
upTime should be field not method
Author: zhangyijun <jo...@gmail.com>
Reviewers: Jagadish <ja...@apache.org>
Closes #9 from zhangyijun/patch-1
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/d6686b0f
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/d6686b0f
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/d6686b0f
Branch: refs/heads/master
Commit: d6686b0f02a7f16eabdcec5b4fb83f41461829fc
Parents: 24d22bb
Author: zhangyijun <jo...@gmail.com>
Authored: Mon Jan 22 14:05:51 2018 -0800
Committer: Jagadish <jv...@linkedin.com>
Committed: Mon Jan 22 14:05:51 2018 -0800
----------------------------------------------------------------------
.../src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/d6686b0f/samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala
----------------------------------------------------------------------
diff --git a/samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala b/samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala
index 7ab866f..abecab3 100644
--- a/samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala
+++ b/samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala
@@ -41,7 +41,7 @@ class YarnContainer(container: Container) {
val startTime = System.currentTimeMillis()
def startTimeStr(dtFormatter: Option[DateTimeFormatter] = None) =
dtFormatter.getOrElse(YarnContainerUtils.dateFormater).print(startTime)
- def upTime = System.currentTimeMillis()
+ val upTime = System.currentTimeMillis()
def upTimeStr(periodFormatter: Option[PeriodFormatter] = None) =
periodFormatter.getOrElse(YarnContainerUtils.periodFormater).print(new Period(startTime, upTime))
-}
\ No newline at end of file
+}