Hi Taras, On first glance this looks like a bug to me. Can you try the latest 1.12 version (1.12.4)? If the bug still persists can you share the full job manager and task manager logs to further debug this problem.
Best, Fabian > On 2. Jun 2021, at 13:22, Taras Moisiuk <t.v.mois...@gmail.com> wrote: > > 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/
