From ea23c9b7a0a9fcd749ef25b827efff87737d9b6e Mon Sep 17 00:00:00 2001 From: Balaji Varadarajan Date: Fri, 3 Aug 2018 16:40:58 -0700 Subject: [PATCH] Minor bug fixes found during testing --- hoodie-cli/src/main/java/com/uber/hoodie/cli/Table.java | 3 ++- .../src/main/java/com/uber/hoodie/io/HoodieCreateHandle.java | 2 +- hoodie-common/src/main/avro/HoodieCommitMetadata.avsc | 5 +++-- 3 files changed, 6 insertions(+), 4 deletions(-) diff --git a/hoodie-cli/src/main/java/com/uber/hoodie/cli/Table.java b/hoodie-cli/src/main/java/com/uber/hoodie/cli/Table.java index d02b7810a..79f1424cb 100644 --- a/hoodie-cli/src/main/java/com/uber/hoodie/cli/Table.java +++ b/hoodie-cli/src/main/java/com/uber/hoodie/cli/Table.java @@ -144,7 +144,8 @@ public class Table implements Iterable> { if (fieldNameToConverterMap.containsKey(fieldName)) { return fieldNameToConverterMap.get(fieldName).apply(row.get(idx)); } - return row.get(idx).toString(); + Object v = row.get(idx); + return v == null ? "null" : v.toString(); }).collect(Collectors.toList()); }).collect(Collectors.toList()); } diff --git a/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieCreateHandle.java b/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieCreateHandle.java index e05e34d2f..a0b232105 100644 --- a/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieCreateHandle.java +++ b/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieCreateHandle.java @@ -75,7 +75,7 @@ public class HoodieCreateHandle extends HoodieIOH throw new HoodieInsertException( "Failed to initialize HoodieStorageWriter for path " + getStorageWriterPath(), e); } - logger.info("New InsertHandle for partition :" + partitionPath); + logger.info("New InsertHandle for partition :" + partitionPath + " with fileId " + fileId); } public HoodieCreateHandle(HoodieWriteConfig config, String commitTime, HoodieTable hoodieTable, diff --git a/hoodie-common/src/main/avro/HoodieCommitMetadata.avsc b/hoodie-common/src/main/avro/HoodieCommitMetadata.avsc index 832b5fc9c..3d41765ff 100644 --- a/hoodie-common/src/main/avro/HoodieCommitMetadata.avsc +++ b/hoodie-common/src/main/avro/HoodieCommitMetadata.avsc @@ -59,7 +59,8 @@ }, { "name":"totalUpdatedRecordsCompacted", - "type":["null","long"] + "type":["null","long"], + "default" : null } ] } @@ -74,4 +75,4 @@ }] } ] -} \ No newline at end of file +}