scala 遍历 java 的 util.Map
Flink 从 Kafka 获取数据进行处理,本来运行的好好的,突然报错:Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy具体错误日志如下:Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job exec