Hi, Which version of Flink is this? It cannot recover because it expects more data to have been written than is there, which seems to indicate that flushing did not work correctly.
Best, Aljoscha > On 19. Dec 2017, at 00:40, xiatao123 <t...@udacity.com> wrote: > > Hi Das, > Have you got your .pending issue resolved? I am running into the same > issue where the parquet files are all in pending status. > Please help to share your solutions. > Thanks, > Tao > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
