flink

flink copied to clipboard

[BP-1.20][FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally #26790

2

This is a backport pr to 1.20 branch

lincoln-lil

[hotfix][docs] Add Kafka-to-Kafka SQL example to documentation

6

## What is the purpose of the change This is a documentation-only change, submitted as a `[hotfix][docs]` per contribution guidelines. It adds an example demonstrating how to use Apache Flink...

Ashfaqbs

[FLINK-38089] Avoid pushing down non-deterministic filter in FILTER_RULES

1

## What is the purpose of the change Currently, filters with non deterministic features will be pushed down to join/agg/union, which can result in errors. ## Brief change log -...

Au-Miner

[FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

1

- What is the purpose of the change This is an implementation of MAP_FROM_ENTRIES - Brief change log MAP_FROM_ENTRIES for Table API and SQL ``` map_from_entries(map) - Returns a map...

liuyongvs

[FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception

3

This is a revised version of the previous (auto-)closed PR #24205 More discussions in the JIRA: https://issues.apache.org/jira/browse/FLINK-34251 ## What is the purpose of the change Currently the ClosureCleaner throws exception...

liuml07

[hotfix][docs] Update build documentation to require Java 17

1

The README correctly states that JDK 17 is the default for building Flink. However, the build instructions in the docs still state Java 11 is required. The default build commands...

tomncooper

[hotfix] Adds Override annotation

1

## What is the purpose of the change This PR proposes to add `@Override` for `getSelfGateway()` method in `PekkoRpcService`. Since this method is from `RpcService` interface. ## Brief change log...

luyizhizaio

[FLINK-38050][UI] Correct Flink UI Dropdown Width

4

## What is the purpose of the change Currently, the dropdown to add a metric for an operator, under the metrics section, has a fixed width. This makes it difficult...

nishita-09

[FLINK-38057][runtime] Fix the error value between getting and using idleStartTime in source reader metric group

1

## What is the purpose of the change This pull request fixed the error value between getting and using idleStartTime in source reader metric group. ## Brief change log Use...

ruanhang1993

[BP-2.0][FLINK-37944][test] Add utils for initializing process function test harnesses with async state

1

```release-2.0``` backport of ([#26697](https://github.com/apache/flink/pull/26697))

AlexYinHan