flink

flink copied to clipboard

[hotfix][runtime] Minor polish for the parameter naming of ExecutionGraphWithVertexParallelism#create.

1

## What is the purpose of the change [hotfix][runtime] Minor polish for the parameter naming of ExecutionGraphWithVertexParallelism#create. ## Brief change log [hotfix][runtime] Minor polish for the parameter naming of ExecutionGraphWithVertexParallelism#create....

RocMarshal

[FLINK-38716][docs] Describe the impact of slot.request.max-interval on balanced tasks scheduling.

1

## What is the purpose of the change [FLINK-38716][docs] Describe the impact of slot.request.max-interval on balanced tasks scheduling. ## Brief change log [FLINK-38716][docs] Describe the impact of slot.request.max-interval on balanced...

RocMarshal

[hotfix][docs] Add documentation for building multiple legacy releases on Windowses on Windows

2

## What is the purpose of the change This pull request adds a new documentation page that provides a practical guide for compiling multiple Flink releases on Windows, including older...

MOliverRoth

[FLINK-37427] Fix NPE in StandaloneHaServices and add unit testAdd unit test case for StandaloneHaServices constructor

2

## What is the purpose of the change developers receive unhelpful error messages when parameters are null. ## Brief change log Replace checkNotNull(clusterRestEndpointAddress, clusterRestEndpointAddress) with checkNotNull(clusterRestEndpointAddress, "clusterRestEndpointAddress") to ensure the...

lurongjiang

[FLINK-38703][runtime] Update slot manager metrics in thread-safety manner

4

## What is the purpose of the change This PR resolves a race condition that leads to a `ConcurrentModificationException` when OpenTelemetry (OTel) metrics are collected simultaneously with updates to the...

ztison

[FLINK-38695][table-runtime] Fix wrong metric about left cache request count in DeltaJoinCache

2

## What is the purpose of the change Fix wrong metric about left cache request count in DeltaJoinCache. ## Brief change log - Fix wrong metric about left cache request...

xuyangzhong

Fix watermark alignment explanation in documentation

2

According to the following description, the flag should be false, then make sense. ## What is the purpose of the change *(For example: This pull request makes task deployment go...

SherwinFeng

Fix watermark alignment explanation in documentation

2

according to the following description and the flag should be false，then make sense. ## What is the purpose of the change *(For example: This pull request makes task deployment go...

SherwinFeng

[FLINK-37607] Fix RpcEndpoint#MainThreadExecutor lost scheduling tasks when not running

4

## What is the purpose of the change *The pull request is to resolve the issue of task loss occurring before the RPC server starts when using org.apache.flink.runtime.rpc.RpcEndpoint.MainThreadExecutor#schedule.* ## Brief...

Look-Y-Y

[FLINK-38557][FileSystems] Bumped presto version from 0.272 to 0.295

2

## What is the purpose of the change * Bumps the version of presto to reduce the vulnerabilities present in the previous version ## Brief change log - *Updated the...

kosuruvarunkumar