Repository: incubator-samza Updated Branches: refs/heads/master bb82797e9 -> 31c64f671
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/31c64f67 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/31c64f67 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/31c64f67 Branch: refs/heads/master Commit: 31c64f671fb86c66e5130dd06bff3179c2b6605b Parents: bb82797 Author: Chris Riccomini <[email protected]> Authored: Fri Jun 13 09:43:49 2014 -0700 Committer: Chris Riccomini <[email protected]> Committed: Fri Jun 13 09:43:49 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/31c64f67/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 0934ebe..15245d4 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 @@ -200,10 +200,7 @@ class KafkaCheckpointManager( } def start { - if (partitions.contains(new Partition(0))) { - createTopic - } - + createTopic validateTopic }
