You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by na...@apache.org on 2016/03/05 08:39:49 UTC
samza git commit: SAMZA-888: SamzaContainer initializes
ExponentialSleepStrategy with randInt that is inclusive of 0
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 <fe...@gmail.com>
Authored: Fri Mar 4 23:36:59 2016 -0800
Committer: Navina <na...@gmail.com>
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