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)
