[ https://issues.apache.org/jira/browse/FLINK-2458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661749#comment-14661749 ]
ASF GitHub Bot commented on FLINK-2458: --------------------------------------- Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/970#discussion_r36513206 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java --- @@ -79,7 +68,7 @@ public AbstractRuntimeUDFContext(String name, this.subtaskIndex = subtaskIndex; this.userCodeClassLoader = userCodeClassLoader; this.executionConfig = executionConfig; - this.distributedCache = new DistributedCache(cpTasks); + this.distributedCache = Preconditions.checkNotNull(new DistributedCache(cpTasks)); --- End diff -- Ah yes. Sorry. > Distributed Cache doesn't work with iterations. > ----------------------------------------------- > > Key: FLINK-2458 > URL: https://issues.apache.org/jira/browse/FLINK-2458 > Project: Flink > Issue Type: Bug > Reporter: Sachin Goel > Assignee: Sachin Goel > > Distributed cache files cannot be accessed when working in Iterative > contexts. While constructing the context in {{AbstractIterativePactTask}}, > the distributed entries are not passed on to runtime context. > My commit will add this and also unify the distributed cache system to work > everywhere, including in the Collection Environment. -- This message was sent by Atlassian JIRA (v6.3.4#6332)