WenjunMin

[FLINK-28751][Table SQL/Runtime] Optimize the performance of the json…

5

… functions ## What is the purpose of the change This PR is meant to improve the performance of the built in json functions. The default `LRUCache` used in the...

Explicitly exit ShuffleWorker process when terminate future finished

1

In our usage, we encounter a case where the shuffle worker registers timeout and triggers a fatal error, but the shuffle worker process does not exit and this leads to...

[FRS-66] Introduce shuffleworker deployed by statefulset and pvc

1

This is the first part to introduce the shuffle worker deployed by stateful set. It will complete with three PR as plan: - Introduce the statefulset builder and parameters (this...

By default, the shuffleManagerClient will print the log as below. But the worker Instance id is not human readable. It can not quick link to the target ShuffleWorker. We need...

Support to use StatefulSet + Pvc to deploy the shuffle service

2

In the current kubernetes mode, the rss use the hostPath or the emptyDir to store the shuffle data. But, In our company, the local disk resource is very rare and...

[FLINK-29088][table] Extract the common project to enhance source reuse

4

## What is the purpose of the change This PR is meant to provide a way to extract the common project for the same source in a single rel tree....

[FLINK-29061][Table/Planner] Cleanup unused code in StringCallGen

6

## What is the purpose of the change Remove the dead code in the `StringCallGen` and the related function codes

https://github.com/japaric/trust/blob/54884a59a050bd96e51be85d9ae7f0262bc8e5ea/ci/install.sh#LL39C16-L39C16 The `https://japaric.github.io/trust/install.sh` use the wrong path to download the cross asserts now.

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation In stream mode, the unaware bucket mode will use the `FIFOSplitAssigner`, So we...

[core] support decouple the delta files lifecycle

2

### Purpose This PR is meant to support decouple the delta files lifecycle #2899 The basic idea behind this is that: - Add fileSource in `DatafileMeta` to indicate whether this...