You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@mrql.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/06 19:50:13 UTC

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15274635#comment-15274635 ] 

ASF GitHub Bot commented on MRQL-89:
------------------------------------

GitHub user fegaras opened a pull request:

    https://github.com/apache/incubator-mrql/pull/20

    [MRQL-89] Support Flink 1.0 and fix environment serialization for Flink

    

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/fegaras/incubator-mrql MRQL-89

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/incubator-mrql/pull/20.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #20
    
----
commit cec9d8110006515ab33ab458870f2db0661d1efb
Author: Leonidas Fegaras <fe...@cse.uta.edu>
Date:   2016-05-06T19:28:27Z

    [MRQL-89] Support Flink 1.0 and fix environment serialization for Flink

----


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