对于从保存点恢复Flink检查点,当我们使用java基本类型的值状态时,它可以正常运行,但当使用java对象的值状态时,它会抛出异常。它的关键解决方案是什么?任何想法都将受到感谢。at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTask.java:738)
at org.apache.flink.streaming.runtime.tasks.StreamTask.i
我无法在Amazons中启动Apache的纱线会话。我得到的错误信息是$ cd flink-0.9.0
$ .Diagnostics: File file:/home/hadoop/.flink/application_1439466798234_0008/flink-conf.yaml does not existjava.io.File