[jira] [Created] (FLINK-1595) Add a complex integration test for Streaming API

Gyula Fora created FLINK-1595: - Summary: Add a complex integration test for Streaming API Key: FLINK-1595 URL: https://issues.apache.org/jira/browse/FLINK-1595 Project: Flink Issue Type: Task

Re: [jira] [Created] (FLINK-1594) DataStreams don't support self-join

We have a join operator that is defined over windows in the data stream. So the problem is not with the join itself, but it seems that trying to apply this window-join with itself throws an error. On Fri, Feb 20, 2015 at 4:50 PM, Alexander Alexandrov < alexander.s.alexand...@gmail.com> wrote: > I

Stale Synchronous Parallel iterations in Flink

Hello Everyone,  I am Nam-Luc Tran, research Engineer at EURA NOVA [1]. Our research subjects cover distributed machine learning and we have been working on dataflow graph processing for a while now. We have been reading from you since Stratosphere :-) Our current research focuses on Stale Synchr

Re: [jira] [Created] (FLINK-1594) DataStreams don't support self-join

I guess the intended behavior here is to just throw a nicer error, as you cannot really join two data streams. 2015-02-20 16:41 GMT+01:00 Daniel Bali (JIRA) : > Daniel Bali created FLINK-1594: > -- > > Summary: DataStreams don't support self-join >

[jira] [Created] (FLINK-1594) DataStreams don't support self-join

Daniel Bali created FLINK-1594: -- Summary: DataStreams don't support self-join Key: FLINK-1594 URL: https://issues.apache.org/jira/browse/FLINK-1594 Project: Flink Issue Type: Bug Compo

[jira] [Created] (FLINK-1593) Improve exception handling int Streaming runtime

Gyula Fora created FLINK-1593: - Summary: Improve exception handling int Streaming runtime Key: FLINK-1593 URL: https://issues.apache.org/jira/browse/FLINK-1593 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-1592) Refactor StreamGraph to store vertex IDs as Integers instead of Strings

Gyula Fora created FLINK-1592: - Summary: Refactor StreamGraph to store vertex IDs as Integers instead of Strings Key: FLINK-1592 URL: https://issues.apache.org/jira/browse/FLINK-1592 Project: Flink

[jira] [Created] (FLINK-1591) Remove window merge before flatten as an optimization

Gyula Fora created FLINK-1591: - Summary: Remove window merge before flatten as an optimization Key: FLINK-1591 URL: https://issues.apache.org/jira/browse/FLINK-1591 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-1590) Log environment information also in YARN mode

Robert Metzger created FLINK-1590: - Summary: Log environment information also in YARN mode Key: FLINK-1590 URL: https://issues.apache.org/jira/browse/FLINK-1590 Project: Flink Issue Type: Imp

Re: Question about Hadoop profiles in POM

Thanks for the answers! I didn't set the scope to provided, but now I will make that change. Regards, Daniel 2015-02-20 14:27 GMT+01:00 Aljoscha Krettek : > Did you set the scope to provided? As in: > > >com.google.guava >guava >${guava.version} >provided > > > Then this shoul

Re: Question about Hadoop profiles in POM

Did you set the scope to provided? As in: com.google.guava guava ${guava.version} provided Then this should be a good solution, yes. On Fri, Feb 20, 2015 at 1:05 PM, Dániel Bali wrote: > Hi! > > I was working on FLINK-1522 > and F

Re: Question about Hadoop profiles in POM

Hey Daniel, welcome to the shady world of shading maven dependencies (and Hadoop not shading its super old guava version ;) ). I'll have a look at your branch. I think Aljoscha added the guava dependency for the test scope of the hadoop1 profile. He made this change when he moved the HadoopInputF

Question about Hadoop profiles in POM

Hi! I was working on FLINK-1522 and FLINK-1576 and started converting Gelly library examples to work with file inputs. I added a test for LabelPropagationExample and got failures in Travis when ha

[jira] [Created] (FLINK-1589) Add option to pass Configuration to LocalExecutor

Robert Metzger created FLINK-1589: - Summary: Add option to pass Configuration to LocalExecutor Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type:

[jira] [Created] (FLINK-1588) Load flink configuration also from classloader

Robert Metzger created FLINK-1588: - Summary: Load flink configuration also from classloader Key: FLINK-1588 URL: https://issues.apache.org/jira/browse/FLINK-1588 Project: Flink Issue Type: Ne