Hi Flink Community,
I hope you're doing well.
I'm currently working on a simple Flink project where I read a file using
`env.readTextFile("/opt/input.txt")`, process transactions per user, and write
the results to an output CSV file. However, I keep encountering this error
during execution:
Despite copying the file inside the Flink Docker container (I used `docker exec
flink-jobmanager cp /opt/flink/input.txt /opt/input.txt` and confirmed the file
exists with `ls -l /opt/input.txt`), Flink still throws the error.
I’ve tried several fixes and reviewed file permissions, but nothing worked.
I've attached (or linked) my project including:- The Java code
(`UserTransactionSum.java`)- The sample input file (`input.txt`)- The
`docker-compose.yml` I used to start the Flink cluster
**Can anyone kindly review and tell me what I might be missing?** Any
suggestions would be greatly appreciated.
Best regards, Faezeh Ghanbarian [email protected]
