Repository: incubator-samza Updated Branches: refs/heads/0.7.0 d089d344d -> c06b9bc06
SAMZA-289; fix race condition that makes jobs fail with invalid checkpoint topic partition count Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/c06b9bc0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/c06b9bc0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/c06b9bc0 Branch: refs/heads/0.7.0 Commit: c06b9bc06763b68d7fd71443010dc8af3637392d Parents: d089d34 Author: Chris Riccomini <[email protected]> Authored: Fri Jun 13 09:43:49 2014 -0700 Committer: Chris Riccomini <[email protected]> Committed: Fri Jun 13 09:44:21 2014 -0700 ---------------------------------------------------------------------- .../apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/c06b9bc0/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala ---------------------------------------------------------------------- diff --git a/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala b/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala index d5f7957..ad8ed3a 100644 --- a/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala +++ b/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala @@ -194,10 +194,7 @@ class KafkaCheckpointManager( } def start { - if (partitions.contains(new Partition(0))) { - createTopic - } - + createTopic validateTopic }
