[jira] [Created] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

zhouli created FLINK-34133: -- Summary: Merge MiniBatchInterval when propagate traits to child block Key: FLINK-34133 URL: https://issues.apache.org/jira/browse/FLINK-34133 Project: Flink Issue Type:

[jira] [Updated] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

[ https://issues.apache.org/jira/browse/FLINK-34133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhouli updated FLINK-34133: --- Description:   we should merge MiniBatchInterval when propagate traits to child block, otherwise we may ge

[jira] [Updated] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

[ https://issues.apache.org/jira/browse/FLINK-34133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhouli updated FLINK-34133: --- Attachment: image-2024-01-17-20-34-30-039.png > Merge MiniBatchInterval when propagate traits to child block

[jira] [Updated] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

[ https://issues.apache.org/jira/browse/FLINK-34133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhouli updated FLINK-34133: --- Attachment: (was: MinibatchIntervalTest.java) > Merge MiniBatchInterval when propagate traits to child b

[jira] [Updated] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

[ https://issues.apache.org/jira/browse/FLINK-34133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhouli updated FLINK-34133: --- Attachment: StreamWindowSQLExample.java > Merge MiniBatchInterval when propagate traits to child block > ---

[jira] [Updated] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

[ https://issues.apache.org/jira/browse/FLINK-34133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhouli updated FLINK-34133: --- Attachment: plan.txt > Merge MiniBatchInterval when propagate traits to child block > --

[jira] [Commented] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

[ https://issues.apache.org/jira/browse/FLINK-34133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807965#comment-17807965 ] zhouli commented on FLINK-34133: Hi [~xuyangzhong] , I have put the code and plan in the

[jira] [Created] (FLINK-33659) Avoid unnecessary retries when restore from savepoint failed.

zhouli created FLINK-33659: -- Summary: Avoid unnecessary retries when restore from savepoint failed. Key: FLINK-33659 URL: https://issues.apache.org/jira/browse/FLINK-33659 Project: Flink Issue Type

[jira] [Commented] (FLINK-33659) Avoid unnecessary retries when restore from savepoint failed.

[ https://issues.apache.org/jira/browse/FLINK-33659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789974#comment-17789974 ] zhouli commented on FLINK-33659: Hi, [~zhuzh] , wdyt ? > Avoid unnecessary retries when

[jira] [Closed] (FLINK-33659) Avoid unnecessary retries when restore from savepoint failed.

[ https://issues.apache.org/jira/browse/FLINK-33659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhouli closed FLINK-33659. -- Resolution: Invalid > Avoid unnecessary retries when restore from savepoint failed. >

[jira] (FLINK-33659) Avoid unnecessary retries when restore from savepoint failed.

[ https://issues.apache.org/jira/browse/FLINK-33659 ] zhouli deleted comment on FLINK-33659: was (Author: leo zhou): Hi, [~zhuzh] , wdyt ? > Avoid unnecessary retries when restore from savepoint failed. > ---

[jira] [Commented] (FLINK-28619) flink sql window aggregation using early fire will produce empty data

[ https://issues.apache.org/jira/browse/FLINK-28619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569257#comment-17569257 ] zhouli commented on FLINK-28619: when using upsert-kafka as a sink, it  will write DELET

[jira] [Comment Edited] (FLINK-28619) flink sql window aggregation using early fire will produce empty data

[ https://issues.apache.org/jira/browse/FLINK-28619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569257#comment-17569257 ] zhouli edited comment on FLINK-28619 at 7/21/22 3:56 AM: - when u

[jira] [Updated] (FLINK-26692) migrate TpcdsTestProgram.java to new source

[ https://issues.apache.org/jira/browse/FLINK-26692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhouli updated FLINK-26692: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > migrate TpcdsTestProgram.java

[jira] [Commented] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

[ https://issues.apache.org/jira/browse/FLINK-28227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564750#comment-17564750 ] zhouli commented on FLINK-28227: Hi [~afedulov] ，if you don't mind, I'd like to take thi

[jira] [Commented] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

[ https://issues.apache.org/jira/browse/FLINK-28227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564840#comment-17564840 ] zhouli commented on FLINK-28227: Thanks, [~martijnvisser] . > Add implementations for c

[jira] [Commented] (FLINK-28056) Introduce high level API for cases that do not require specific SourceEnumerator logic.

[ https://issues.apache.org/jira/browse/FLINK-28056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564842#comment-17564842 ] zhouli commented on FLINK-28056: I'm working on FLINK-28227 now and found that it's woul

[jira] [Commented] (FLINK-28056) Introduce high level API for cases that do not require specific SourceEnumerator logic.

[ https://issues.apache.org/jira/browse/FLINK-28056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564846#comment-17564846 ] zhouli commented on FLINK-28056: Hi [~martijnvisser], IMO, the change is trivial，we just

[jira] [Commented] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

[ https://issues.apache.org/jira/browse/FLINK-28227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564935#comment-17564935 ] zhouli commented on FLINK-28227: [~afedulov] It's ok, looking forward to your nice work.

[jira] [Comment Edited] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

[ https://issues.apache.org/jira/browse/FLINK-28227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564935#comment-17564935 ] zhouli edited comment on FLINK-28227 at 7/11/22 11:12 AM: -- [~af