[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xie Yi updated FLINK-29816:
---
Description:
h4. 1. How to repeat
ProcessWindowFunction, and make some exception in process()
test code
Xie Yi created FLINK-29816:
--
Summary: Userfunction exception in ProcessWindowFunction was
called before invoke during restore state(subtask was in INITIALIZING state),
but SteamTask skip handle Exception
Key: FLINK-29816
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627428#comment-17627428
]
Xie Yi edited comment on FLINK-29816 at 11/2/22 3:10 AM:
-
I also found some
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627420#comment-17627420
]
Xie Yi edited comment on FLINK-29816 at 11/2/22 3:11 AM:
-
[~Weijie Guo] I
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627428#comment-17627428
]
Xie Yi edited comment on FLINK-29816 at 11/2/22 2:57 AM:
-
I also found some
[ https://issues.apache.org/jira/browse/FLINK-29816 ]
Xie Yi deleted comment on FLINK-29816:
was (Author: xieyi):
I have some confusions
1. Why registerTimer during restoreGate?
2. Why Userfunction in ProcessWindowFunction is desinged to be
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627428#comment-17627428
]
Xie Yi commented on FLINK-29816:
I also found some phenomenon
h4. h4. 1. userfunction in
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627428#comment-17627428
]
Xie Yi edited comment on FLINK-29816 at 11/2/22 3:11 AM:
-
I also found some
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627420#comment-17627420
]
Xie Yi commented on FLINK-29816:
I didn't use unalignCheckpoint, I had test flink 1.14.0, 1.15.2,
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xie Yi updated FLINK-29816:
---
Attachment: image-2022-11-02-10-42-21-099.png
> Userfunction exception in ProcessWindowFunction was called
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627443#comment-17627443
]
Xie Yi commented on FLINK-29816:
I have some confusions
1. Why registerTimer during restoreGate?
2.
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xie Yi updated FLINK-29816:
---
Description:
h4. 1. How to repeat
ProcessWindowFunction, and make some exception in process()
test code
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xie Yi updated FLINK-29816:
---
Affects Version/s: 1.14.0
> Userfunction exception in ProcessWindowFunction was called before invoke
>
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xie Yi updated FLINK-29816:
---
Description:
h4. 1. How to repeat
ProcessWindowFunction, and make some exception in process()
test code
Xie Yi created FLINK-35244:
--
Summary: Move package for flink-connector-tidb-cdc test
Key: FLINK-35244
URL: https://issues.apache.org/jira/browse/FLINK-35244
Project: Flink
Issue Type: Improvement
Xie Yi created FLINK-35245:
--
Summary: Add metrics for flink-connector-tidb-cdc
Key: FLINK-35245
URL: https://issues.apache.org/jira/browse/FLINK-35245
Project: Flink
Issue Type: Improvement
16 matches
Mail list logo