K
Size: a a a
K
DM
I
I
Caused by: java.lang.RuntimeException: org.apache.flink.util.FlinkException: Could not retrieve submitted JobGraph from state handle under /37de668d8aeb35d671ea5a9e3c030ce7. This indicates that the retrieved state handle is broken. Try cleaning the state handle store.
Caused by: org.apache.flink.util.FlinkException: Could not retrieve submitted JobGraph from state handle under /37de668d8aeb35d671ea5a9e3c030ce7. This indicates that the retrieved state handle is broken. Try cleaning the state handle store.
Caused by: java.io.FileNotFoundException: /mnt/flink/recovery/submittedJobGraphc960a482e538 (No such file or directory)
I
blob.server.port: 6124
env.java.opts: -XX:+HeapDumpOnOutOfMemoryError
#jobmanager.rpc.address: jobmanager
jobmanager.rpc.port: 6123
jobmanager.heap.size: 6000m
taskmanager.heap.size: 8000m
taskmanager.rpc.port: 6122
taskmanager.memory.size: 10000
taskmanager.numberOfTaskSlots: 4
task.cancellation-interval: 3000000
rest.idleness-timeout: 3000000
slot.request.timeout: 9000000
heartbeat.timeout: 1000000
web.timeout: 120000
high-availability: zookeeper
high-availability.jobmanager.port: 6123
high-availability.zookeeper.quorum: zookeeper-0.zookeeper-headless:2181,zookeeper-1.zookeeper-headless:2181,zookeeper-2.zookeeper-headless:2181
high-availability.zookeeper.path.root: /flink
high-availability.cluster-id: /tsp_{{ .Values.urlScheme.project }}
high-availability.storageDir: /mnt/flink/recovery
zookeeper.sasl.disable: true
A
I
A
/mnt/flink/recovery
?A
I
/mnt/flink/recovery
?I
A
A
A
I
A
A
I
A
I