Ilia Karpov

Update k8s-api to v1.21 (to support ephemeral volumes)

1

It would be great if spark application could use [generic ephemeral volumes ](https://kubernetes.io/docs/concepts/storage/ephemeral-volumes/#generic-ephemeral-volumes) to store shuffle/cached data (because of transient nature of this data). This option is more storage efficient...

Question: what restartPolicy is needed for?

2

Hi, I've read [crd docs](https://github.com/spotify/flink-on-k8s-operator/blob/master/docs/crd.md) but can't understand what does it mean `when the job fails`, thus can't understand what is the purpose of `restartPolicy`. Can you kindly explain why...

[Bug]: Checkpointing doesn't trigger records flush to clickhouse

1

### What happened? Originally I've tested connector agains type error failures (type incompatibility between kafka source table and clickhouse sink table): selected from kafka-table integer column (say, json number field...