Paris Carbone created SAMOA-51:
----------------------------------
Summary: Update Flink Module to v0.10.0
Key: SAMOA-51
URL: https://issues.apache.org/jira/browse/SAMOA-51
Project: SAMOA
Issue Type: Task
Components: SAMOA-Flink
Reporter: Paris Carbone
Priority: Minor
Flink v0.10.0 is fresh and comes with many performance and api improvements so
an upgrade is a must!
The only non-trivial thing that needs change is, again, loops. Flink now
assumes a forward parallelism perseverance between components. In other words,
we need to repartition sources to match the tail parallelism before starting a
flink iteration.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)