> On Feb. 3, 2016, 2:36 a.m., Jagadish Venkatraman wrote: > > samza-kafka/src/test/scala/org/apache/samza/checkpoint/kafka/TestKafkaCheckpointManager.scala, > > line 84 > > <https://reviews.apache.org/r/43053/diff/2/?file=1230302#file1230302line84> > > > > nit: failOnTopicValidation.
tnx, fixed. - Boris ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/43053/#review117554 ----------------------------------------------------------- On Feb. 3, 2016, 1:41 a.m., Boris Shkolnik wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/43053/ > ----------------------------------------------------------- > > (Updated Feb. 3, 2016, 1:41 a.m.) > > > Review request for samza. > > > Repository: samza > > > Description > ------- > > We have a validation code that verifies that checkpoint topic has the right > number of partitions (1). > But, in some environments, it is difficult to repair or delete the invalid > topic. > This config will allow to by pass this validation (it will issue a warning > only) and to continue with a checkpoint topic with an incorrect number of > partitions. > The checkpoints are written into partion 0. > > > Diffs > ----- > > samza-core/src/main/scala/org/apache/samza/config/JobConfig.scala > 1a8adae4d30fa198c90e8c177c7f17269c5953cd > > samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala > 787de1f62479a098bf251f072fca03bbf92f7c6d > > samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManagerFactory.scala > 7db894091284794b7f5fac164eb55b5d78184a36 > > samza-kafka/src/main/scala/org/apache/samza/migration/KafkaCheckpointMigration.scala > c6b1fe4bf3c3601502e014d582d86f8ea0850b20 > samza-kafka/src/main/scala/org/apache/samza/util/KafkaUtil.scala > f4311d1cda7c66c66544c5a3ac94a17cae62863a > > samza-kafka/src/test/scala/org/apache/samza/checkpoint/kafka/TestKafkaCheckpointManager.scala > af4051b28df5eeaeaee527a24907a8e66441f743 > > Diff: https://reviews.apache.org/r/43053/diff/ > > > Testing > ------- > > > Thanks, > > Boris Shkolnik > >
