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
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
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:
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
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
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 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
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
Thank you, we'll try to address these issues soon...
On Fri, Jul 17, 2015 at 7:07 PM, Gábor Gévay gga...@gmail.com wrote:
BlobUtilsTest.before:45 null
BlobUtilsTest.before:45 null
BlobServerDeleteTest.testDeleteFails:291 null
