You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@mrql.apache.org by "Leonidas Fegaras (JIRA)" <ji...@apache.org> on 2016/05/08 17:54:12 UTC

[jira] [Closed] (MRQL-89) Support Flink 1.0 and fix environment serialization for Flink

     [ https://issues.apache.org/jira/browse/MRQL-89?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Leonidas Fegaras closed MRQL-89.
--------------------------------
    Resolution: Fixed

> Support Flink 1.0 and fix environment serialization for Flink
> -------------------------------------------------------------
>
>                 Key: MRQL-89
>                 URL: https://issues.apache.org/jira/browse/MRQL-89
>             Project: MRQL
>          Issue Type: Bug
>          Components: Run-Time/Flink
>    Affects Versions: 0.9.8
>            Reporter: Leonidas Fegaras
>            Assignee: Leonidas Fegaras
>             Fix For: 0.9.6
>
>
> There are few changes in Flink 1.0 that makes it incompatible with old versions. The most important is that the combine method in groupBy must be defined separately from the reduce method. Need also to fix the serialization of the global environment in Flink (instead of using the default). This will fix the problem of global functions.



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