flink-on-k8s-operator

flink-on-k8s-operator copied to clipboard

How to set operator Log format and Level

1

After installing the operator I saw that our Log aggregation solution (datadog) started considering all operator logs as ERROR and its not optimally displaying them. I'd like to explicitly tell...

andre-taveira

i've got an error when i use **make deploy** to deploy this project on my centos virtual machine. > which: no controller-gen in (/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.71-2.b15.el7_2.x86_64/jre//bin:/usr/local/maven/bin:/root/.ft:/root/bin) > go: creating new go.mod: module...

LeaderYeDion

Webhook call failing due to bad cert

1

After upgrading flink operator, somehow the webhook certificate has become unusable and operator won't accept webhook connections when trying to deploy a `flinkcluster` CR. **environment** * operator versions: v1beta1-9, v0.2.1...

jamesclair

Check project status

8

Is this repository still maintained and ongoing project? I want to utilize this project, but it seems that there is no recent activity, so I want to check it. If...

becoming-proc

Improve update and savepoint handling

7

### Purpose of this PR Currently, savepoint and its related routines are scattered in several places. It make difficult to enhance this operator now. This PR organizes them so that...

elanv

Flink Session Cluster Installation is faling

9

based on https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/issues/356, we have tried all the mentioned steps but still the flink session cluster installation is failed. First we tried with the below steps and it didn't helped...

sumchak1

According to the [resource definition](https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/blob/master/docs/crd.md), `flinkProperties` can be specified for job/task manager configuration. However, this configuration is not used for the job submitter. Is there any way/method to specify the...

clouddra

Unable to deploy flink session cluster with the default certficate in kubernetes version 1.19

2

We are deploying flink session cluster on kubernetes version 1.19 . We have deployed flink operator successfully. But when we are applying helm chart for flink session cluster we are...

vinaykw

k8s 1.19 golang 1.15 doesn't like the webhook cert generated

1

Kubernetes 1.19 updates Golang to 1.15+ which throws this error when trying to validate the webhook caBundle: ``` Post \"https://flink-operator-webhook-service..svc:443/mutate-flinkoperator-k8s-io-v1beta1-flinkcluster?timeout=30s\": x509: certificate relies on legacy Common Name field, use SANs...

sgraham785

How to enforce SSL/TLS everywhere through this operator?

8

Hey everyone, I've been trying this operator successfully on OpenShift after making a few small changes and applying a workaround https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/issues/288 in to use Flink 1.11. Now I'd like to...

a-roberts