[jira] [Created] (FLINK-15436) Add a hook of deserialized for pojo state object.

xiemeilong created FLINK-15436: -- Summary: Add a hook of deserialized for pojo state object. Key: FLINK-15436 URL: https://issues.apache.org/jira/browse/FLINK-15436 Project: Flink Issue Type: W

[jira] [Commented] (FLINK-15436) Add a hook of deserialized for pojo state object.

[ https://issues.apache.org/jira/browse/FLINK-15436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005883#comment-17005883 ] xiemeilong commented on FLINK-15436: [~yunta]  The recovery  need performed on every

[jira] [Commented] (FLINK-15436) Add a hook of deserialized for pojo state object.

[ https://issues.apache.org/jira/browse/FLINK-15436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005916#comment-17005916 ] xiemeilong commented on FLINK-15436: [~yunta]  Thanks you very much.      For exam

[jira] [Comment Edited] (FLINK-15436) Add a hook of deserialized for pojo state object.

[ https://issues.apache.org/jira/browse/FLINK-15436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005916#comment-17005916 ] xiemeilong edited comment on FLINK-15436 at 12/31/19 3:29 AM:

[jira] [Closed] (FLINK-15436) Add a hook of deserialized for pojo state object.

[ https://issues.apache.org/jira/browse/FLINK-15436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiemeilong closed FLINK-15436. -- Resolution: Won't Do > Add a hook of deserialized for pojo state object. > -

[jira] [Commented] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

[ https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082019#comment-17082019 ] xiemeilong commented on FLINK-16585: I have the same issue on cluster mode, but not

[jira] [Created] (FLINK-17108) Exception: Cannot determine simple type name "com"

xiemeilong created FLINK-17108: -- Summary: Exception: Cannot determine simple type name "com" Key: FLINK-17108 URL: https://issues.apache.org/jira/browse/FLINK-17108 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-17108) Exception: Cannot determine simple type name "com"

[ https://issues.apache.org/jira/browse/FLINK-17108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084563#comment-17084563 ] xiemeilong commented on FLINK-17108: Is there any workaround for this? > Exception:

[jira] [Created] (FLINK-17708) ScalarFunction has different classloader after submit task jar to cluster。

xiemeilong created FLINK-17708: -- Summary: ScalarFunction has different classloader after submit task jar to cluster。 Key: FLINK-17708 URL: https://issues.apache.org/jira/browse/FLINK-17708 Project: Flink

[jira] [Created] (FLINK-16269) Generic type can not be matched when convert table to stream.

xiemeilong created FLINK-16269: -- Summary: Generic type can not be matched when convert table to stream. Key: FLINK-16269 URL: https://issues.apache.org/jira/browse/FLINK-16269 Project: Flink Is

[jira] [Commented] (FLINK-16269) Generic type can not be matched when convert table to stream.

[ https://issues.apache.org/jira/browse/FLINK-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105934#comment-17105934 ] xiemeilong commented on FLINK-16269: After upgrade to 1.10.1,  a new type mismatch o

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105982#comment-17105982 ] xiemeilong commented on FLINK-16662: After upgrade to 1.10.1, a similar issue occurr

[jira] [Commented] (FLINK-16269) Generic type can not be matched when convert table to stream.

[ https://issues.apache.org/jira/browse/FLINK-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106831#comment-17106831 ] xiemeilong commented on FLINK-16269: [~jark] Is it the same issue or related? > Gen

[jira] [Comment Edited] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105982#comment-17105982 ] xiemeilong edited comment on FLINK-16662 at 5/14/20, 5:08 AM:

[jira] [Created] (FLINK-17683) Pojo with no-args constructor will be treated as ROW when returned by ScalarFunction， but not when it is a field of case class.

xiemeilong created FLINK-17683: -- Summary: Pojo with no-args constructor will be treated as ROW when returned by ScalarFunction， but not when it is a field of case class. Key: FLINK-17683 URL: https://issues.apache.or

[jira] [Commented] (FLINK-16269) Generic type can not be matched when convert table to stream.

[ https://issues.apache.org/jira/browse/FLINK-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106933#comment-17106933 ] xiemeilong commented on FLINK-16269: [~jark]   [FLINK-17683 | https://issues.apache.

[jira] [Commented] (FLINK-17708) ScalarFunction has different classloader after submit task jar to cluster。

[ https://issues.apache.org/jira/browse/FLINK-17708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123547#comment-17123547 ] xiemeilong commented on FLINK-17708: [~zhanglibing1...@126.com]  No other people wat

[jira] [Comment Edited] (FLINK-17708) ScalarFunction has different classloader after submit task jar to cluster。

[ https://issues.apache.org/jira/browse/FLINK-17708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123547#comment-17123547 ] xiemeilong edited comment on FLINK-17708 at 6/2/20, 9:16 AM: -

[jira] [Commented] (FLINK-17708) ScalarFunction has different classloader after submit task jar to cluster。

[ https://issues.apache.org/jira/browse/FLINK-17708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123604#comment-17123604 ] xiemeilong commented on FLINK-17708: Yes, this error happened on  1.10.1.  This issu

[jira] [Commented] (FLINK-17708) ScalarFunction has different classloader after submit task jar to cluster。

[ https://issues.apache.org/jira/browse/FLINK-17708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124731#comment-17124731 ] xiemeilong commented on FLINK-17708: Sorry，I only upgraded the jar，but forgot to upg

[jira] [Closed] (FLINK-17708) ScalarFunction has different classloader after submit task jar to cluster。

[ https://issues.apache.org/jira/browse/FLINK-17708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiemeilong closed FLINK-17708. -- Resolution: Not A Bug > ScalarFunction has different classloader after submit task jar to cluster。 > -