Hi! FileProcessingMode.PROCESS_CONTINUOUSLY means to continuously scans the file for updates, and there should be nothing to do with stopping the streaming job.
I'm suspecting that in the column you defined the watermark there is some data which exceeds Long.MAX_VALUE. A Long.MAX_VALUE watermark indicates the job to stop. You might also want to share your code in the mailing lists so others can look into this problem more deeply. Fra <peci...@gmail.com> 于2021年8月19日周四 下午5:26写道： > Hello, during my personal development of a Flink streaming Platform i > found something that perplexes me. > > Using FileProcessingMode.*PROCESS_CONTINUOUSLY* > > Into a streaming job that uses tumbling Windows and watermarks causes my > streaming process to stop ad the reading files phase. > > Meanwhile if i delete my declarations of Windows and watermark the program > works as expected. > > Is there some meaning behind this behaviour ? my theory is that > PROCESS_CONTINOUSLY re-reads the file and that causes a contradiction with > the watermarks created in the first reading of the files, causing it to stop > > > > > > Inviato da Posta <https://go.microsoft.com/fwlink/?LinkId=550986> per > Windows > > >
