Null Pointer exception in Parquet Output
@@ -91,9 +91,9 @@ public class ParquetWriteSupport extends WriteSupport<RowMetaAndData> {
recordConsumer.addBinary(Binary.fromString(valueMeta.getString(valueData)));
break;
}
- }
recordConsumer.endField(field.getTargetFieldName(), i);
}
+ }
recordConsumer.endMessage();
} catch (HopException e) {
throw new RuntimeException("Error writing row to Parquet", e);
