[jira] [Created] (FLINK-6283) Enable to clear a given file cache path

Zohar Mizrahi created FLINK-6283: Summary: Enable to clear a given file cache path Key: FLINK-6283 URL: https://issues.apache.org/jira/browse/FLINK-6283 Project: Flink Issue Type: Improvemen

Re: Flink limitations under Beam

Hi, I don’t have any hard numbers for this, and it depends on what kind of state backend is used (Heap backend or RocksDB backend). Iterations are documented in the Flink doc: https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/datastream_api.html#iterations

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

Hi Gyula, I'm trying to push Stefan R. to get the RocksDB fixes in asap. On Sat, Apr 8, 2017 at 5:17 PM, Gyula Fóra wrote: > Hi All, > > Any updates on this? > > It would be nice to get this out soon, the Kafka bug is hurting our prod > jobs big time. > > Thanks, > Gyula > > On Wed, Apr 5, 2017

[jira] [Created] (FLINK-6284) Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore

Xiaogang Shi created FLINK-6284: --- Summary: Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore Key: FLINK-6284 URL: https://issues.apache.org/jira/browse/FLINK-6284 Project:

[jira] [Created] (FLINK-6285) resolve hadoop-compatibility confusion

Petr Novotnik created FLINK-6285: Summary: resolve hadoop-compatibility confusion Key: FLINK-6285 URL: https://issues.apache.org/jira/browse/FLINK-6285 Project: Flink Issue Type: Bug Affe