[
https://issues.apache.org/jira/browse/MRQL-89?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15275266#comment-15275266
]
Hudson commented on MRQL-89:
----------------------------
SUCCESS: Integrated in mrql-master-snapshot #34 (See
[https://builds.apache.org/job/mrql-master-snapshot/34/])
[MRQL-89] Support Flink 1.0 and fix environment serialization for Flink
(fegaras:
[https://git-wip-us.apache.org/repos/asf?p=incubator-mrql.git&a=commit&h=cec9d8110006515ab33ab458870f2db0661d1efb])
* core/src/main/java/org/apache/mrql/Environment.java
* pom.xml
* flink/src/main/java/org/apache/mrql/FlinkEvaluator.gen
* core/src/main/java/org/apache/mrql/Interpreter.gen
* flink/pom.xml
* core/src/main/java/org/apache/mrql/MR_dataset.java
* conf/mrql-env.sh
* core/src/main/java/org/apache/mrql/TopLevel.gen
> 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)
