Briefly describe the problem this PR fixes or the feature it introduces. Reference Flink JIRA ticket when possible.
List the key changes in this PR.
This change is a trivial rework / code cleanup without any test coverage.
(or)
This change added tests and can be verified as follows:
- Added/Updated unit tests in
...* - Added/Updated integration tests in
...* - Manually tested by ...
- Does this pull request introduce a new feature? (yes / no)
- If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented)
- Yes (please specify the tool below)