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/06 14:31:12 UTC

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

Leonidas Fegaras created MRQL-89:
------------------------------------

             Summary: 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)