Ted Yu created FLINK-6651: ----------------------------- Summary: Clearing registeredStates map should be protected in SharedStateRegistry#clear Key: FLINK-6651 URL: https://issues.apache.org/jira/browse/FLINK-6651 Project: Flink Issue Type: Bug Reporter: Ted Yu Priority: Minor
{code} public void clear() { registeredStates.clear(); } {code} In other places of SharedStateRegistry, lock is taken on registeredStates before operation. We should do the same for clear() method. -- This message was sent by Atlassian JIRA (v6.3.15#6346)