[FLINK-2826] transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Assignee: Ted Yu
• Reporter: Ted Yu
• Created: 06/Oct/15 23:21
• Updated: 11/Nov/15 15:37
• Resolved: 11/Nov/15 15:37

Description

Here is related code:

                        if (references.isEmpty()) {
                                disposed = true;
                                data = null;
                                transformed = null;

Elsewhere, transformed is modified with lock on BroadcastVariableMaterialization.this