Stefan Richter created FLINK-9902:
-
Summary: Improve and refactor window checkpointing IT cases
Key: FLINK-9902
URL: https://issues.apache.org/jira/browse/FLINK-9902
Project: Flink
Issue Type
Kostas Kloudas created FLINK-9903:
-
Summary: Add support for bulk writers.
Key: FLINK-9903
URL: https://issues.apache.org/jira/browse/FLINK-9903
Project: Flink
Issue Type: Sub-task
Hi everyone,
I am currently dealing with an OOM issue caused by continuous queries in Flink
SQL (for example, a GROUP BY clause without a window). After looking into
Flink's Runtime & Core module, I found that as time goes by, StateTables in the
HeapKeyedStateBackend grows larger and larger, b
Hi,
>
> I am currently dealing with an OOM issue caused by continuous queries in
> Flink SQL (for example, a GROUP BY clause without a window). After looking
> into Flink's Runtime & Core module, I found that as time goes by, StateTables
> in the HeapKeyedStateBackend grows larger and larger,
Himanshu Roongta created FLINK-9904:
---
Summary: Allow users to control MaxDirectMemorySize
Key: FLINK-9904
URL: https://issues.apache.org/jira/browse/FLINK-9904
Project: Flink
Issue Type: Im
Gregory Fee created FLINK-9905:
--
Summary: ClassCastException:
org.apache.flink.streaming.runtime.streamrecord.LatencyMarker
Key: FLINK-9905
URL: https://issues.apache.org/jira/browse/FLINK-9905
Project:
Hi all,
We just merged on the master [FLINK-9753] (commit
66b1f854a0250bdd048808d40f93aa2990476841)
and [FLINK-9903] (commit b56c75ca375049b1d2c80d2d0945ae1ae04eb39e).
These two commits introduce:
1) a big refactoring to the new StreamingFileSink which allows it to support
bulk formats in gene
