[jira] [Created] (FLINK-2686) Extend JSON plan dump to contain channel info

Ufuk Celebi created FLINK-2686: -- Summary: Extend JSON plan dump to contain channel info Key: FLINK-2686 URL: https://issues.apache.org/jira/browse/FLINK-2686 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

Greg Hogan created FLINK-2685: - Summary: TaskManager deadlock on NetworkBufferPool Key: FLINK-2685 URL: https://issues.apache.org/jira/browse/FLINK-2685 Project: Flink Issue Type: Bug C

Re: Streaming KV store abstraction

I think that is actually a cool way to kick of an addition to the system. Gives you a lot of flexibility and releasing and testing... It helps, though, to upload maven artifacts for it! On Tue, Sep 15, 2015 at 7:18 PM, Gyula Fóra wrote: > Hey All, > > We decided to make this a standalone librar

[jira] [Created] (FLINK-2684) Make TypeInformation non-serializable again by removing Table API's need for it

Till Rohrmann created FLINK-2684: Summary: Make TypeInformation non-serializable again by removing Table API's need for it Key: FLINK-2684 URL: https://issues.apache.org/jira/browse/FLINK-2684 Project

Re: Streaming KV store abstraction

Hey All, We decided to make this a standalone library until it is stable enough and then we can decide whether we want to keep it like that or include in the project: https://github.com/gyfora/StreamKV Cheers, Gyula Gianmarco De Francisci Morales ezt írta (időpont: 2015. szept. 9., Sze, 20:25)

CompactingHashTable question

Hello to my squirrels, I ran into an NPE for some iterations code and it looks like what's described in FLINK-2443 . I'm trying to understand the problem and I could really use your help :) So far, it seems that the exception is caused by a null v

[jira] [Created] (FLINK-2683) Add utilities for heap-backed keyed state in time panes

Stephan Ewen created FLINK-2683: --- Summary: Add utilities for heap-backed keyed state in time panes Key: FLINK-2683 URL: https://issues.apache.org/jira/browse/FLINK-2683 Project: Flink Issue Typ

[jira] [Created] (FLINK-2682) Add a dedicated processing time aligned keyed window operator

Stephan Ewen created FLINK-2682: --- Summary: Add a dedicated processing time aligned keyed window operator Key: FLINK-2682 URL: https://issues.apache.org/jira/browse/FLINK-2682 Project: Flink Is

[jira] [Created] (FLINK-2681) Scala API does not support Either type to be used as key

Till Rohrmann created FLINK-2681: Summary: Scala API does not support Either type to be used as key Key: FLINK-2681 URL: https://issues.apache.org/jira/browse/FLINK-2681 Project: Flink Issue

[jira] [Created] (FLINK-2680) Create a dedicated aligned-event time window operator

Stephan Ewen created FLINK-2680: --- Summary: Create a dedicated aligned-event time window operator Key: FLINK-2680 URL: https://issues.apache.org/jira/browse/FLINK-2680 Project: Flink Issue Type:

[jira] [Created] (FLINK-2679) Scala API does not support Try type as keys

Till Rohrmann created FLINK-2679: Summary: Scala API does not support Try type as keys Key: FLINK-2679 URL: https://issues.apache.org/jira/browse/FLINK-2679 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-2678) Java/Scala API does not support multi-dimensional arrays as keys

Till Rohrmann created FLINK-2678: Summary: Java/Scala API does not support multi-dimensional arrays as keys Key: FLINK-2678 URL: https://issues.apache.org/jira/browse/FLINK-2678 Project: Flink

[jira] [Created] (FLINK-2677) Add a general-purpose keyed-window operator

Stephan Ewen created FLINK-2677: --- Summary: Add a general-purpose keyed-window operator Key: FLINK-2677 URL: https://issues.apache.org/jira/browse/FLINK-2677 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2676) Add abstraction for keyed window state

Stephan Ewen created FLINK-2676: --- Summary: Add abstraction for keyed window state Key: FLINK-2676 URL: https://issues.apache.org/jira/browse/FLINK-2676 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2675) Add utilities for scheduled triggers

Stephan Ewen created FLINK-2675: --- Summary: Add utilities for scheduled triggers Key: FLINK-2675 URL: https://issues.apache.org/jira/browse/FLINK-2675 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2674) Rework windowing logic

Stephan Ewen created FLINK-2674: --- Summary: Rework windowing logic Key: FLINK-2674 URL: https://issues.apache.org/jira/browse/FLINK-2674 Project: Flink Issue Type: Bug Components: Stre

[jira] [Created] (FLINK-2673) Scala API does not support Option type as key

Till Rohrmann created FLINK-2673: Summary: Scala API does not support Option type as key Key: FLINK-2673 URL: https://issues.apache.org/jira/browse/FLINK-2673 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-2672) Add partitioned output format to HDFS RollingSink

Mohamed Amine ABDESSEMED created FLINK-2672: --- Summary: Add partitioned output format to HDFS RollingSink Key: FLINK-2672 URL: https://issues.apache.org/jira/browse/FLINK-2672 Project: Flink

[jira] [Created] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

Matthias J. Sax created FLINK-2671: -- Summary: Instable Test StreamCheckpointNotifierITCase Key: FLINK-2671 URL: https://issues.apache.org/jira/browse/FLINK-2671 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-2670) Instable Test S3FileSystemTest

Matthias J. Sax created FLINK-2670: -- Summary: Instable Test S3FileSystemTest Key: FLINK-2670 URL: https://issues.apache.org/jira/browse/FLINK-2670 Project: Flink Issue Type: Bug Co