----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33453/ -----------------------------------------------------------
(Updated April 22, 2015, 9:47 p.m.) Review request for samza, Yan Fang, Chris Riccomini, Naveen Somasundaram, and Yi Pan (Data Infrastructure). Summary (updated) ----------------- SAMZA-557 Reuse local state in SamzaContainer on clean shutdown Repository: samza Description ------- Changed default to yarn cwd instead of io.tmpDir and refactored code Diffs ----- samza-core/src/main/scala/org/apache/samza/config/ShellCommandConfig.scala 1a2dd4413f56e53dbeeb47b5637d7b0c50522f02 samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala 720fbdceafc4fe69b048d81a677e874d13e6d22f samza-core/src/main/scala/org/apache/samza/storage/TaskStorageManager.scala f68a7fee24614fce101e91c4f933d9b4e65dda0a samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala 66c2a0dc2e38e21f951727a30f0987776ac52fe2 Diff: https://reviews.apache.org/r/33453/diff/ Testing (updated) ------- Tested locally using hello-samza. Note: you have to set an environment variable LOGGED_STORE_BASE_DIR pointing to the new location to persist the changelog attached stores. Otherwise, it will default to YARN's cwd and will not re-use local state. Thanks, Navina Ramesh
