SAMZA-1083 Do not load task stores which are older than delete tombstones during...
authorShanthoosh Venkataraman <santhoshvenkat1988@gmail.com>
Thu, 9 Feb 2017 00:07:27 +0000 (16:07 -0800)
committerJacob Maes <jmaes@linkedin.com>
Thu, 9 Feb 2017 00:07:27 +0000 (16:07 -0800)
commit38b1dc38dfc0b71df5dd5ca983c4c668a6cc20be
tree5b4c9a8dba3b760ce56a731ada6abd14163f9d2c
parente57b4a342b4b60c1b8f8db1d088325921814b207
SAMZA-1083 Do not load task stores which are older than delete tombstones during container startup
samza-core/src/main/java/org/apache/samza/storage/StorageRecovery.java
samza-core/src/main/scala/org/apache/samza/config/StorageConfig.scala
samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
samza-core/src/main/scala/org/apache/samza/storage/TaskStorageManager.scala
samza-core/src/test/scala/org/apache/samza/storage/TestTaskStorageManager.scala
samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala