Hi Team, I am upgrading Flink from 1.12 to 1.16. W...
# troubleshooting
l
Hi Team, I am upgrading Flink from 1.12 to 1.16. We were using
ParquetPojoInputFormat
in 1.12 and looks like this class was removed starting from 1.14 (part of this PR). I wonder if there’s docs on what substitute class or migration we can reference? Thanks
s
Look at
ParquetColumnarRowInputFormat
👀 1
l
hmmm
ParquetColumnarRowInputFormat
doesn’t seem to implement that
InputFormat
interface in flink-core.
Looks like I might need to switch to using the file-connector if I want to switch to
ParquetColumnarRowInputFormat
? Currently I was just using
StreamingExecutionEnvironment#createInput