Fix minor bugs in ParquetWriter.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/d08b8b80 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/d08b8b80 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/d08b8b80 Branch: refs/heads/master Commit: d08b8b80880e12d29aa29bd0087c66554db166e4 Parents: b879e42 Author: Steven Phillips <[email protected]> Authored: Thu May 15 12:14:06 2014 -0700 Committer: Steven Phillips <[email protected]> Committed: Thu May 15 15:13:11 2014 -0700 ---------------------------------------------------------------------- .../org/apache/drill/exec/store/parquet/ParquetRecordWriter.java | 4 +++- .../java/org/apache/drill/exec/store/parquet/ParquetWriter.java | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/d08b8b80/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java index 3ba13f4..b26f688 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java @@ -180,6 +180,8 @@ public class ParquetRecordWriter extends ParquetOutputRecordWriter { @Override public void cleanup() throws IOException { - flush(); + if (recordCount > 0) { + flush(); + } } } http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/d08b8b80/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetWriter.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetWriter.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetWriter.java index ea9798a..51e9219 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetWriter.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetWriter.java @@ -68,7 +68,7 @@ public class ParquetWriter extends AbstractWriter { return formatPlugin.getStorageConfig(); } - @JsonProperty("format") + @JsonIgnore public FormatPluginConfig getFormatConfig(){ return formatPlugin.getConfig(); }
