Re: [DISCUSS] Deprecate Spargel API for 0.9

2015-03-11 Thread Vasiliki Kalavri
Thanks for the input everyone! If no objections, I will open an issue for deprecating the Spargel API tomorrow. Cheers, V. On 11 March 2015 at 15:59, Fabian Hueske wrote: > +1 for deprecating > > 2015-03-11 14:11 GMT+01:00 Kostas Tzoumas : > > > +1 for deprecating and pointing people to Gelly >

Re: [DISCUSS] Offer Flink with Scala 2.11

2015-03-11 Thread Robert Metzger
Thank you for opening the pull request. It looks great so far. There came up one question while discussing Alex changes in the PR: To make this change really usable for our users, we need to provide our users with different poms for each artifact, containing either Scala 2.10 or 2.11. Its basicall

Re: Could not build up connection to JobManager

2015-03-11 Thread Till Rohrmann
Hi Dulaj, sorry for my late response. It looks as if the JobClient tries to connect to the JobManager using its IPv6 instead of IPv4. Akka is really picky when it comes to remote address. If Akka binds to the FQDN, then other ActorSystem which try to connect to it using its IP address won't be suc

[jira] [Created] (FLINK-1691) Inprove CountCollectITCase

2015-03-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1691: --- Summary: Inprove CountCollectITCase Key: FLINK-1691 URL: https://issues.apache.org/jira/browse/FLINK-1691 Project: Flink Issue Type: Bug Components:

Re: [DISCUSS] Deprecate Spargel API for 0.9

2015-03-11 Thread Kostas Tzoumas
+1 for deprecating and pointing people to Gelly On Wed, Mar 11, 2015 at 10:30 AM, Ufuk Celebi wrote: > > On 10 Mar 2015, at 22:02, Vasiliki Kalavri > wrote: > > > Hi all, > > > > I would like your opinion on whether we should deprecate the Spargel API > in > > 0.9. > > > > Gelly doesn't depend

[jira] [Created] (FLINK-1686) Streaming iteration heads cannot be instantiated

2015-03-11 Thread Paris Carbone (JIRA)
Paris Carbone created FLINK-1686: Summary: Streaming iteration heads cannot be instantiated Key: FLINK-1686 URL: https://issues.apache.org/jira/browse/FLINK-1686 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-1685) Document how to read gzip/compressed files with Flink

2015-03-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1685: - Summary: Document how to read gzip/compressed files with Flink Key: FLINK-1685 URL: https://issues.apache.org/jira/browse/FLINK-1685 Project: Flink Issue T

Re: [DISCUSS] Deprecate Spargel API for 0.9

2015-03-11 Thread Ufuk Celebi
On 10 Mar 2015, at 22:02, Vasiliki Kalavri wrote: > Hi all, > > I would like your opinion on whether we should deprecate the Spargel API in > 0.9. > > Gelly doesn't depend on Spargel, it actually contains it -- we have copied > the relevant classes over. I think it would be a good idea to depr

[jira] [Created] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on

2015-03-11 Thread JIRA
Gábor Hermann created FLINK-1684: Summary: Make Kafka connectors read/write a partition the worker is on Key: FLINK-1684 URL: https://issues.apache.org/jira/browse/FLINK-1684 Project: Flink

Re: [DISCUSS] Deprecate Spargel API for 0.9

2015-03-11 Thread Alexander Alexandrov
+1 2015-03-11 9:41 GMT+01:00 Till Rohrmann : > If Spargel's functionality is a subset of Gelly, I'm also in favor of a > deprecation. This will direct new users directly to Gelly and gives old > ones time to adapt their code. > > On Wed, Mar 11, 2015 at 1:56 AM, Henry Saputra > wrote: > > > Than

Re: [DISCUSS] Deprecate Spargel API for 0.9

2015-03-11 Thread Till Rohrmann
If Spargel's functionality is a subset of Gelly, I'm also in favor of a deprecation. This will direct new users directly to Gelly and gives old ones time to adapt their code. On Wed, Mar 11, 2015 at 1:56 AM, Henry Saputra wrote: > Thanks for bringing up for discussion, Vasia > > > I am +1 for de