flink-kubernetes-operator

flink-kubernetes-operator copied to clipboard

[FLINK-34970] Translate architecture documents into Chinese

1

## What is the purpose of the change https://issues.apache.org/jira/browse/FLINK-34970 Translate architecture documents into Chinese ## Brief change log *(for example:)* - *Periodic savepoint trigger is introduced to the custom resource*...

caicancai

[FLINK-34906] Only scale when all tasks are running

6

## What is the purpose of the change Currently, the autoscaler will scale a job when the JobStatus is RUNNING. But the JobStatus will be RUNNING once job starts schedule,...

1996fanrui

## What is the purpose of the change We introduced a logic to scale down the JobManager before the task managers are killed to have a more graceful shutdown sequence....

gyfora

[FLINK-34537] Autoscaler JDBC Support HikariPool

2

## What is the purpose of the change *Autoscaler JDBC Support HikariPool to Replace JDBC DirverManager* ## Brief change log - *Add Autoscaler HikariPool Test* - *Replace JDBC DirverManager Wiht...

czy006

## What is the purpose of the change Flink can report slot sharing group information in the vertex information. This can be used to fine tune the autoscaler algorithm to...

gaborgsomogyi

[FLINK-33634] Add Conditions to Flink CRD's Status field

14

## What is the purpose of the change This PR is for issue https://issues.apache.org/jira/browse/FLINK-33634 to add Conditions field in the CR status of Flink Deployment and FlinkSessionJob. ## Brief change...

lajith2006

Adding affinity rule.

2

## What is the purpose of the change Improving the optimization of pod distribution and placement within a Kubernetes cluster is essential for enhancing resource utilization. Affinity proves to be...

Anshul1128

[FLINK-34441] Add guide to submit flink SQL scripts via the operator (using flink-sql-runner-example)

1

## What is the purpose of the change This pull request adds documentation about flink-sql-runner-example in the Kubernetes operator documentation page. Majority of the content is copied over from the...

prakash-42

## What is the purpose of the change Implement FlinkStateSnapshot as according to FLIP-446. This PR does not include the e2e-tests and documentation. ## Brief change log - Added `FlinkStateSnapshot`...

mateczagany

[FLINK-31215] [autoscaler] Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators

12

## What is the purpose of the change This pull request adds logic for backpropagating processing rate from non-scalable bottlenecks to upstream operators, potentially reducing parallelism of bakcpressured vertices after...

aplyusnin