[FLINK-30624][runtime] Introduce a new HeapPriorityQueue for StatusWatermarkValve to avoid affecting the performance of memory state backend.#21779

Closed

wanglijie95 wants to merge 1 commit into

apache:masterfrom

wanglijie95:FLINK-30624

Commits on Jan 30, 2023

[FLINK-30624][runtime] Introduce a new HeapPriorityQueue for StatusWatermarkValve to avoid affecting the performance of memory state backend.
wanglijie95
committed