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:
[
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
[
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
[
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
[
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
> ---
[
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
> --
[
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
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
[
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
[
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.
>
[ 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.
> ---
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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.
[
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
20 matches
Mail list logo