flink

flink copied to clipboard

Fix grammar in Adaptive Scheduler documentation

2

Correct grammatical error in the description of the Adaptive Scheduler. ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob...

Maestro2496

[hotfix] [docs] Rework 'Name and Description' section of operators overview to improve grammar and clarity

1

## What is the purpose of the change Reworks the 'Name and Description' section of `content/docs/dev/datastream/operators/overview.md` to improve grammar and clarity.

cassie365

[hotfix] Add null check for currentReader in pauseOrResumeSplits

1

## What is the purpose of the change Add null check for pauseOrResumeSplits to avoid NPE ## Brief change log Added null check for `currentReader` in pauseOrResumeSplits(). ## Verifying this...

xccui

[FLINK-38584][metrics] Support checkpoint path as Prometheus info-style metric

1

## What is the purpose of the change This pull request enhances the Prometheus reporter to export the `lastCheckpointExternalPath` metric as an info-style metric, making it compatible with Prometheus and...

sohurdc

[FLINK-38566] Support CEP DSL

7

## What is the purpose of the change Related to [FLINK-38566](https://issues.apache.org/jira/browse/FLINK-38566) # Flink CEP DSL Module This module provides a Domain-Specific Language (DSL) for Apache Flink's Complex Event Processing (CEP)...

kaori-seasons

Pashley/flink 38350 release 1.20

1

## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring...

pra91

[FLINK-38516][Table SQL/Gateway] Add config for read-only sql gateway

2

https://issues.apache.org/jira/browse/FLINK-38516 ## What is the purpose of the change The Flink SQL Gateway currently lacks native support for read-only mode to restrict [ModifyOperations](https://github.com/apache/flink/blob/master/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ModifyOperation.java) (e.g., INSERT, DELETE). This feature allows ad-hoc...

rosakng

[hotfix] Tracks the number of pending manual compactions.

3

## What is the purpose of the change This pull request tracks the pendingManualCompactions in org.apache.flink.state.rocksdb.sstmerge.CompactionTracker: ## Brief change log - Currently, there is only `pendingManualCompactions--` in the code. -...

littleeleventhwolf

[FLINK-38225] Sets proper precondition to ensure that GCS operations are retryable

1

## What is the purpose of the change Ensures that the operations become idempotent or atomic, allowing the GCS client to safely retry the 503 errors. Thus client can actually...

JTaky

[FLINK-38444][table] Join unique keys should not contain null values

12

## What is the purpose of the change The planner currently considers the union of both the unique and upsert keys from the left and from the right to be...

gustavodemorais