[jira] [Created] (FLINK-3020) Local execution: set number of task manager slots to the maximum parallelism

2015-11-16 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3020: - Summary: Local execution: set number of task manager slots to the maximum parallelism Key: FLINK-3020 URL: https://issues.apache.org/jira/browse/FLINK-3020

Re: How to use static data with streams?

2015-11-16 Thread Kashmar, Ali
Hi Robert, Thanks for the help! I’ve managed to implement my use case using your suggested approach of combining the streams. Just a follow up on 2b) below, I’m not clear on this statement "partition (split) the data stream so that the right protocol packets end up at the right machine”. How do I

[jira] [Created] (FLINK-3019) CLI does not list running/restarting jobs

2015-11-16 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3019: -- Summary: CLI does not list running/restarting jobs Key: FLINK-3019 URL: https://issues.apache.org/jira/browse/FLINK-3019 Project: Flink Issue Type: Bug

Re: Re: Storm Compatibility

2015-11-16 Thread Maximilian Michels
You are right in saying that both API approaches support executing Storm jobs. However, I think the proposed changes make it much easier to reuse Storm topologies. And here is why: 1. No existing classes need to be exchanged. A Storm topology stays like it is. If you already have it defined somew

Re: Apache Flink 0.10.0 released

2015-11-16 Thread Slim Baltagi
Hi I’m very pleased to be first to tweet about the release of Apache Flink 0.10.0 just after receiving Fabian’s email :) Flink 1.0 is around the corner now! Slim Baltagi On Nov 16, 2015, at 7:53 AM, Fabian Hueske wrote: > Hi everybody, > > The Flink community is excited to announce that Apa

Apache Flink 0.10.0 released

2015-11-16 Thread Fabian Hueske
Hi everybody, The Flink community is excited to announce that Apache Flink 0.10.0 has been released. Please find the release announcement here: --> http://flink.apache.org/news/2015/11/16/release-0.10.0.html Best, Fabian

Re: Release notes for 0.10.0

2015-11-16 Thread Fabian Hueske
Hi everybody, thanks for your input and feedback. I updated the draft and published the release announcement a few minutes ago: --> http://flink.apache.org/news/2015/11/16/release-0.10.0.html Thanks, Fabian 2015-11-15 20:39 GMT+01:00 Alexander Alexandrov < alexander.s.alexand...@gmail.com>: >

[jira] [Created] (FLINK-3018) Job state discarded from web interface for restarting jobs

2015-11-16 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-3018: - Summary: Job state discarded from web interface for restarting jobs Key: FLINK-3018 URL: https://issues.apache.org/jira/browse/FLINK-3018 Project: Flink Issue Type