(DEPRECATED) Apache Flink User Mailing List archive.

Re: ProcessFunction example from the documentation giving me error

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

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 <[hidden email]>:

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