Bulk Operation

FLINK-25318 Use default classloader in TaskManager when there are no user jars for job

FLINK-25318 Generate the same code for the same logic

FLINK-25318 Move the serialization of ShuffleDescriptorGroup out of the RPC main thread

FLINK-25318 Support plan cache for DQL in SQL Gateway

FLINK-25318 Align the job execution result fetching timeout in CollectResultFetcher with akka timeout

FLINK-25318 Improve Flink UI's time precision from second level to millisecond level

FLINK-25318 SlotManager supports pulling up all TaskManagers at initialization

FLINK-25318 Support concurrency control when submitting OLAP jobs to Dispatcher

FLINK-25318 Using ZGC in JDK17 to solve long time class unloading STW

FLINK-25318 Upload python jar when sql contains python udf jar

FLINK-25318 Use default classloader in jobmanager when there are no user jars for job

FLINK-25318 Support customized listener during task manager startup

FLINK-25318 Improve to reuse threads in TaskManager for different tasks between jobs

FLINK-25318 Add WebSocket in Dispatcher to support olap query submission and push results in session cluster

FLINK-25318 Improve cache hit rate of generated class

FLINK-25318 Parallelized heavy serialization operations in StreamingJobGraphGenerator

FLINK-25318 Optimize the time of fetching job status in the job submission of session cluster

FLINK-25318 Memory pages in LazyMemorySegmentPool should be clear after they are released to MemoryManager

FLINK-25318 Remove the redundant serialization of RPC invocation at Flink side.

FLINK-25318 Ignore buffer pools which have no floating buffer in buffer redistributing

FLINK-25318 ExecutionGraphInfoStore in session cluster should split failed and successful jobs

FLINK-25318 TaskExecutor always creates local file for task even when local state store is not used

FLINK-25318 Too many JM logs in flink session cluster for olap queries

FLINK-25318 Add thread dump feature for jobmanager

FLINK-25318 Improvement of connection from TM to JM in session cluster

FLINK-25318 HiveSourceFileEnumerator should fetch splits asynchronously

FLINK-25318 Manage and share gateways of taskmanagers between jobs in session cluster

FLINK-25318 Improvement of execution graph store in flink session cluster for jobs

FLINK-25318 Improvement of reuse segments for join/agg/sort operators in TaskManager for flink olap queries

FLINK-25318 Support listen and notify mechanism for PartitionRequest

FLINK-25318 job name should not always be `collect` submitted by sql client

FLINK-25318 Add min number of slots configuration to limit total number of slots

FLINK-25318 Enable TCP connection reuse across multiple jobs.

FLINK-25318 System classloader memory leak after loading too many codegen classes.