samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tao Feng <fengta...@gmail.com>
Subject Review Request 43011: SAMZA-807: Need a configuration variable to ignore SystemStreamPartitionGrouperFactory changes in checkpoint topic
Date Sat, 30 Jan 2016 08:05:48 GMT

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

Review request for samza.


Repository: samza


Description
-------

Add a configuration tunable(job.systemstreampartition.grouper.diff.ignored) to ignore SystemStreamPartitionGrouperFactory
changes in checkpoint topic with default set to false.
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/43011/diff/


Testing
-------

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


Thanks,

Tao Feng


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message