[
https://issues.apache.org/jira/browse/FLINK-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039311#comment-16039311
]
ASF GitHub Bot commented on FLINK-6823:
---------------------------------------
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4068#discussion_r120427357
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/BroadcastVariableManager.java
---
@@ -18,34 +18,42 @@
package org.apache.flink.runtime.broadcast;
-import java.io.IOException;
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
-
import org.apache.flink.api.common.typeutils.TypeSerializerFactory;
import org.apache.flink.runtime.io.network.api.reader.MutableReader;
import org.apache.flink.runtime.operators.BatchTask;
+import java.io.IOException;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * The BroadcastVariableManager is used to manage the materialization of
broadcast variables. References to materialized
+ * broadcast variables are cached and shared between parallel subtasks. A
reference count is maintained to track whether
+ * a the materialization may be cleaned up.
--- End diff --
Delete leading `a`.
> Activate checkstyle for runtime/broadcast
> -----------------------------------------
>
> Key: FLINK-6823
> URL: https://issues.apache.org/jira/browse/FLINK-6823
> Project: Flink
> Issue Type: Improvement
> Components: Local Runtime
> Reporter: Chesnay Schepler
> Assignee: Chesnay Schepler
> Priority: Trivial
> Fix For: 1.4.0
>
>
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
