[DISCUSS]Why not emit messages to prevent too early state eviction in MiniBatchGroupAggFunction?

When using SELECT DISTINCT in Flink SQL I found that when a new message with the same key arrives, it will emit a retract and a new insert message. According to JIRA-FLINK-8566 and JIRA-FLINK-8564

Re: [VOTE] Add Translation Specification for Stateful Functions

+1 A specification really matters for the translation quality. -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

Re: [DISCUSS]Why not emit messages to prevent too early state eviction in MiniBatchGroupAggFunction?

Hi Benchao, Thank you for your confirmation. I created an issue for this bug as Flink-19592 (https://issues.apache.org/jira/browse/FLINK-19592) - Best wishes. Smile -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

[DISCUSS]Select Chinese words from table union all get java.lang.OutOfMemoryError: Java heap space on Flink 1.9.x with Blink planner

in Flink 1.11.2 with some new syntax:* ----- Best wishes. Smile -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

Re: [DISCUSS]Select Chinese words from table union all get java.lang.OutOfMemoryError: Java heap space on Flink 1.9.x with Blink planner

"UNION ALL\n" + "SELECT\n" + "'another_text' AS text,\n" + "'中文' AS another_text\n" +

[jira] [Created] (FLINK-19592) MiniBatchGroupAggFunction should emit messages to prevent too early state eviction of downstream operators

Smile created FLINK-19592: - Summary: MiniBatchGroupAggFunction should emit messages to prevent too early state eviction of downstream operators Key: FLINK-19592 URL: https://issues.apache.org/jira/browse/FLINK-19592

[jira] [Created] (FLINK-27087) Configuration "taskmanager.network.detailed-metrics" in metrics document was mistaken as "taskmanager.net.detailed-metrics"

Smile created FLINK-27087: - Summary: Configuration "taskmanager.network.detailed-metrics" in metrics document was mistaken as "taskmanager.net.detailed-metrics" Key: FLINK-27087 URL: https://issues.ap