[ https://issues.apache.org/jira/browse/FLINK-2458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14698613#comment-14698613 ]
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_r37144300 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -897,7 +897,7 @@ class TaskManager( config.timeout, libCache, fileCache, - runtimeInfo) + new TaskRuntimeInfo(hostname, taskManagerConfig, tdd.getAttemptNumber)) --- End diff -- Ah. Yes. That makes sense. I will revert this and open a separate PR. Apologies. > 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)