)
> (9320e1ac8143dce9ef827d2bea2d274e) switched from RUNNING to FAILED.
>
> org.apache.flink.runtime.io.network.partition.PartitionNotFoundException:
> Partition 3814daa5451408e1746b6edccf3469fe@8e9d09d5282e5ed7fb5af4a4e937ce2d
> not found.
>
> at
> org.apache.flink.runtime.io.network.partition.ResultPartitionManager.creat
rigger,
CoalesceAndDecorateWindowedGenericRecordProcessWindowFunction) (1/16)
(9320e1ac8143dce9ef827d2bea2d274e).
From: John Stone
Date: Thursday, January 10, 2019 at 3:31 PM
To: "user@flink.apache.org"
Subject: Recovery problem 1 of 2 in Flink 1.6.3
This is the first of two recovery problems I'm seeing running Flink 1.6.3 in
Kubernetes.
This is the first of two recovery problems I'm seeing running Flink 1.6.3 in
Kubernetes. I'm posting them in separate messages for brevity and because the
second is not directly related to the first. Any advice is appreciated.
Setup:
Flink 1.6.3 in Kubernetes (flink:1.6.3-hadoop28-scala_2.11).
