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 per Windows |
- Theory question on process_continously processing mode and wat... Fra
