Code Review Request

[ganlute]

Could anyone help me review the changes？Thank you~



Here is the JIRA: https://issues.apache.org/jira/browse/FLINK-28910
Here is the PR: https://github.com/apache/flink/pull/20542