The thread is blocked in your user-code, so whether we can unblock it
depends on what said user-code is doing.
On 05/12/2021 19:13, Yuval Itzchakov wrote:
Hi,
Flink 1.14.0,
Scala 2.12
Flink on Kubernetes
I use Lyfts FlinkOperator, which sets up a job cluster in Kubernetes
and then submits the
Hi,
Flink 1.14.0,
Scala 2.12
Flink on Kubernetes
I use Lyfts FlinkOperator, which sets up a job cluster in Kubernetes and
then submits the job via the REST API.
At times, the job fails. Specifically one case I am analyzing fails due to
invalid state migration. I see the following error when
execut
