Update: The job is working correctly if add an additional identity mapping step:
env.createInput(parquetInputFormat)
.map(record => record)
.sinkTo(FileSink.forBulkFormat...)
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
