Flink TCP socket custom source - savepoint cannot be taken

2023-06-30 Thread Kamal Mittal via user
Hello Community, I have a requirement to read data coming over TCP socket stream and for the same written one custom source function reading data by TCP socket. Job is running successfully but while trying to take a savepoint, error comes that savepoint cannot be taken. Is there any limitation

Re: Flink TCP socket custom source - savepoint cannot be taken

2023-07-03 Thread Martijn Visser
Hi Kamal, There's no such limitation, so most likely this is related to the implementation of your TCP source connector. Do keep in mind that just by the nature of TCP, I doubt that you will have any guarantees when it comes to this source. E.g. if you roll back to a savepoint of one day ago, how