flink

flink copied to clipboard

[hotfix] Avoid duplicate operation !

2

## What is the purpose of the change This PR aims to avoid duplicate operation `!` and remove the variable `detached`. ## Brief change log Avoid duplicate operation `!`. ##...

beliefer

[FLINK-36659][docs] Update Kafka connector docs for 4.0.0

1

Update Kafka connector docs for 4.0.0

AHeise

[FLINK-38765] Fix persisted metadata handling in sink

1

## What is the purpose of the change Fixes a bug where an incorrect type is used in sink for * shuffling * sink upsert materializer * constraint validation ##...

dawidwys

[FLINK-37504] Handle TLS Certificate Renewal

8

https://issues.apache.org/jira/browse/FLINK-37504 ## What is the purpose of the change Implementation of the TLS Renewal for SSL. Adds functionality to be notified if SSL keys were changed on the Flink container....

JTaky

[FLINK-38416] bugfix correct constructor arg order

3

## What is the purpose of the change Fix order of arguments in constructor for `NestedMapConstraint`, Specifically, args for key and value getters are in the wrong order compared to...

rymurr

Add AI Documentation Support

1

This PR adds .cursor directory and updates .gitignore to support AI documentation tools.

keshavpandya06

[FLINK-30975] Upgrade hadoop to 3.4.X

4

## What is the purpose of the change Hadoop 3.4.X introduced [2500+ bug fixes](https://hadoop.apache.org/release/3.4.0.html) and support for AWS SDK V2. Note [AWS SDK V1](https://aws.amazon.com/blogs/developer/announcing-end-of-support-for-aws-sdk-for-java-v1-x-on-december-31-2025/) is EOL 12/31/2025. One challenge is...

ctrlaltdilj

[FLINK-38382][kafka] Support avro primitive types in Confluent Schema Registry binding

2

## What is the purpose of the change This pull request adds support for primitive types in `ConfluentRegistryAvroSerializationSchema` by introducing a new `forPrimitiveType` factory method. This enables serialization of primitive...

parisni

[FLINK-38372][Runtime / Metrics] Introduces whitelist to the flink-metrics-prometheus

1

## What is the purpose of the change *Allowing users to specify a whitelist of metrics to be exposed through the Prometheus reporter.* ## Brief change log - *Adding a...

Myracle

[FLINK-38321][table] Optimize the timer registration logic in window e…

1

## What is the purpose of the change Optimize the timer registration logic in window early/late firing scenarios. For keys that will not receive subsequent data, it is unnecessary to...

liuyongvs