[jira] [Updated] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly

2025-02-17 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] He Wang updated FLINK-37300: Description: Many data types in the database do not have a one-to-one correspondence with the data types

[jira] [Updated] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly

2025-02-17 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] He Wang updated FLINK-37300: Description: Many data types in the database do not have a one-to-one correspondence with the data types

[jira] [Closed] (FLINK-35508) Use OceanBase LTS version Docker image in testing

2025-02-11 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] He Wang closed FLINK-35508. --- Resolution: Fixed Now we are using version 4.2.1 lts and latest version after FLINK-35638 > Use OceanBase L

[jira] [Created] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly

2025-02-11 Thread He Wang (Jira)
He Wang created FLINK-37300: --- Summary: Add database native type information to Column struct to generate ddl correctly Key: FLINK-37300 URL: https://issues.apache.org/jira/browse/FLINK-37300 Project: Flink

[jira] [Created] (FLINK-37293) Length of Binary type is missing in OceanBase pipeline connector

2025-02-10 Thread He Wang (Jira)
He Wang created FLINK-37293: --- Summary: Length of Binary type is missing in OceanBase pipeline connector Key: FLINK-37293 URL: https://issues.apache.org/jira/browse/FLINK-37293 Project: Flink Issue

[jira] [Commented] (FLINK-37254) flink cdc的oceanbase cdc 存在表字段的默认值为default '0'抛出异常

2025-02-04 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923907#comment-17923907 ] He Wang commented on FLINK-37254: - Looks like the TableSchemaBuilder used in OceanBaseDa

[jira] [Created] (FLINK-36458) Use original 'OceanBaseCEContainer' of testcontainers in testing

2024-10-09 Thread He Wang (Jira)
He Wang created FLINK-36458: --- Summary: Use original 'OceanBaseCEContainer' of testcontainers in testing Key: FLINK-36458 URL: https://issues.apache.org/jira/browse/FLINK-36458 Project: Flink Issue

[jira] [Created] (FLINK-36024) Handle BinaryLogClient exceptions when searching for the starting binlog offset

2024-08-09 Thread He Wang (Jira)
He Wang created FLINK-36024: --- Summary: Handle BinaryLogClient exceptions when searching for the starting binlog offset Key: FLINK-36024 URL: https://issues.apache.org/jira/browse/FLINK-36024 Project: Flink

[jira] [Commented] (FLINK-35909) JdbcFilterPushdownPreparedStatementVisitorTest fails

2024-07-31 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869888#comment-17869888 ] He Wang commented on FLINK-35909: - I didn't notice this jira before, and I tried to subm

[jira] [Closed] (FLINK-34966) Support to read snapshot by table partitions in MySQL CDC Source

2024-07-16 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] He Wang closed FLINK-34966. --- Resolution: Won't Do > Support to read snapshot by table partitions in MySQL CDC Source > --

[jira] [Commented] (FLINK-34966) Support to read snapshot by table partitions in MySQL CDC Source

2024-07-16 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866600#comment-17866600 ] He Wang commented on FLINK-34966: - [~renqs] Sorry for the late reply. Once I wanted to e

[jira] [Commented] (FLINK-35137) Release flink-connector-jdbc v3.2.0 for Flink 1.19

2024-07-07 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863653#comment-17863653 ] He Wang commented on FLINK-35137: - [~dannycranmer]  Sorry I didn't make it clear, I was

[jira] [Commented] (FLINK-35137) Release flink-connector-jdbc v3.2.0 for Flink 1.19

2024-07-05 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863143#comment-17863143 ] He Wang commented on FLINK-35137: - Hi [~dannycranmer] , the website of version 3.2.0 doe

[jira] [Created] (FLINK-35638) Modify OceanBase Docker container to make the test cases runnable on non-Linux systems

2024-06-18 Thread He Wang (Jira)
He Wang created FLINK-35638: --- Summary: Modify OceanBase Docker container to make the test cases runnable on non-Linux systems Key: FLINK-35638 URL: https://issues.apache.org/jira/browse/FLINK-35638 Project:

[jira] [Created] (FLINK-35508) Use OceanBase LTS version Docker image in testing

2024-06-03 Thread He Wang (Jira)
He Wang created FLINK-35508: --- Summary: Use OceanBase LTS version Docker image in testing Key: FLINK-35508 URL: https://issues.apache.org/jira/browse/FLINK-35508 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-34966) Support to read snapshot by table partitions in MySQL CDC Source

2024-03-29 Thread He Wang (Jira)
He Wang created FLINK-34966: --- Summary: Support to read snapshot by table partitions in MySQL CDC Source Key: FLINK-34966 URL: https://issues.apache.org/jira/browse/FLINK-34966 Project: Flink Issue

[jira] [Created] (FLINK-34944) Use Incremental Source Framework in Flink CDC OceanBase Source Connector

2024-03-26 Thread He Wang (Jira)
He Wang created FLINK-34944: --- Summary: Use Incremental Source Framework in Flink CDC OceanBase Source Connector Key: FLINK-34944 URL: https://issues.apache.org/jira/browse/FLINK-34944 Project: Flink

[jira] [Updated] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

2024-03-26 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] He Wang updated FLINK-34639: Fix Version/s: cdc-3.1.0 > Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

[jira] [Created] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

2024-03-11 Thread He Wang (Jira)
He Wang created FLINK-34639: --- Summary: Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector Key: FLINK-34639 URL: https://issues.apache.org/jira/browse/FLINK-34639 Project: Flink

[jira] [Created] (FLINK-34572) JDBC: Support OceanBase catalog

2024-03-04 Thread He Wang (Jira)
He Wang created FLINK-34572: --- Summary: JDBC: Support OceanBase catalog Key: FLINK-34572 URL: https://issues.apache.org/jira/browse/FLINK-34572 Project: Flink Issue Type: New Feature Compo

[jira] [Updated] (FLINK-34545) Add OceanBase pipeline connector to Flink CDC

2024-02-29 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] He Wang updated FLINK-34545: Description: Flink CDC supports end-to-end jobs starting from version 3.0.0, but now only supports sink t

[jira] [Created] (FLINK-34545) Add OceanBase pipeline connector to Flink CDC

2024-02-29 Thread He Wang (Jira)
He Wang created FLINK-34545: --- Summary: Add OceanBase pipeline connector to Flink CDC Key: FLINK-34545 URL: https://issues.apache.org/jira/browse/FLINK-34545 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-32714) JDBC: Add dialect for OceanBase database

2023-07-30 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749035#comment-17749035 ] He Wang commented on FLINK-32714: - Hi  [~yangs] , sorry for the late reply. I have submi

[jira] [Created] (FLINK-32714) JDBC: Add dialect for OceanBase database

2023-07-30 Thread He Wang (Jira)
He Wang created FLINK-32714: --- Summary: JDBC: Add dialect for OceanBase database Key: FLINK-32714 URL: https://issues.apache.org/jira/browse/FLINK-32714 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-28013) java.lang.ClassNotFoundException: org.apache.flink.hbase.shaded.io.netty.channel.EventLoopGroup

2023-07-27 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748153#comment-17748153 ] He Wang commented on FLINK-28013: - I got the same exception. After comparing the depende