sopan98 opened a new pull request, #21151: URL: https://github.com/apache/flink/pull/21151
This PR aims to solve the issue presented here: https://issues.apache.org/jira/browse/FLINK-29611 ## What is the purpose of the change The fix is to change the HashMap in HeapBroadcastState to LinkedHashMap to make the tests more stable (less flaky). ## Brief change log - Changing the map implementation of HeadBroadcastState - Modifying the tests that depend on this class (Only changing the order of insertion and not the elements or anything else) ## Verifying this change Existing tests already cover this change, and it can pass them successfully. The tests are: 1. org.apache.flink.streaming.api.operators.co.CoBroadcastWithNonKeyedOperatorTest.testMultiStateSupport 2. org.apache.flink.api.datastream.DataStreamBatchExecutionITCase.batchBroadcastExecution 3. org.apache.flink.api.datastream.DataStreamBatchExecutionITCase.batchKeyedBroadcastExecution ## Does this pull request potentially affect one of the following parts: * Dependencies (does it add or upgrade a dependency): No * The public API, i.e., is any changed class annotated with `@Public(Evolving)`: No * The serializers: No * The runtime per-record code paths (performance sensitive): No * Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn/Mesos,, ZooKeeper: No * The S3 file system connector: No ## Documentation Does this pull request introduce a new feature? No -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
