flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gyula Fora (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1137) Add a way to switch between mutable object safe mode and efficient object reuse mode
Date Fri, 03 Oct 2014 11:44:33 GMT

    [ https://issues.apache.org/jira/browse/FLINK-1137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14157911#comment-14157911
] 

Gyula Fora commented on FLINK-1137:
-----------------------------------

I think this is a good idea, we implemented something like this in the streaming api.

You can call .setMutability(true) on the operators. But we still need to work on it a little
bit for some transformations.

> Add a way to switch between mutable object safe mode and efficient object reuse mode
> ------------------------------------------------------------------------------------
>
>                 Key: FLINK-1137
>                 URL: https://issues.apache.org/jira/browse/FLINK-1137
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: Stephan Ewen
>            Priority: Minor
>
> Right now, Flink is conservative and takes precautions with respect to mutable objects.
Neither the modifying of objects that are input to UDFs, nor modifying objects that are returned,
will cause wrong results.
> This incurs a certain overhead for some operators. Most operators have a way to avoid
that.
> I propose an optional switch to allow to set the system to a mode where it avoids those
precautions, for the sake of efficiency.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message