at org.apache.flink.core.execution.DefaultExecutorServiceLoader.getExecutorFactory(DefaultExecutorServiceLoader.java:1713) at com.cep.StaticAlarmGenerationEntryTest
我有一个Flink流作业,它失败了,我得到了作为below.Can的日志谁告诉我如何解决这个问题?它有时在运行一天后失败,有时在几个小时后失败。(600000), ListStateDescriptor{serializer=org.apache.flink.api.common.typeutils.base.ListSerializer@ece0f926:146)
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel