[jira] [Updated] (FLINK-35119) UPDATE DataChangeEvent deserialized data is incorrect

[ https://issues.apache.org/jira/browse/FLINK-35119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qishang Zhong updated FLINK-35119: -- Description: When DebeziumChangelogMode is upsert, the before of DataChangeEvent is null,

[jira] [Created] (FLINK-35119) UPDATE DataChangeEvent deserialized data is incorrect

Qishang Zhong created FLINK-35119: - Summary: UPDATE DataChangeEvent deserialized data is incorrect Key: FLINK-35119 URL: https://issues.apache.org/jira/browse/FLINK-35119 Project: Flink

[jira] [Updated] (FLINK-35119) UPDATE DataChangeEvent deserialized data is incorrect

[ https://issues.apache.org/jira/browse/FLINK-35119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qishang Zhong updated FLINK-35119: -- Description: When DebeziumChangelogMode is upsert, the before of DataChangeEvent is null,

[jira] [Comment Edited] (FLINK-34948) CDC RowType can not convert to flink row type

[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831316#comment-17831316 ] Qishang Zhong edited comment on FLINK-34948 at 3/27/24 12:06 PM: -

[jira] [Comment Edited] (FLINK-34948) CDC RowType can not convert to flink row type

[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831316#comment-17831316 ] Qishang Zhong edited comment on FLINK-34948 at 3/27/24 12:05 PM: -

[jira] [Updated] (FLINK-34948) CDC RowType can not convert to flink row type

[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qishang Zhong updated FLINK-34948: -- Summary: CDC RowType can not convert to flink row type (was: CDC RowType can not convert to

[jira] [Commented] (FLINK-34948) CDC RowType can not convert to flink type

[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831316#comment-17831316 ] Qishang Zhong commented on FLINK-34948: --- [~loserwang1024] There is no corresponding scenario in

[jira] [Updated] (FLINK-34948) CDC RowType can not convert to flink type

[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qishang Zhong updated FLINK-34948: -- Fix Version/s: cdc-3.1.0 > CDC RowType can not convert to flink type >

[jira] [Updated] (FLINK-34948) CDC RowType can not convert to flink type

[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qishang Zhong updated FLINK-34948: -- Affects Version/s: (was: cdc-3.1.0) > CDC RowType can not convert to flink type >

[jira] [Updated] (FLINK-34948) CDC RowType can not convert to flink type

[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qishang Zhong updated FLINK-34948: -- Affects Version/s: cdc-3.1.0 > CDC RowType can not convert to flink type >

[jira] [Created] (FLINK-34948) CDC RowType can not convert to flink type

Qishang Zhong created FLINK-34948: - Summary: CDC RowType can not convert to flink type Key: FLINK-34948 URL: https://issues.apache.org/jira/browse/FLINK-34948 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34905) The default length of CHAR/BINARY data type of Add column DDL

Qishang Zhong created FLINK-34905: - Summary: The default length of CHAR/BINARY data type of Add column DDL Key: FLINK-34905 URL: https://issues.apache.org/jira/browse/FLINK-34905 Project: Flink

[jira] [Commented] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577822#comment-17577822 ] Qishang Zhong commented on FLINK-28817: --- [~thw]  I tried to open a PR for this issue.

[jira] [Commented] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576669#comment-17576669 ] Qishang Zhong commented on FLINK-28817: --- I encountered the similar problem. [~thw] Please take a

[jira] [Commented] (FLINK-21573) Support expression reuse in codegen

[ https://issues.apache.org/jira/browse/FLINK-21573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17354966#comment-17354966 ] Qishang Zhong commented on FLINK-21573: --- [~lzljs3620320] Yes, I tried.  `isDeterministic` return

[jira] [Commented] (FLINK-21573) Support expression reuse in codegen

[ https://issues.apache.org/jira/browse/FLINK-21573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347654#comment-17347654 ] Qishang Zhong commented on FLINK-21573: --- Hi [~lzljs3620320] . In this case, UDF `split_str` will

[jira] [Commented] (FLINK-19873) Skip DDL change events for Canal data

[ https://issues.apache.org/jira/browse/FLINK-19873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317678#comment-17317678 ] Qishang Zhong commented on FLINK-19873: --- [~jark]   The ticket only skip `CREATE` type, I think we

[jira] [Closed] (FLINK-18277) Elasticsearch6DynamicSink#asSummaryString() return identifier typo

[ https://issues.apache.org/jira/browse/FLINK-18277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qishang Zhong closed FLINK-18277. - Resolution: Fixed > Elasticsearch6DynamicSink#asSummaryString() return identifier typo >

[jira] [Commented] (FLINK-18277) Elasticsearch6DynamicSink#asSummaryString() return identifier typo

[ https://issues.apache.org/jira/browse/FLINK-18277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134214#comment-17134214 ] Qishang Zhong commented on FLINK-18277: --- [~jark] can you assign to me and I will be familiar with

[jira] [Created] (FLINK-18277) Elasticsearch6DynamicSink#asSummaryString() return identifier typo

Qishang Zhong created FLINK-18277: - Summary: Elasticsearch6DynamicSink#asSummaryString() return identifier typo Key: FLINK-18277 URL: https://issues.apache.org/jira/browse/FLINK-18277 Project: Flink