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
[
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
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:
[
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
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
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:
[
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]
>
[
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):
[
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]
>
[
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]
>
[
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]
>
[
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
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
[
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
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
15 matches
Mail list logo