Hi,
Could you let me know what data source / connector you are using?
My gut feeling is that perhaps some sources have already reached EOF and
terminated, which may explain the exception (which is expected behaviour).
Cheers,
Gordon
--
Sent from: http://apache-flink-user-mailing-list-archive.2
Hi,
I developed a Flink application that read data from files and inserts them
into the database. During the job running, I attempted to get a savepoint
and cancel the job but I got the following error:
Caused by: java.util.concurrent.CompletionException:
> org.apache.flink.runtime.checkpoint.Che