Hi Zhenqiu, I tried to read a parquet file using the code in your PR, and got the following error when reading a column of type timestamp (nullable = true).
Thanks and best regards, ``` Caused by: java.lang.IllegalArgumentException: Can not set java.math.BigInteger field ... to java.lang.String at sun.reflect.UnsafeFieldAccessorImpl.throwSetIllegalArgumentException(UnsafeFieldAccessorImpl.java:167) at sun.reflect.UnsafeFieldAccessorImpl.throwSetIllegalArgumentException(UnsafeFieldAccessorImpl.java:171) at sun.reflect.UnsafeObjectFieldAccessorImpl.set(UnsafeObjectFieldAccessorImpl.java:81) at java.lang.reflect.Field.set(Field.java:764) at org.apache.flink.formats.parquet.ParquetPojoInputFormat.convert(ParquetPojoInputFormat.java:96) at org.apache.flink.formats.parquet.ParquetInputFormat.nextRecord(ParquetInputFormat.java:159) at org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator$SplitReader.run(ContinuousFileReaderOperator.java:323) ``` [ Full content available at: https://github.com/apache/flink/pull/6483 ] This message was relayed via gitbox.apache.org for [email protected]
