flink-on-k8s-operator

flink-on-k8s-operator copied to clipboard

Restricted CRD API group "k8s.io"

3

Controller-tools 0.4.1, which fixes the issue #311 , has been released. However, this only applies to CRD v1. (Now we use v1beta1.) Not only that, but CRD v1 restricts the...

elanv

Savepoints flow changes

5

Hey guys, following the comments from @functicons @elanv on my PR: #392 and elanv's fix: #401 for the intermediate fix for Savepoints (which had more than 1 triggered) I would...

shashken

Flink-operator cluster status keeps 'Creating' for hours

2

I started a flinkcluster that named 'aaa', for example. First, I executed 'kubectl get flinkcluster -n namespace'. The flinkcluster 'aaa' appeared, but the pods did not appear. Then I executed...

scape7yu

Manage multiple jobs on Session Cluster mode.

1

Do you have plan to manage multiple jobs lifecycle on Session cluster? I understand that Job Cluster is the easy way, however we afraid to have too many K8s pods,...

webmanAv

Support HA mode for JobManager

16

https://ci.apache.org/projects/flink/flink-docs-stable/ops/jobmanager_high_availability.html

functicons

Why there is no nodeSelector in spec level or in Job in CRD?

6

Why there is no nodeSelector in spec level or in Job in latest [crd](https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/blob/master/docs/crd.md)? Having node selector in Job also will be helpful or at `spec` level will be much...

chethanuk

- added affinity passthrough to job pod spec - added nodeSelector passthrough to job pod spec (#380) - added tolerations passthrough to job pod spec e

sgraham785

Update/remove offheap memory settings

4

As of Flink 1.11, the properties for setting the offheap memory have changed and no longer match the ones set by the operator. Docs: https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/memory/mem_migration.html#taskmanager-heap-size. These properties are always set...

EnriqueL8

I honestly didn't expect `undeploy` to delete the namespace I'm using. Is it really necessary? The namespace can contain other non-Flink related resources (like secrets).

sap1ens

When flink version >= 1.10 , the "taskmanager.heap.size" is not work.

19

We have calcute flink memory use "tmMemoryOffHeapRatio" and "tmMemLimitByte' in operator, But it is not work for flink 1.10. flink 1.10 use "taskmanager.memory.process.size" to limit the flink memory. If we...

Mrart