java.lang.NullPointerException: Name is null
at java.lang.Enum.valueOf(Enum.java:236)
at
org.apache.parquet.hadoop.metadata.CompressionCodecName.valueOf(CompressionCodecName.java:26)
at
org.apache.nifi.parquet.utils.ParquetUtils.createParquetConfig(ParquetUtils.java:172)
at
org.apache.nifi.parquet.ParquetReader.createRecordReader(ParquetReader.java:48)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:254)
at
org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:105)
at com.sun.proxy.$Proxy190.createRecordReader(Unknown Source)
at
org.apache.nifi.processors.standard.SplitRecord$1.process(SplitRecord.java:156)
I think it's because I forgot to set the schema write strategy on the
ParquetRecordSetWriter to be "write schema." Is there a workaround for
this?
Thanks,
Mike