flinkk8soperator

flinkk8soperator copied to clipboard

Add status object schema to CRD.

1

Fixes #253 Adds the `status` object schema to the CRD to address problems with newer releases of Kubernetes (e.g. 1.20+) that validate CRD data. This might not be required in...

skidder

According to the states, if dual mode, either failure in `ClusterStarting` or `SubmittingJob` will leads to the `RollingBackJob` mode. However, when I tested, I noticed that 1. In `ClusterStaring` state,...

lydian

Exception occurred in REST handler: Job X not found

3

Hey, I am using the operator in version `docker.io/lyft/flinkk8soperator:1355d206b5fb4efd6f6e4ccf24085a87a29443c5`. Running ok aws eks version 1.21. Sometimes The job manager floods the log with this message and when it starts, I...

liad5h

Bumps [numpy](https://github.com/numpy/numpy) from 1.16.4 to 1.22.0. Release notes Sourced from numpy's releases. v1.22.0 NumPy 1.22.0 Release Notes NumPy 1.22.0 is a big release featuring the work of 153 contributors spread...

dependabot[bot]

Support user-defined multiple namespaces

3

Feature enhancement. Instead of flink-operator namespace, we'd like to support user-defined multiple namespaces per flink application

pzou1974

CRD schema required for object validation in newer Kubernetes releases

1

Newer versions of Kubernetes (e.g. 1.20+) perform type-validation of data written to the CRD. The CRD for the Flink operator currently does not define a schema for the `status` object....

skidder

Fixes #250 Resolves CRD validation errors in Kubernetes 1.20+ for `nodeSelector` values.

skidder

Configuring Prometheus metric reporter

21

Good day. We use Flink Prometheus metric reporter (https://ci.apache.org/projects/flink/flink-docs-release-1.9/monitoring/metrics.html#prometheus-orgapacheflinkmetricsprometheusprometheusreporter) in conjunction with Prometheus Operator ServiceMonitor (https://github.com/coreos/prometheus-operator/blob/master/Documentation/user-guides/getting-started.md#related-resources) to collect Flink cluster metrics. But when we tried to swithc to flinkk8soperator we...

aleksandr-spb

Configure s3 for checkpointing

1

Dears It is recommended to copy the s3 fs proper jar plugin to the plugin path (weither it is hdfs or presto) before starting the job manager. How to support...

mootezbessifi

nodeSelector does not get picked up

1

We are trying to set the `nodeSelector` attribute in the taskManagerConfig and jobManagerConfig, but, it gets ignored. ``` jobManagerConfig: nodeSelector: instancezone: primary resources: requests: memory: "1Gi" cpu: "500m" limits: memory:...

sushraju