[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-27 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694062#comment-17694062 ] Weijie Guo commented on FLINK-29816: release 1.17 via 65e455189d2a88fd62be2e8a464feab4687ee088. >

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-26 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693756#comment-17693756 ] Rui Fan commented on FLINK-29816: - Thanks [~RocMarshal] for your contribution, and [~Weijie Guo]

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-22 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692250#comment-17692250 ] Rui Fan commented on FLINK-29816: - Hi [~Weijie Guo] , thanks for your reminder. I have requested them,

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692227#comment-17692227 ] Weijie Guo commented on FLINK-29816: [~fanrui] If we prefer to fix it in the first way (that is,

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-22 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692203#comment-17692203 ] Rui Fan commented on FLINK-29816: - Hi [~Weijie Guo] [~RocMarshal] , thanks for your analysis and PR.

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692108#comment-17692108 ] Weijie Guo commented on FLINK-29816: Thanks [~RocMarshal] for your analysis. It is a good proposal

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-22 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692057#comment-17692057 ] RocMarshal commented on FLINK-29816: As described in the historical comments and description text,

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691341#comment-17691341 ] Weijie Guo commented on FLINK-29816: [~RocMarshal]You are assigned. > Userfunction exception in

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691339#comment-17691339 ] RocMarshal commented on FLINK-29816: [~Weijie Guo] thanks for the reply. I'm interested in it. May I

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691137#comment-17691137 ] Weijie Guo commented on FLINK-29816: [~RocMarshal] Thanks for the reminder. TBH, I don't have time

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691132#comment-17691132 ] RocMarshal commented on FLINK-29816: hi, [~Weijie Guo] Any process on this issue ?  > Userfunction

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2022-11-17 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635247#comment-17635247 ] Yingjie Cao commented on FLINK-29816: - Any update on this issue? > Userfunction exception in

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2022-11-01 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627450#comment-17627450 ] Weijie Guo commented on FLINK-29816: # Because the restored channel can work normally in this stage,

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2022-11-01 Thread Xie Yi (Jira)
[ 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.

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2022-11-01 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627442#comment-17627442 ] Weijie Guo commented on FLINK-29816: [~xieyi] Yes,This phenomenon is normal. When restoring, the

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2022-11-01 Thread Xie Yi (Jira)
[ 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   

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2022-11-01 Thread Xie Yi (Jira)
[ 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,

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2022-11-01 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627061#comment-17627061 ] Weijie Guo commented on FLINK-29816: [~xieyi] Thanks for reporting this, what version of flink do