Repository: incubator-samza Updated Branches: refs/heads/master f076c33c1 -> 783b05a63
SAMZA-266; allow empty checkpoint factory config Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/783b05a6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/783b05a6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/783b05a6 Branch: refs/heads/master Commit: 783b05a637465eef4a177beabbc3e116a7353b37 Parents: f076c33 Author: Yan Fang <[email protected]> Authored: Tue May 20 09:26:53 2014 -0700 Committer: Chris Riccomini <[email protected]> Committed: Tue May 20 09:26:53 2014 -0700 ---------------------------------------------------------------------- .../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/incubator-samza/blob/783b05a6/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 24364f4..9b967b5 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 @@ -267,7 +267,7 @@ object SamzaContainer extends Logging { info("Got metrics reporters: %s" format reporters.keys) val checkpointManager = config.getCheckpointManagerFactory match { - case Some(checkpointFactoryClassName) => + case Some(checkpointFactoryClassName) if (!checkpointFactoryClassName.isEmpty) => Util .getObj[CheckpointManagerFactory](checkpointFactoryClassName) .getCheckpointManager(config, samzaContainerMetrics.registry)
