Re: Flink Job Fails with FileNotFoundException for Existing File

2025-04-26 Thread Feng Jin
Hi FaƩze Thank you for providing the detailed description and attachments. In Flink, the actual file reading operation is performed by the TaskManager, not the JobManager. Although you copied the file into the JobManager container, the TaskManager is the one that attempts to access /opt/input.txt

Flink Job Fails with FileNotFoundException for Existing File

2025-04-22 Thread faeze ghanbarian via user
Dear Flink Community, I'm currently working on a simple Apache Flink project inside Docker using version 1.15.2. The goal of the project is to read user transactions from a text file (`input.txt`), calculate the total transaction amount per user, and write the result as a CSV. My code uses this