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 +}