[jira] [Created] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-21 Thread Huang Wei (JIRA)
Huang Wei created FLINK-2391: Summary: Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException Key: FLINK-2391 URL: https://issues.apache.org/jira/browse/FLINK-2391

[jira] [Created] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination

2015-07-21 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2390: - Summary: Replace iteration timeout with algorithm for detecting termination Key: FLINK-2390 URL: https://issues.apache.org/jira/browse/FLINK-2390 Project: Flink I

[jira] [Created] (FLINK-2389) Add dashboard frontend architecture amd build infrastructue

2015-07-21 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2389: --- Summary: Add dashboard frontend architecture amd build infrastructue Key: FLINK-2389 URL: https://issues.apache.org/jira/browse/FLINK-2389 Project: Flink Issu

[jira] [Created] (FLINK-2388) JobManager should try retrieving jobs from archive

2015-07-21 Thread Enrique Bautista Barahona (JIRA)
Enrique Bautista Barahona created FLINK-2388: Summary: JobManager should try retrieving jobs from archive Key: FLINK-2388 URL: https://issues.apache.org/jira/browse/FLINK-2388 Project: Flin

[jira] [Created] (FLINK-2387) Add test for live accumulators in Streaming

2015-07-21 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-2387: - Summary: Add test for live accumulators in Streaming Key: FLINK-2387 URL: https://issues.apache.org/jira/browse/FLINK-2387 Project: Flink Issue Typ

[jira] [Created] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API

2015-07-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2386: - Summary: Implement Kafka connector using the new Kafka Consumer API Key: FLINK-2386 URL: https://issues.apache.org/jira/browse/FLINK-2386 Project: Flink Is

[jira] [Created] (FLINK-2385) Scala DataSet.distinct should have parenthesis

2015-07-21 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2385: --- Summary: Scala DataSet.distinct should have parenthesis Key: FLINK-2385 URL: https://issues.apache.org/jira/browse/FLINK-2385 Project: Flink Issue Type: Bug

Re: Communicating between nodes at runtime

2015-07-21 Thread Sachin Goel
@Stephan, why would there be a problem with the reliability of updates? Also, what would be the best way to achieve this functionality? Preferably using the current API. Cheers! Sachin -- Sachin Goel Computer Science, IIT Delhi m. +91-9871457685 On Tue, Jul 21, 2015 at 4:17 PM, Stephan Ewen wr

Re: Failing tests on Windows

2015-07-21 Thread Stephan Ewen
Thank you, we'll try to address these issues soon... On Fri, Jul 17, 2015 at 7:07 PM, Gábor Gévay wrote: > > BlobUtilsTest.before:45 null > > BlobUtilsTest.before:45 null > > BlobServerDeleteTest.testDeleteFails:291 null > > BlobLibraryCacheManagerTest.testRegisterAndDownload:196 Could n

Re: Error while deserializing event

2015-07-21 Thread Stephan Ewen
Hi! Actually, the lib folder should cover it - it contains all code, and that is what is relevant there. A common cause of such problems is version mismatches, meaning one node runs some code, another node other code. That sometimes happens when shared folders are not fully synced. Not sure if it

[jira] [Created] (FLINK-2383) Add new Window Operator that can use Timestamps/Watermarks

2015-07-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2383: --- Summary: Add new Window Operator that can use Timestamps/Watermarks Key: FLINK-2383 URL: https://issues.apache.org/jira/browse/FLINK-2383 Project: Flink

Re: Communicating between nodes at runtime

2015-07-21 Thread Stephan Ewen
I see the use case for that, but I don't think that this should be realized through Flink's network stack. The network stack is designed for continuous streams, backpressure, and configurable throughput/latency. I think it is not the best solution for asynchronous messaging. Also, for the ML field