You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ni...@apache.org on 2016/02/02 01:36:04 UTC
[48/50] [abbrv] samza git commit: SAMZA-857: fix missing break in
RocksDbOptionsHelper#options()
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 <fe...@gmail.com>
Authored: Wed Jan 20 11:12:56 2016 -0800
Committer: Yi Pan (Data Infrastructure) <ni...@gmail.com>
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");
}