Hi,
I have a use case where I need to get UniqueId of an operator inside a
stream. DataStream's getId() returns the ID of the stream but I have
operator partitioned (say partitionByHash) inside the datastream. So I
would like to get unique ID for each operator working in parallel. Is there
a way in
Greg Hogan created FLINK-3721:
-
Summary: Min and max accumulators
Key: FLINK-3721
URL: https://issues.apache.org/jira/browse/FLINK-3721
Project: Flink
Issue Type: New Feature
Components
Hi Greg,
I just pushed v1.0.0-rc2 for Peel to Sonatype.
As Till said, we are using the framework extensively at the TU for
benchmarking and comparing different systems (mostly Flink and Spark).
We recently used Peel to conduct some experiments for FLINK-2237. If you
want to learn more about the
Trevor Grant created FLINK-3720:
---
Summary: Add warm starts for models
Key: FLINK-3720
URL: https://issues.apache.org/jira/browse/FLINK-3720
Project: Flink
Issue Type: Improvement
Comp
Niels Basjes created FLINK-3719:
---
Summary: WebInterface: Moving the barrier between graph and stats
Key: FLINK-3719
URL: https://issues.apache.org/jira/browse/FLINK-3719
Project: Flink
Issue Ty
Aljoscha Krettek created FLINK-3718:
---
Summary: Add Option For Completely Async Backup in RocksDB State
Backend
Key: FLINK-3718
URL: https://issues.apache.org/jira/browse/FLINK-3718
Project: Flink
Kostas Kloudas created FLINK-3717:
-
Summary: Add functionality to get the current offset of a source
with a FileInputFormat
Key: FLINK-3717
URL: https://issues.apache.org/jira/browse/FLINK-3717
Projec
Hi all,
I am currently working on some issues and been wondering if you have
settings for Intellij code style that would follow your coding guidelines
available (I tried to look on wikis but could not find it). If not could
someone share its own? I would be grateful.
Regards
Dawid Wysakowicz
