Great!
If you send me your JIRA user I can add you as a contributor and assign the
issue to you.
Best, Fabian
Von: jaxbihani
Hi,
a regular tumbling time window of 5 seconds gets all elements within that
period of time (semantics of time varies for processing, ingestion, and event
time modes) and triggers the execution after 5 seconds.
If you define a custom trigger, the assignment policy remains the same, but the
t
Do you want to move the folder within a running job? This might cause a lot of
problems, because you cannot (easily) control when a move command would be
executed.
Wouldn’t it be a better idea to do that after a job is finished and use the
regular HDFS client?
From: Flavio Pompermaier
Se
Hi,
aggregate performs an in-place aggregation, i.e., the input and output type of
aggregate() is identical, but the aggregated fields are updated.
Causion: All fields that are not associated with an aggregation function and
are not not a grouping field have non-deterministic values. That mea
Thank you very much!
From: Hilmi Yildirim
Sent: Tuesday, 9. June, 2015 11:40
To: user@flink.apache.org
Done
https://issues.apache.org/jira/browse/FLINK-2188
Am 09.06.2015 um 11:26 schrieb Fabian Hueske:
Would you mind opening a JIRA for this issue?
-> https://issues.apa
