You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2014/06/13 18:44:02 UTC
git commit: SAMZA-289;
fix race condition that makes jobs fail with invalid checkpoint topic
partition count
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 <cr...@criccomi-mn.linkedin.biz>
Authored: Fri Jun 13 09:43:49 2014 -0700
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
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
}