Hi all,I am new to Flink. I am using the classes CountWithTimestamp and CountWithTimeoutFunction from the examples found inI 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 helpThanks
Free forum by Nabble | Edit this page |