Junrui Lee

[FLINK-33576][core] Introduce new Flink conf file 'config.yaml' supporting standard YAML syntax.

4

## What is the purpose of the change Introduce new Flink conf file 'config.yaml' supporting standard YAML syntax. ## Brief change log - *Introduce new Flink conf file 'config.yaml' supporting...

[FLINK-33980][core] Reorganize job configuration

10

## What is the purpose of the change Reorganize job configuration ## Brief change log 1. Migrate configuration from non-ConfigOption objects to use ConfigOption. 2. Adopt a single Configuration object...

[FLINK-33982][core] Introduce new config options for Batch Job Recovery

2

## What is the purpose of the change [FLINK-33982][core] Introduce new config options for Batch Job Recovery ## Brief change log Introduce new config options for Batch Job Recovery ##...

[FLINK-33986][runtime] Extend ShuffleMaster to support snapshot and restore state.

1

## What is the purpose of the change Extend ShuffleMaster to support snapshot and restore state. ## Brief change log Extend shuffleMaster to support batch snapshot as follows: 1. Add...

[FLINK-33892][runtime] Support Job Recovery from JobMaster Failures for Batch Jobs.

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...

[FLINK-33983][runtime] Introduce JobEvent and JobEventStore

1

## What is the purpose of the change [FLINK-33983][runtime] Introduce JobEvent and JobEventStore ## Brief change log Introduce JobEvent and JobEventStore ## Verifying this change This change added tests and...

[FLINK-35731][runtime] Fix incorrect parallelism configured detection for Sink V2.

1

## What is the purpose of the change Fix incorrect parallelism configured detection for Sink V2. ## Brief change log - Fix incorrect parallelism configured detection for Sink V2. -...

[FLINK-33678][streaming-java] Remove RestartStrategies related public API.

2

## What is the purpose of the change [FLINK-33581](https://issues.apache.org/jira/browse/FLINK-33581)/FLIP-381 Deprecate configuration getters/setters that return/set complex Java objects. In Flink 2.0 we should remove these deprecated method and fields. This change...

[FLINK-33678][streaming-java] Remove CheckpointStorage related public API.

1

## What is the purpose of the change [FLINK-33581](https://issues.apache.org/jira/browse/FLINK-33581)/FLIP-381 Deprecate configuration getters/setters that return/set complex Java objects. In Flink 2.0 we should remove these deprecated method and fields. This change...

[FLINK-36064][streaming] Refactor Collect sink to eliminate dependency on OperatorID.

1

## What is the purpose of the change [FLINK-36064][streaming] Refactor Collect sink to eliminate dependency on OperatorID. ## Verifying this change This change is already covered by existing tests ##...