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
