[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] [Commented] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]

2018-07-03 Thread Josh Lemer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531680#comment-16531680 ] Josh Lemer commented on FLINK-9221: --- [~yanghua]You may be right. One reason why it may be wrong to put

[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:

[jira] [Updated] (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)
[ https://issues.apache.org/jira/browse/FLINK-9385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josh Lemer updated FLINK-9385: -- Component/s: Webfrontend Web Client Metrics > Operators with two

[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:

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

2018-04-19 Thread Josh Lemer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josh Lemer updated FLINK-9221: -- Component/s: DataSet API > Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] >

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

2018-04-19 Thread Josh Lemer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444250#comment-16444250 ] Josh Lemer commented on FLINK-9221: --- Fixed! > Add method SinkFunction[A]#contramap[B](f: B => A):

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

2018-04-19 Thread Josh Lemer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josh Lemer updated FLINK-9221: -- Labels: flink (was: ) > Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] >

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

2018-04-19 Thread Josh Lemer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josh Lemer updated FLINK-9221: -- Affects Version/s: 1.5.0 > Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] >

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

2018-04-19 Thread Josh Lemer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josh Lemer updated FLINK-9221: -- Component/s: DataStream API > Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] >

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

2018-04-19 Thread Josh Lemer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josh Lemer updated FLINK-9221: -- Description: Just like it is very useful to use `DataStream[T]` as a sort of Functor or Monad with

[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] [Commented] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2018-04-16 Thread Josh Lemer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16439956#comment-16439956 ] Josh Lemer commented on FLINK-7484: --- Hey there folks, are we all sure that this issue has been entirely

[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