[
https://issues.apache.org/jira/browse/SAMOA-51?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15073869#comment-15073869
]
ASF GitHub Bot commented on SAMOA-51:
-------------------------------------
Github user senorcarbone commented on the pull request:
https://github.com/apache/incubator-samoa/pull/44#issuecomment-167783226
@abifet @gdfm we could merge this if you are ok with it. Just let me know,
whenever you have free time.
There are not too many changes anyway. Mainly refactorings to comply with
the new Flink streaming API. cheers!
> 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.
> I will hopefully have a fully working and tested version this week
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
