[jira] [Created] (FLINK-5184) Error result of compareSerialized in RowComparator class

2016-11-28 Thread godfrey he (JIRA)
godfrey he created FLINK-5184: - Summary: Error result of compareSerialized in RowComparator class Key: FLINK-5184 URL: https://issues.apache.org/jira/browse/FLINK-5184 Project: Flink Issue Type:

[jira] [Created] (FLINK-5179) MetricRegistry life-cycle issues with HA

2016-11-28 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5179: --- Summary: MetricRegistry life-cycle issues with HA Key: FLINK-5179 URL: https://issues.apache.org/jira/browse/FLINK-5179 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5178) allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system

2016-11-28 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5178: -- Summary: allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system Key: FLINK-5178 URL: https://issues.apache.org/jira/browse/FLINK-5178 Project: Flink

[jira] [Created] (FLINK-5177) Improve nullability handling

2016-11-28 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5177: --- Summary: Improve nullability handling Key: FLINK-5177 URL: https://issues.apache.org/jira/browse/FLINK-5177 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5174) Fix memory leak in the CEP library.

2016-11-28 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5174: - Summary: Fix memory leak in the CEP library. Key: FLINK-5174 URL: https://issues.apache.org/jira/browse/FLINK-5174 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5173) Upgrade RocksDB dependency

2016-11-28 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5173: --- Summary: Upgrade RocksDB dependency Key: FLINK-5173 URL: https://issues.apache.org/jira/browse/FLINK-5173 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-5172) In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided"

2016-11-28 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5172: --- Summary: In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided" Key: FLINK-5172 URL: https://issues.apache.org/jira/browse/FLINK-5172 Project:

Re: Window's Checkpoint problem

2016-11-28 Thread Till Rohrmann
Hi 时某人, I think you've found an inconsistency in Flink's windowing API (but it's the same in the Java API). Handling operator state in the context of windows is a little bit delicate because you could have multiple windows in flight, though. I've pulled Aljoscha in this thread who is more

[jira] [Created] (FLINK-5171) Wrong use of Preconditions.checkState in TaskManagerRunner

2016-11-28 Thread shuai.xu (JIRA)
shuai.xu created FLINK-5171: --- Summary: Wrong use of Preconditions.checkState in TaskManagerRunner Key: FLINK-5171 URL: https://issues.apache.org/jira/browse/FLINK-5171 Project: Flink Issue Type:

[jira] [Created] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified

2016-11-28 Thread shuai.xu (JIRA)
shuai.xu created FLINK-5170: --- Summary: getAkkaConfig will use localhost if hostname is specified Key: FLINK-5170 URL: https://issues.apache.org/jira/browse/FLINK-5170 Project: Flink Issue Type:

[jira] [Created] (FLINK-5169) Make consumption of input channels fair

2016-11-28 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5169: -- Summary: Make consumption of input channels fair Key: FLINK-5169 URL: https://issues.apache.org/jira/browse/FLINK-5169 Project: Flink Issue Type: Improvement