----------------------------------------------------------- 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
