drill-dev mailing list archives

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 <sphillips@maprtech.com>
Authored: Thu May 15 12:14:06 2014 -0700
Committer: Steven Phillips <sphillips@maprtech.com>
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();
   }