Repository: samza Updated Branches: refs/heads/master 9abcc8eec -> d6051086f
SAMZA-888: SamzaContainer initializes ExponentialSleepStrategy with randInt that is inclusive of 0 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/d6051086 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/d6051086 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/d6051086 Branch: refs/heads/master Commit: d6051086fa09b148e9f7f6572e45e28a996635f7 Parents: 9abcc8e Author: Tao Feng <[email protected]> Authored: Fri Mar 4 23:36:59 2016 -0800 Committer: Navina <[email protected]> Committed: Fri Mar 4 23:37:55 2016 -0800 ---------------------------------------------------------------------- .../src/main/scala/org/apache/samza/container/SamzaContainer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/d6051086/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala index e3d0b6c..bcbc90a 100644 --- a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala +++ b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala @@ -103,7 +103,7 @@ object SamzaContainer extends Logging { * assignments, and returns objects to be used for SamzaContainer's * constructor. */ - def readJobModel(url: String, initialDelayMs: Int = scala.util.Random.nextInt(DEFAULT_READ_JOBMODEL_DELAY_MS)) = { + def readJobModel(url: String, initialDelayMs: Int = scala.util.Random.nextInt(DEFAULT_READ_JOBMODEL_DELAY_MS) + 1) = { info("Fetching configuration from: %s" format url) SamzaObjectMapper .getObjectMapper
