Minor bug fixes found during testing
This commit is contained in:
committed by
vinoth chandar
parent
594059a19c
commit
ea23c9b7a0
@@ -144,7 +144,8 @@ public class Table implements Iterable<List<String>> {
|
|||||||
if (fieldNameToConverterMap.containsKey(fieldName)) {
|
if (fieldNameToConverterMap.containsKey(fieldName)) {
|
||||||
return fieldNameToConverterMap.get(fieldName).apply(row.get(idx));
|
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());
|
||||||
}).collect(Collectors.toList());
|
}).collect(Collectors.toList());
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -75,7 +75,7 @@ public class HoodieCreateHandle<T extends HoodieRecordPayload> extends HoodieIOH
|
|||||||
throw new HoodieInsertException(
|
throw new HoodieInsertException(
|
||||||
"Failed to initialize HoodieStorageWriter for path " + getStorageWriterPath(), e);
|
"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<T> hoodieTable,
|
public HoodieCreateHandle(HoodieWriteConfig config, String commitTime, HoodieTable<T> hoodieTable,
|
||||||
|
|||||||
@@ -59,7 +59,8 @@
|
|||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name":"totalUpdatedRecordsCompacted",
|
"name":"totalUpdatedRecordsCompacted",
|
||||||
"type":["null","long"]
|
"type":["null","long"],
|
||||||
|
"default" : null
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
@@ -74,4 +75,4 @@
|
|||||||
}]
|
}]
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user