Lucas Heimberg

When a FlinkApplication custom resource is added, the controller of the flink-operator creates job- and taskmanager deployments. These are labelled with a hash value `flink-hash`, which is computed from the...

Deletion and recreation of FlinkApplication with the same name tries to continue the old job

1

I observed the following behaviour during deletion and recreation of a FlinkApplication custom resource: 1. I create a FlinkApplication with name x. The Flink job cluster is correctly created and...

Job- and taskmanagers are not updated on change of docker image in FlinkApplication resource

3

I have updated a (running) FlinkApplication custom resource to Flink 1.9.1 and a reference to a docker image (1.0.5 below) containing a stream processor using Flink 1.9.1. The custom resource...

In the current implementation, the tasks of the Snowflake Kafka connector create a Snowflake pipe for each partition of the consumed Kafka topic. Especially in the face of large amounts...

Handling of parameterized complex types in arguments to UDFs

10

Fixes #2085. ### Description Formerly, it was not possible to load variants of the same UDF that only differ in the type parameter of the complex argument type, e.g., `f(List...

[bug]: Garbage collection of cluster-wide resources owned by operator deployment fails

2

### Describe the bug The installation of webhooks in the init container of the operator creates a service as well as a ValidatingWebhookConfiguration and a MutatingWebhookConfiguration. All three resources are...

This PR fixes https://github.com/actgardner/gogen-avro/issues/207. Previously, the code, generated by the compiler, tried to set the hint size on the target even when the (array or map) data was actually skipped...