Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
SystemDS 3.1
Description
Since some federated instructions do not wait for the worker's response, it happens that the worker iterates the LocalVariableMap, while another thread at the worker is already modifying (create/remove) the map for the next federated request, which leads to a ConcurrentModificationException.
An example for this situation can be found when executing the FederatedAlsCGTest. There, the method LocalVariableMap.hasReferences() iterates the HashMap (triggered by 'rmvar' instruction) while the thread from the next request is putting a new entry into the map.
Attachments
Issue Links
- links to