Repository: kudu Updated Branches: refs/heads/master cf38b5218 -> 21a01cff6
Set desiredBlockSize in pbToColumnSchema pbToColumnSchema forgets to set desiredBlockSize; this fixes it. Change-Id: I918a483b6e4bf84db6e6d97e47768f999f6ab880 Reviewed-on: http://gerrit.cloudera.org:8080/4407 Tested-by: Kudu Jenkins Reviewed-by: Jean-Daniel Cryans <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kudu/repo Commit: http://git-wip-us.apache.org/repos/asf/kudu/commit/21a01cff Tree: http://git-wip-us.apache.org/repos/asf/kudu/tree/21a01cff Diff: http://git-wip-us.apache.org/repos/asf/kudu/diff/21a01cff Branch: refs/heads/master Commit: 21a01cff6e0eddc82a519b80a0da3ec7a7ab57ea Parents: cf38b52 Author: Will Berkeley <[email protected]> Authored: Tue Sep 13 18:43:27 2016 -0400 Committer: Jean-Daniel Cryans <[email protected]> Committed: Wed Sep 14 17:56:17 2016 +0000 ---------------------------------------------------------------------- .../src/main/java/org/apache/kudu/client/ProtobufHelper.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kudu/blob/21a01cff/java/kudu-client/src/main/java/org/apache/kudu/client/ProtobufHelper.java ---------------------------------------------------------------------- diff --git a/java/kudu-client/src/main/java/org/apache/kudu/client/ProtobufHelper.java b/java/kudu-client/src/main/java/org/apache/kudu/client/ProtobufHelper.java index 174cdb3..d4ca5b8 100644 --- a/java/kudu-client/src/main/java/org/apache/kudu/client/ProtobufHelper.java +++ b/java/kudu-client/src/main/java/org/apache/kudu/client/ProtobufHelper.java @@ -86,12 +86,14 @@ public class ProtobufHelper { ColumnSchema.Encoding encoding = ColumnSchema.Encoding.valueOf(pb.getEncoding().name()); ColumnSchema.CompressionAlgorithm compressionAlgorithm = ColumnSchema.CompressionAlgorithm.valueOf(pb.getCompression().name()); + int desiredBlockSize = pb.getCfileBlockSize(); return new ColumnSchema.ColumnSchemaBuilder(pb.getName(), type) .key(pb.getIsKey()) .nullable(pb.getIsNullable()) .defaultValue(defaultValue) .encoding(encoding) .compressionAlgorithm(compressionAlgorithm) + .desiredBlockSize(desiredBlockSize) .build(); }
