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
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