Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5230#discussion_r163930707
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java
---
@@ -137,7 +155,12 @@ public ExecutionConfig getExecutionConfig() {
@Override
public Set<String> getRegisteredStateNames() {
- return registeredStates.keySet();
+ Set<String> stateNames = new HashSet<>(
--- End diff --
Might not make sense to have a new `HashSet` every time
`getRegisteredStateNames` is called.
OTOH, would it make sense to have a separate
`getRegisteredBroadcastStateNames` on the interface?
---
