flinkk8soperator

flinkk8soperator copied to clipboard

The operator is designed to manage a single job. There are use cases where it is desirable to only have the Flink cluster stood up and manually manage the job....

tweise

I think this is somewhat related to #102. There is a suggestion about using mutating admission webhooks for this, but given that the sidecar pattern is so widely used I...

jmdacruz

TaskExecutor could not resolve address.

1

## Error Log ``` 2019-09-25 07:45:37,610 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Could not resolve ResourceManager address akka.tcp://flink@wordcount-operator-example-68077756:6123/user/resourcemanager, retrying in 10000 ms: Ask timed out on [ActorSelection[Anchor(akka.tcp://flink@wordcount-operator-example-68077756:6123/), Path(/user/resourcemanager)]] after [10000 ms]. Sender[null] sent...

mikechengwei

This repo currently uses dep to manage its package dependencies. The dep functionality is now legacy and has been replaced with Go modules. The repo should be converted to a...

hapnermw

transfer a running job to flinkk8soperator

2

Is it possible to tranfer a running flink job to `flinkk8soperator` seamlessly, especially recover from a savepoint?

nealsun

Adding new service port to Job manager service

3

Hi, We are trying to expose metrics vis Prometheus reporter. We added prometheus reporter and port details to flink config. We want this port to be exposed from service. But...

rmuthupandian

Question: what is the difference between this project and the Flink project's k8s operator?

1

Hi there, Can't quite figure out judging by the docs whether this operator is distinct from the [Flink project's operator](https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/). Are they the same thing, fork's of each other or...

campbellC

The flink High availability should be using `kuberentes.cluster-id` instead of `high-availability.cluster-id` Here's the settings: https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/deployment/ha/kubernetes_ha/ It seems like in 1.13 is already the same config: https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/deployment/ha/kubernetes_ha/

lydian

Support for Kubernetes 1.24+

2

This PR updates the operator to use Kubernetes 1.24 APIs, tested on Kubernetes 1.27. ## Changes 1. Updates project dependencies in `go.mod` to use the K8S 1.24 APIs 2. Updates...

skidder

v1.22

3

- crd changes - upgrade to v1.22

leoluoInSea