You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@samza.apache.org by Tao Feng <fe...@gmail.com> on 2016/01/30 09:00:02 UTC

Review Request 43010: SAMZA-807: Need a configuration variable to ignore SystemStreamPartitionGrouperFactory changes in checkpoint topic

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/43010/
-----------------------------------------------------------

Review request for samza.


Repository: samza


Description
-------

1. Add a configuration tunable(job.systemstreampartition.grouper.diff.ignored) to ignore SystemStreamPartitionGrouperFactory changes in checkpoint topic with default set to false.
2. Add unit test


Diffs
-----

  docs/learn/documentation/versioned/jobs/configuration-table.html 67055307329c81c9347f1de352420a48a63634b4 
  samza-core/src/main/scala/org/apache/samza/config/JobConfig.scala 1a8adae4d30fa198c90e8c177c7f17269c5953cd 
  samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.scala ea8462dc10d0c98fe99215e6b6b9d59cce4bcffa 
  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/test/scala/org/apache/samza/checkpoint/kafka/TeskKafkaCheckpointLogKey.scala c360b6c74ff924311f350df2e49424351a5c8d07 
  samza-kafka/src/test/scala/org/apache/samza/checkpoint/kafka/TestKafkaCheckpointManager.scala af4051b28df5eeaeaee527a24907a8e66441f743 

Diff: https://reviews.apache.org/r/43010/diff/


Testing
-------

./gradlew clean build && ./gradlew checkstyleMain checkstyleTest


Thanks,

Tao Feng