[NIFI-5891] NiFi record serde throws NPE when decimal field has null value

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Core Framework
• Environment: RHEL 7.5 ; Open JDK 1.8
• Assignee: Unassigned
• Reporter: Gideon Korir
• Created: 11/Dec/18 16:56
• Updated: 13/Dec/18 15:24
• Resolved: 13/Dec/18 15:24

Description

When an incoming record has a null decimal field, NiFiRecordSerDe (
org.apache.hive.streaming) throws an NPE when trying to create a HiveDecimal. This causes the PutHive3Streaming processor to skip the record and log a warning.
 
The lines:

val = HiveDecimal.create(record.getAsDouble(fieldName));

should be changed to something along the lines of:

Double d = record.getAsDouble(fieldName);
val = d == null ? null : HiveRecord.create(d);

The bug is insidious and occurs during Auto-unboxing.

Issue Links

• links to: GitHub Pull Request #3216