Hi anna, Can you share your program and the exception stack trace and more details about what's your source and state backend?
>From the information you provided, it seems Flink started a network connect but timed out. Thanks, vino. 2018-07-20 14:14 GMT+08:00 anna stax <annasta...@gmail.com>: > Hi all, > > I am new to Flink. I am using the classes CountWithTimestamp and > CountWithTimeoutFunction from the examples found in > https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/stream/ > operators/process_function.html > > I am getting the error Exception in thread "main" > org.apache.flink.runtime.client.JobExecutionException: > java.net.ConnectException: Operation timed out (Connection timed out) > > Looks like when timer’s time is reached I am getting this error. Any idea > why. Please help > > Thanks >
