ProcessFunction example from the documentation giving me error

Posted by anna stax on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/ProcessFunction-example-from-the-documentation-giving-me-error-tp21651.html

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