[
https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15493858#comment-15493858
]
ASF GitHub Bot commented on FLINK-4615:
---------------------------------------
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2496#discussion_r79007600
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/Driver.java ---
@@ -87,4 +87,6 @@
* @throws Exception Exceptions may be forwarded.
*/
void cancel() throws Exception;
+
+ void resetForIterativeTasks() throws Exception;
--- End diff --
I saw that code. But am not sure how to do that. Driver is actually
instantiated from the config. So how to ensure that it is of type
ResettableDriver? You mean all drivers will now become a type of
ResettableDriver?
> Reusing the memory allocated for the drivers and iterators
> ----------------------------------------------------------
>
> Key: FLINK-4615
> URL: https://issues.apache.org/jira/browse/FLINK-4615
> Project: Flink
> Issue Type: Sub-task
> Components: Local Runtime
> Reporter: ramkrishna.s.vasudevan
> Assignee: ramkrishna.s.vasudevan
> Fix For: 1.0.0
>
>
> Raising as a subtask so that individually can be committed and for better
> closer reviews.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
