flink

flink copied to clipboard

[FLINK-36881][table] Introduce GroupTableAggFunction in GroupTableAggregate with Async State API

2

## What is the purpose of the change Introduce GroupTableAggFunction in GroupTableAggregate with async state api. ## Brief change log - *Introduce GroupTableAggFunction in GroupTableAggregate with async state api.* -...

Au-Miner

[FLINK-36851][table] Introduce TemporalProcessTimeJoinOperator in TemporalJoin with Async State API

3

## What is the purpose of the change Introduce TemporalProcessTimeJoinOperator in TemporalJoin with async state api. ## Brief change log - *Introduce TemporalProcessTimeJoinOperator in TemporalJoin with async state api.* -...

Au-Miner

[FLINK-18590][json] Support json array explode to multi messages (#26…

2

This is a 1:1 backport of https://github.com/apache/flink/pull/26473 into Flink 1.20 * [FLINK-18590][json] Support json array explode to multi messages --------- ## What is the purpose of the change *(For example:...

gmdfalk

[FLINK-37327] [Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows

4

## What is the purpose of the change Add a Format Option to the Debezium Format to optionally skip emitting the UPDATE_BEFORE Rows when deserializing a Debezium message with op='u'....

klam-shop

Fix CVE-2022-25168

4

This PR addresses a critical security vulnerability (Command Injection) in the extractTarFileUsingTar method of CompressionUtils. Modified extractTarFileUsingTar to use a stream-based approach that passes file content through stdin instead of...

th555555

[FLINK-37817] Adds bundled aggregates for group by (FLIP-491)

1

## What is the purpose of the change This PR implements one of the first portions of `FLIP-491`. It has a couple components: - Adds a new operator `KeyedAsyncWaitOperator` which...

AlanConfluent

[hotfix] Correct the comments for FlinkSecurityManager

6

## What is the purpose of the change This PR aim to correct the comments for `FlinkSecurityManager`. The original comments means cannot avoid the overhead. It is wrong. ## Brief...

beliefer

[FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows

9

## What is the purpose of the change This PR aim to avoid duplicate calculations for `SlidingEventTimeWindows`. The original code put the expression `timestamp - size` into the loop, so...

beliefer

[hotfix][s3] Improve interruption handling for s5cmd

1

Small hotfix, for not waiting for s5cmd process to finish (`s5cmd` was being cancelled, Flink was just not waiting for it to happen and was incorrectly logging a warning). ##...

pnowojski

[FLINK-37666]: Address CWE-378: Creation of Temporary File With Insec…

8

…ure Permissions in Temporary File Creation ## What is the purpose of the change The purpose of the change is to replace the usage of File.createTempFile with Files.createTempFile across multiple...

atu-sharm