SAMZA-857: fix missing break in RocksDbOptionsHelper#options()
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/fc303e55 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/fc303e55 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/fc303e55 Branch: refs/heads/samza-sql Commit: fc303e55955d6a4eeb4cbf17c229141b6e54ccaf Parents: 95ba041 Author: Tao Feng <[email protected]> Authored: Wed Jan 20 11:12:56 2016 -0800 Committer: Yi Pan (Data Infrastructure) <[email protected]> Committed: Wed Jan 20 11:12:56 2016 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/fc303e55/samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java ---------------------------------------------------------------------- diff --git a/samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java b/samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java index e474231..d4f765c 100644 --- a/samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java +++ b/samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java @@ -61,6 +61,7 @@ public class RocksDbOptionsHelper { break; case "none": compressionType = CompressionType.NO_COMPRESSION; + break; default: log.warn("Unknown rocksdb.compression codec " + compressionInConfig + ", overwriting to Snappy"); }
