[jira] [Created] (FLINK-11007) Update documentation to describe new checkpoint metadata file behavior

2018-11-26 Thread Josh Lemer (JIRA)
Josh Lemer created FLINK-11007: -- Summary: Update documentation to describe new checkpoint metadata file behavior Key: FLINK-11007 URL: https://issues.apache.org/jira/browse/FLINK-11007 Project: Flink

[jira] [Created] (FLINK-9396) Allow streaming sources (especially Files, Kafka) to set max queued input elements

2018-05-17 Thread Josh Lemer (JIRA)
Josh Lemer created FLINK-9396: - Summary: Allow streaming sources (especially Files, Kafka) to set max queued input elements Key: FLINK-9396 URL: https://issues.apache.org/jira/browse/FLINK-9396 Project: F

[jira] [Created] (FLINK-9385) Operators with two inputs should show "Records Received" in Web UI separately, rather than added together

2018-05-16 Thread Josh Lemer (JIRA)
Josh Lemer created FLINK-9385: - Summary: Operators with two inputs should show "Records Received" in Web UI separately, rather than added together Key: FLINK-9385 URL: https://issues.apache.org/jira/browse/FLINK-9385

[jira] [Created] (FLINK-9264) Add method Writer[A]#contramap[B](f: B => A): Writer[B]

2018-04-27 Thread Josh Lemer (JIRA)
Josh Lemer created FLINK-9264: - Summary: Add method Writer[A]#contramap[B](f: B => A): Writer[B] Key: FLINK-9264 URL: https://issues.apache.org/jira/browse/FLINK-9264 Project: Flink Issue Type: T

[jira] [Created] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]

2018-04-19 Thread Josh Lemer (JIRA)
Josh Lemer created FLINK-9221: - Summary: Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] Key: FLINK-9221 URL: https://issues.apache.org/jira/browse/FLINK-9221 Project: Flink

[jira] [Created] (FLINK-8440) Create Gitter Chanel for Flink users

2018-01-16 Thread Josh Lemer (JIRA)
Josh Lemer created FLINK-8440: - Summary: Create Gitter Chanel for Flink users Key: FLINK-8440 URL: https://issues.apache.org/jira/browse/FLINK-8440 Project: Flink Issue Type: Task Rep