flink-on-k8s-operator

flink-on-k8s-operator copied to clipboard

we currently benchmark the operator to reflect real situration where tens of jobs come up concurrently. we observe an issue where the submitters pods reach each one consume 1000m+ cpu....

iftachsc

Introduce CRD v1: fix CRD generation bugs and enable field validation

1

This PR introduces CRD v1. CRD v1 is supported in Kubernetes version 1.16+. * Note There is a known issue(#382) for introducing CRD v1. For now, applied a workaround marking...

elanv

Helm Chart install uses self-signed cert

10

The Helm chart creates a self-signed cert which is being rejected by kubectl apply when I try to create a job cluster. michael@michael:~$ sudo kubectl apply -f cog/authoring/test.yaml [sudo] password...

technomage

If I set the securityContext for the flink-operator container inside the flink-operator-controller-manager to run as non-root user (or to drop all capabilites) the container fails to run with the following...

timsn

To comply to our policies I have set several securityContext settings. Such as to the Jobmanager, Taskmanger and Job. The CRD clearly allows to set the securityContext for all the...

timsn

Fix cert-generation, add permission to get secret

16

Cert generator is unable to get secret because of missing permission.

batas

Need to update api/v1beta1/zz_generated.deepcopy.go

1

Hi, I just ran `make generate` against the master branch with latest commit: ``` commit 0310df76d6e2128cd5d2bc51fae4e842d370c463 (HEAD -> master, origin/master, origin/HEAD) Author: GoogleCloudPlatform Date: Sun Feb 28 21:07:18 2021 +0000...

nlu90

Fix memory divisor in calHeapSize

2

Currently, the calculated flink heap size is larger than it really is, As it used 1000 as divisor. This pr used 1024 as divisor to fix the issue.

sharkdtu

How to start job after jobmanager fails for whatever reason?

1

Hi folks, I am still getting familiar with Flink-operator, and I would like to ask for your help with the following question. After starting a new Flink Job Cluster a...

frenkdefrog

## Background Add possibilities for mounting secret properties from `Secret`. Resolves #383 ### Implementation strategy As @shashken described at https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/issues/383#issuecomment-747453395, Use `flinkPropertiesSecret` option in CRD and mount the entire properties...

devholic