I'm running the latest master with a small patch of mine allowing for
additional RocksDb config options. I deleted ~/.m2 and gradle cache to
avoid some issues I was running into. After rebuilding Samza, I'm getting
the following exception on all my jobs:
org.apache.samza.SamzaException: Error opening RocksDB store
xxx/Partition_6, received the following exception from RocksDB
org.rocksdb.RocksDBException: Invalid argument: Compression type Snappy is
not linked with the binary.
at
org.apache.samza.storage.kv.RocksDbKeyValueStore$.openDB(RocksDbKeyValueStore.scala:81)
at
org.apache.samza.storage.kv.RocksDbKeyValueStore.db$lzycompute(RocksDbKeyValueStore.scala:103)
at
org.apache.samza.storage.kv.RocksDbKeyValueStore.db(RocksDbKeyValueStore.scala:103)
at
org.apache.samza.storage.kv.RocksDbKeyValueStore.flush(RocksDbKeyValueStore.scala:195)
at
org.apache.samza.storage.kv.LoggedStore.flush(LoggedStore.scala:107)
at
org.apache.samza.storage.kv.SerializedKeyValueStore.flush(SerializedKeyValueStore.scala:117)
at
org.apache.samza.storage.kv.CachedStore.flush(CachedStore.scala:194)
at
org.apache.samza.storage.kv.NullSafeKeyValueStore.flush(NullSafeKeyValueStore.scala:82)
at
org.apache.samza.storage.kv.KeyValueStorageEngine.flush(KeyValueStorageEngine.scala:123)
at
org.apache.samza.storage.kv.KeyValueStorageEngine.close(KeyValueStorageEngine.scala:135)
at
org.apache.samza.storage.kv.KeyValueStorageEngine.stop(KeyValueStorageEngine.scala:129)
at
org.apache.samza.storage.TaskStorageManager$$anonfun$stopStores$2.apply(TaskStorageManager.scala:193)
at
org.apache.samza.storage.TaskStorageManager$$anonfun$stopStores$2.apply(TaskStorageManager.scala:193)
at scala.collection.Iterator$class.foreach(Iterator.scala:727)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
at
scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206)
at
org.apache.samza.storage.TaskStorageManager.stopStores(TaskStorageManager.scala:193)
at
org.apache.samza.storage.TaskStorageManager.stop(TaskStorageManager.scala:197)
at
org.apache.samza.container.TaskInstance.shutdownStores(TaskInstance.scala:203)
at
org.apache.samza.container.SamzaContainer$$anonfun$shutdownStores$2.apply(SamzaContainer.scala:689)
at
org.apache.samza.container.SamzaContainer$$anonfun$shutdownStores$2.apply(SamzaContainer.scala:689)
at scala.collection.Iterator$class.foreach(Iterator.scala:727)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
at
scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206)
at
org.apache.samza.container.SamzaContainer.shutdownStores(SamzaContainer.scala:689)
at
org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:568)
at
org.apache.samza.container.SamzaContainer$.safeMain(SamzaContainer.scala:93)
at
org.apache.samza.container.SamzaContainer$.main(SamzaContainer.scala:67)
at
org.apache.samza.container.SamzaContainer.main(SamzaContainer.scala)
