[jira] [Commented] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option

2025-02-05 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924366#comment-17924366 ] yux commented on FLINK-37262: - I'll prepare a fix for this ticket. > MySQL CDC connector co

[jira] [Created] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option

2025-02-05 Thread yux (Jira)
yux created FLINK-37262: --- Summary: MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option Key: FLINK-37262 URL: https://issues.apache.org/jira/browse/FLINK-37262 Project:

[jira] [Commented] (FLINK-37255) Unsupported options: scan.partition.record-size

2025-02-05 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923952#comment-17923952 ] yux commented on FLINK-37255: - I'll prepare a patch for this. > Unsupported options: scan.p

[jira] [Closed] (FLINK-37195) TimestampAdd / TimestampDiff series function not available in cluster

2025-01-21 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux closed FLINK-37195. --- Resolution: Resolved It turns out to be caused by a miswritten projection expression typo. Still need to add corres

[jira] [Created] (FLINK-37195) TimestampAdd / TimestampDiff series function not available in cluster

2025-01-21 Thread yux (Jira)
yux created FLINK-37195: --- Summary: TimestampAdd / TimestampDiff series function not available in cluster Key: FLINK-37195 URL: https://issues.apache.org/jira/browse/FLINK-37195 Project: Flink Issue Ty

[jira] [Commented] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes

2025-01-21 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915872#comment-17915872 ] yux commented on FLINK-37191: - I'm investigating this. > MySQL 'Compile and test' stage tim

[jira] [Commented] (FLINK-37156) A Flink pipeline supports collecting data once and writing it to multiple sinks.

2025-01-19 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914529#comment-17914529 ] yux commented on FLINK-37156: - Hi Cheng, Thanks for reporting this! There are already some

[jira] [Commented] (FLINK-37124) Simplify the print log in Flink CDC schema Coordinator

2025-01-14 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913155#comment-17913155 ] yux commented on FLINK-37124: - I'd like to take this ticket. > Simplify the print log in Fl

[jira] [Created] (FLINK-37111) Allow setting `sink.version` for StarRocks Pipeline connector

2025-01-13 Thread yux (Jira)
yux created FLINK-37111: --- Summary: Allow setting `sink.version` for StarRocks Pipeline connector Key: FLINK-37111 URL: https://issues.apache.org/jira/browse/FLINK-37111 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-37000) MySQL CDC could not handle date and time data prior to unix epoch

2025-01-03 Thread yux (Jira)
yux created FLINK-37000: --- Summary: MySQL CDC could not handle date and time data prior to unix epoch Key: FLINK-37000 URL: https://issues.apache.org/jira/browse/FLINK-37000 Project: Flink Issue Type:

[jira] [Created] (FLINK-36956) Pipeline transform should deduce PK column types to be NOT NULL

2024-12-23 Thread yux (Jira)
yux created FLINK-36956: --- Summary: Pipeline transform should deduce PK column types to be NOT NULL Key: FLINK-36956 URL: https://issues.apache.org/jira/browse/FLINK-36956 Project: Flink Issue Type: Bu

[jira] [Comment Edited] (FLINK-36866) Support more CDC YAML numeric casting paths

2024-12-09 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904057#comment-17904057 ] yux edited comment on FLINK-36866 at 12/9/24 8:20 AM: -- [~Leonard] C

[jira] [Commented] (FLINK-36866) Support more CDC YAML numeric casting paths

2024-12-09 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904057#comment-17904057 ] yux commented on FLINK-36866: - [~Leonard] Could you please assign this to me? > Support mor

[jira] [Created] (FLINK-36866) Support more CDC YAML numeric casting paths

2024-12-09 Thread yux (Jira)
yux created FLINK-36866: --- Summary: Support more CDC YAML numeric casting paths Key: FLINK-36866 URL: https://issues.apache.org/jira/browse/FLINK-36866 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-36865) Provide UNIX_TIMESTAMP series functions in YAML pipeline

2024-12-09 Thread yux (Jira)
yux created FLINK-36865: --- Summary: Provide UNIX_TIMESTAMP series functions in YAML pipeline Key: FLINK-36865 URL: https://issues.apache.org/jira/browse/FLINK-36865 Project: Flink Issue Type: New Featur

[jira] [Created] (FLINK-36864) YAML Pipeline could not write number literals that exceeds Int32 range

2024-12-08 Thread yux (Jira)
yux created FLINK-36864: --- Summary: YAML Pipeline could not write number literals that exceeds Int32 range Key: FLINK-36864 URL: https://issues.apache.org/jira/browse/FLINK-36864 Project: Flink Issue T

[jira] [Commented] (FLINK-36854) Column comments and default expressions gone after being transformed

2024-12-05 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903304#comment-17903304 ] yux commented on FLINK-36854: - [~ruanhang1993] I'm interested in this. Could you please assi

[jira] [Created] (FLINK-36854) Column comments and default expressions gone after being transformed

2024-12-05 Thread yux (Jira)
yux created FLINK-36854: --- Summary: Column comments and default expressions gone after being transformed Key: FLINK-36854 URL: https://issues.apache.org/jira/browse/FLINK-36854 Project: Flink Issue Typ

[jira] [Created] (FLINK-36763) Support schema inference and evolution with single-table-mutliple-partition sources

2024-11-20 Thread yux (Jira)
yux created FLINK-36763: --- Summary: Support schema inference and evolution with single-table-mutliple-partition sources Key: FLINK-36763 URL: https://issues.apache.org/jira/browse/FLINK-36763 Project: Flink

[jira] [Commented] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target t

2024-11-18 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899370#comment-17899370 ] yux commented on FLINK-34865: - [~leonard] No, it's not. This feature was implemented by [~no

[jira] [Created] (FLINK-36697) Quickly evolving schema change in Doris fails

2024-11-12 Thread yux (Jira)
yux created FLINK-36697: --- Summary: Quickly evolving schema change in Doris fails Key: FLINK-36697 URL: https://issues.apache.org/jira/browse/FLINK-36697 Project: Flink Issue Type: Bug Compone

[jira] [Created] (FLINK-36690) Pipeline occasionally blocks when handling schema change events in parallel

2024-11-11 Thread yux (Jira)
yux created FLINK-36690: --- Summary: Pipeline occasionally blocks when handling schema change events in parallel Key: FLINK-36690 URL: https://issues.apache.org/jira/browse/FLINK-36690 Project: Flink Is

[jira] [Created] (FLINK-36610) MySQL CDC supports parsing gh-ost generated schema changes

2024-10-28 Thread yux (Jira)
yux created FLINK-36610: --- Summary: MySQL CDC supports parsing gh-ost generated schema changes Key: FLINK-36610 URL: https://issues.apache.org/jira/browse/FLINK-36610 Project: Flink Issue Type: Improvem

[jira] [Commented] (FLINK-36610) MySQL CDC supports parsing gh-ost generated schema changes

2024-10-28 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893390#comment-17893390 ] yux commented on FLINK-36610: - Good idea! I've just finished a simple POC for gh-ost here[1]

[jira] [Resolved] (FLINK-36590) Flink CDC does not Support MySQL > 8.0.x

2024-10-24 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux resolved FLINK-36590. - Resolution: Duplicate Duplicate of FLINK-36520 > Flink CDC does not Support MySQL > 8.0.x > ---

[jira] [Created] (FLINK-36596) YAML Pipeline fails to schema change with no projection fields specified

2024-10-24 Thread yux (Jira)
yux created FLINK-36596: --- Summary: YAML Pipeline fails to schema change with no projection fields specified Key: FLINK-36596 URL: https://issues.apache.org/jira/browse/FLINK-36596 Project: Flink Issue

[jira] [Created] (FLINK-36590) Flink CDC does not Support MySQL > 8.0.x

2024-10-22 Thread yux (Jira)
yux created FLINK-36590: --- Summary: Flink CDC does not Support MySQL > 8.0.x Key: FLINK-36590 URL: https://issues.apache.org/jira/browse/FLINK-36590 Project: Flink Issue Type: Improvement Comp

[jira] [Created] (FLINK-36565) Pipeline YAML should allow merging decimal with different precisions

2024-10-17 Thread yux (Jira)
yux created FLINK-36565: --- Summary: Pipeline YAML should allow merging decimal with different precisions Key: FLINK-36565 URL: https://issues.apache.org/jira/browse/FLINK-36565 Project: Flink Issue Typ

[jira] [Created] (FLINK-36558) MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18

2024-10-16 Thread yux (Jira)
yux created FLINK-36558: --- Summary: MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18 Key: FLINK-36558 URL: https://issues.apache.org/jira/browse/FLINK-36558 Project: Flink

[jira] [Commented] (FLINK-36075) Add paginate partition strategy for mongodb connector

2024-10-15 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889926#comment-17889926 ] yux commented on FLINK-36075: - Sure! Please assign it to me. > Add paginate partition strat

[jira] [Created] (FLINK-36515) Adds high-precision TIME type support in YAML pipeline

2024-10-11 Thread yux (Jira)
yux created FLINK-36515: --- Summary: Adds high-precision TIME type support in YAML pipeline Key: FLINK-36515 URL: https://issues.apache.org/jira/browse/FLINK-36515 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36514) Unable to override include/exclude schema types in lenient mode

2024-10-11 Thread yux (Jira)
yux created FLINK-36514: --- Summary: Unable to override include/exclude schema types in lenient mode Key: FLINK-36514 URL: https://issues.apache.org/jira/browse/FLINK-36514 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-36475) YAML Transform supports case-insensitive column names conversion

2024-10-10 Thread yux (Jira)
yux created FLINK-36475: --- Summary: YAML Transform supports case-insensitive column names conversion Key: FLINK-36475 URL: https://issues.apache.org/jira/browse/FLINK-36475 Project: Flink Issue Type: I

[jira] [Created] (FLINK-36474) YAML Table-merging route should accept more type widening cases

2024-10-10 Thread yux (Jira)
yux created FLINK-36474: --- Summary: YAML Table-merging route should accept more type widening cases Key: FLINK-36474 URL: https://issues.apache.org/jira/browse/FLINK-36474 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-36461) YAML job failed to schema evolve with unmatched transform tables

2024-10-09 Thread yux (Jira)
yux created FLINK-36461: --- Summary: YAML job failed to schema evolve with unmatched transform tables Key: FLINK-36461 URL: https://issues.apache.org/jira/browse/FLINK-36461 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-36453) Backport DBZ-6502 patch to fix Oracle 23.x JDBC driver compatbility

2024-10-09 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887877#comment-17887877 ] yux commented on FLINK-36453: - I'd love to take this ticket. [~leonard] > Backport DBZ-6502

[jira] [Updated] (FLINK-36453) Backport DBZ-6502 patch to fix Oracle 23.x JDBC driver compatbility

2024-10-09 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-36453: Description: DBZ-6502 fixes Oracle JDBC 23.x compatibility, but it wasn't shipped in versions prior to 2.2. We m

[jira] [Created] (FLINK-36453) Backport DBZ-6502 patch to fix Oracle 23.x JDBC driver compatbility

2024-10-09 Thread yux (Jira)
yux created FLINK-36453: --- Summary: Backport DBZ-6502 patch to fix Oracle 23.x JDBC driver compatbility Key: FLINK-36453 URL: https://issues.apache.org/jira/browse/FLINK-36453 Project: Flink Issue Type

[jira] [Created] (FLINK-36408) MySQL pipeline connector could not work with FLOAT type with precision

2024-09-29 Thread yux (Jira)
yux created FLINK-36408: --- Summary: MySQL pipeline connector could not work with FLOAT type with precision Key: FLINK-36408 URL: https://issues.apache.org/jira/browse/FLINK-36408 Project: Flink Issue T

[jira] [Commented] (FLINK-36403) K8s native mode Use ConfigMap to get a better experience

2024-09-29 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885758#comment-17885758 ] yux commented on FLINK-36403: - +1 that repackaging images are not convenient and necessary c

[jira] [Created] (FLINK-36221) Add specification about CAST ... AS ... built-in functions

2024-09-04 Thread yux (Jira)
yux created FLINK-36221: --- Summary: Add specification about CAST ... AS ... built-in functions Key: FLINK-36221 URL: https://issues.apache.org/jira/browse/FLINK-36221 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36219) Add Flink compatibility matrix of CDC releases

2024-09-04 Thread yux (Jira)
yux created FLINK-36219: --- Summary: Add Flink compatibility matrix of CDC releases Key: FLINK-36219 URL: https://issues.apache.org/jira/browse/FLINK-36219 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-36214) Error log when building flink-cdc-pipeline-udf-examples from source code

2024-09-04 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879401#comment-17879401 ] yux commented on FLINK-36214: - Seems it was brought in by FLINK-34876, will investigate this

[jira] [Created] (FLINK-36193) Allow applying new SchemaChangeEvents to sink connectors

2024-09-01 Thread yux (Jira)
yux created FLINK-36193: --- Summary: Allow applying new SchemaChangeEvents to sink connectors Key: FLINK-36193 URL: https://issues.apache.org/jira/browse/FLINK-36193 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-36184) Transform Operator swallows schema changes from tables not present in transform rules

2024-08-29 Thread yux (Jira)
yux created FLINK-36184: --- Summary: Transform Operator swallows schema changes from tables not present in transform rules Key: FLINK-36184 URL: https://issues.apache.org/jira/browse/FLINK-36184 Project: Flink

[jira] [Created] (FLINK-36183) Lenient mode doesn't work with route blocks

2024-08-29 Thread yux (Jira)
yux created FLINK-36183: --- Summary: Lenient mode doesn't work with route blocks Key: FLINK-36183 URL: https://issues.apache.org/jira/browse/FLINK-36183 Project: Flink Issue Type: Bug Component

[jira] [Updated] (FLINK-36153) MySQL fails to handle schema change events In Timestamp or Earliest Offset startup mode

2024-08-25 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-36153: Issue Type: Bug (was: Improvement) > MySQL fails to handle schema change events In Timestamp or Earliest Offset

[jira] [Created] (FLINK-36153) MySQL fails to handle schema change events In Timestamp or Earliest Offset startup mode

2024-08-25 Thread yux (Jira)
yux created FLINK-36153: --- Summary: MySQL fails to handle schema change events In Timestamp or Earliest Offset startup mode Key: FLINK-36153 URL: https://issues.apache.org/jira/browse/FLINK-36153 Project: Flink

[jira] [Commented] (FLINK-36153) MySQL fails to handle schema change events In Timestamp or Earliest Offset startup mode

2024-08-25 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876559#comment-17876559 ] yux commented on FLINK-36153: - [~Leonard] Please assign this to me. > MySQL fails to handle

[jira] [Created] (FLINK-36151) Add documentations for Schema Evolution related options

2024-08-25 Thread yux (Jira)
yux created FLINK-36151: --- Summary: Add documentations for Schema Evolution related options Key: FLINK-36151 URL: https://issues.apache.org/jira/browse/FLINK-36151 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-36114) Schema registry should block when handling existing requests

2024-08-21 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-36114: Issue Type: Bug (was: Improvement) > Schema registry should block when handling existing requests > -

[jira] [Updated] (FLINK-36105) CDC pipeline job could not restore from state in Flink 1.20

2024-08-21 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-36105: Priority: Blocker (was: Major) > CDC pipeline job could not restore from state in Flink 1.20 > --

[jira] [Updated] (FLINK-36114) Schema registry should block when handling existing requests

2024-08-21 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-36114: Priority: Blocker (was: Major) > Schema registry should block when handling existing requests > -

[jira] [Updated] (FLINK-36128) Promote LENIENT mode as the default schema evolution behavior

2024-08-21 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-36128: Issue Type: Bug (was: Improvement) > Promote LENIENT mode as the default schema evolution behavior >

[jira] [Updated] (FLINK-36128) Promote LENIENT mode as the default schema evolution behavior

2024-08-21 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-36128: Priority: Blocker (was: Major) > Promote LENIENT mode as the default schema evolution behavior >

[jira] [Created] (FLINK-36128) Promote LENIENT mode as the default schema evolution behavior

2024-08-21 Thread yux (Jira)
yux created FLINK-36128: --- Summary: Promote LENIENT mode as the default schema evolution behavior Key: FLINK-36128 URL: https://issues.apache.org/jira/browse/FLINK-36128 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-36114) Schema registry should block when handling existing requests

2024-08-20 Thread yux (Jira)
yux created FLINK-36114: --- Summary: Schema registry should block when handling existing requests Key: FLINK-36114 URL: https://issues.apache.org/jira/browse/FLINK-36114 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-36105) CDC pipeline job could not restore from state in Flink 1.20

2024-08-19 Thread yux (Jira)
yux created FLINK-36105: --- Summary: CDC pipeline job could not restore from state in Flink 1.20 Key: FLINK-36105 URL: https://issues.apache.org/jira/browse/FLINK-36105 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-36093) PreTransform operator wrongly filters out columns when multiple transform rules were defined

2024-08-19 Thread yux (Jira)
yux created FLINK-36093: --- Summary: PreTransform operator wrongly filters out columns when multiple transform rules were defined Key: FLINK-36093 URL: https://issues.apache.org/jira/browse/FLINK-36093 Project: F

[jira] [Commented] (FLINK-36092) Transform doesn't fully support with schema evolution

2024-08-19 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874799#comment-17874799 ] yux commented on FLINK-36092: - Noticed this bug when running DataGen -> StarRocks fuzzing te

[jira] [Created] (FLINK-36092) Transform doesn't fully support with schema evolution

2024-08-19 Thread yux (Jira)
yux created FLINK-36092: --- Summary: Transform doesn't fully support with schema evolution Key: FLINK-36092 URL: https://issues.apache.org/jira/browse/FLINK-36092 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36041) Eliminate Calcite dependency during runtime

2024-08-12 Thread yux (Jira)
yux created FLINK-36041: --- Summary: Eliminate Calcite dependency during runtime Key: FLINK-36041 URL: https://issues.apache.org/jira/browse/FLINK-36041 Project: Flink Issue Type: Improvement C

[jira] [Commented] (FLINK-35985) SUBSTRING function not available in transform rules

2024-08-12 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872902#comment-17872902 ] yux commented on FLINK-35985: - Thanks [~MOBIN]'s suggestion! +1 for providing both functions

[jira] [Commented] (FLINK-36034) Remove dependencies of Flink table planner in Transform module

2024-08-11 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872765#comment-17872765 ] yux commented on FLINK-36034: - [~Leonard] I'm willing to investigate this. > Remove depende

[jira] [Created] (FLINK-36034) Remove dependencies of Flink table planner in Transform module

2024-08-11 Thread yux (Jira)
yux created FLINK-36034: --- Summary: Remove dependencies of Flink table planner in Transform module Key: FLINK-36034 URL: https://issues.apache.org/jira/browse/FLINK-36034 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-35615) CDC3.0, the pipeline of mysql-doris , do not support the MySQL field type timestamp(6)

2024-08-08 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872198#comment-17872198 ] yux commented on FLINK-35615: - This has been resolved in https://github.com/apache/flink-cdc

[jira] [Commented] (FLINK-35774) The cache of transform is not updated after process schema change event

2024-08-08 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872193#comment-17872193 ] yux commented on FLINK-35774: - Resolved by https://github.com/apache/flink-cdc/pull/3285. >

[jira] [Commented] (FLINK-35852) When used through the transform function, the decimal(10,2) type field value in the MySQL source table becomes 100 times the original value after being transferred to

2024-08-08 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872192#comment-17872192 ] yux commented on FLINK-35852: - Resolved in https://github.com/apache/flink-cdc/pull/3285. >

[jira] [Created] (FLINK-36006) Add documentations for Flink CDC CLI

2024-08-08 Thread yux (Jira)
yux created FLINK-36006: --- Summary: Add documentations for Flink CDC CLI Key: FLINK-36006 URL: https://issues.apache.org/jira/browse/FLINK-36006 Project: Flink Issue Type: Bug Components: Flin

[jira] [Created] (FLINK-35991) Resolve conflicting definitions in transform SqlFunctionTable definition

2024-08-06 Thread yux (Jira)
yux created FLINK-35991: --- Summary: Resolve conflicting definitions in transform SqlFunctionTable definition Key: FLINK-35991 URL: https://issues.apache.org/jira/browse/FLINK-35991 Project: Flink Issue

[jira] [Created] (FLINK-35986) NULL literal is not supported in Transform rules

2024-08-05 Thread yux (Jira)
yux created FLINK-35986: --- Summary: NULL literal is not supported in Transform rules Key: FLINK-35986 URL: https://issues.apache.org/jira/browse/FLINK-35986 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-35985) SUBSTRING function not available in transform rules

2024-08-05 Thread yux (Jira)
yux created FLINK-35985: --- Summary: SUBSTRING function not available in transform rules Key: FLINK-35985 URL: https://issues.apache.org/jira/browse/FLINK-35985 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-35984) Job crashes when metadata column names present in transform rules

2024-08-05 Thread yux (Jira)
yux created FLINK-35984: --- Summary: Job crashes when metadata column names present in transform rules Key: FLINK-35984 URL: https://issues.apache.org/jira/browse/FLINK-35984 Project: Flink Issue Type:

[jira] [Created] (FLINK-35983) Job crashes when using wildcard (*) match with metadata column

2024-08-05 Thread yux (Jira)
yux created FLINK-35983: --- Summary: Job crashes when using wildcard (*) match with metadata column Key: FLINK-35983 URL: https://issues.apache.org/jira/browse/FLINK-35983 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35982) Transform metadata config doesn't work if no projection block was provided

2024-08-05 Thread yux (Jira)
yux created FLINK-35982: --- Summary: Transform metadata config doesn't work if no projection block was provided Key: FLINK-35982 URL: https://issues.apache.org/jira/browse/FLINK-35982 Project: Flink Iss

[jira] [Created] (FLINK-35981) Transform rule doesn't support referencing one column more than once

2024-08-05 Thread yux (Jira)
yux created FLINK-35981: --- Summary: Transform rule doesn't support referencing one column more than once Key: FLINK-35981 URL: https://issues.apache.org/jira/browse/FLINK-35981 Project: Flink Issue Typ

[jira] [Created] (FLINK-35980) Add transform test coverage in Integrated / E2e tests

2024-08-05 Thread yux (Jira)
yux created FLINK-35980: --- Summary: Add transform test coverage in Integrated / E2e tests Key: FLINK-35980 URL: https://issues.apache.org/jira/browse/FLINK-35980 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35912) SqlServer CDC doesn't chunk UUID-typed columns correctly

2024-07-28 Thread yux (Jira)
yux created FLINK-35912: --- Summary: SqlServer CDC doesn't chunk UUID-typed columns correctly Key: FLINK-35912 URL: https://issues.apache.org/jira/browse/FLINK-35912 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-35889) mongo cdc restore from expired resume token and job status still running but expect failed

2024-07-24 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868347#comment-17868347 ] yux edited comment on FLINK-35889 at 7/24/24 12:08 PM: --- Sure, I no

[jira] [Commented] (FLINK-35889) mongo cdc restore from expired resume token and job status still running but expect failed

2024-07-24 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868347#comment-17868347 ] yux commented on FLINK-35889: - Sure, I noticed that such behaviour could be controlled by `

[jira] [Created] (FLINK-35883) Wildcard projection inserts column at wrong place

2024-07-23 Thread yux (Jira)
yux created FLINK-35883: --- Summary: Wildcard projection inserts column at wrong place Key: FLINK-35883 URL: https://issues.apache.org/jira/browse/FLINK-35883 Project: Flink Issue Type: Bug Com

[jira] [Commented] (FLINK-35883) Wildcard projection inserts column at wrong place

2024-07-23 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868022#comment-17868022 ] yux commented on FLINK-35883: - I'd like to investigate this based on FLINK-35272. > Wildcar

[jira] [Commented] (FLINK-35634) Add a CDC quickstart utility

2024-07-22 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867744#comment-17867744 ] yux commented on FLINK-35634: - Paimon / kafka sink options have been added. > Add a CDC qui

[jira] [Created] (FLINK-35868) Bump Mongo driver version to support Mongo 7.0+

2024-07-19 Thread yux (Jira)
yux created FLINK-35868: --- Summary: Bump Mongo driver version to support Mongo 7.0+ Key: FLINK-35868 URL: https://issues.apache.org/jira/browse/FLINK-35868 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-35634) Add a CDC quickstart utility

2024-07-19 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867204#comment-17867204 ] yux commented on FLINK-35634: - Just implemented a primitive demo for `cdcup` in https://git

[jira] [Commented] (FLINK-35634) Add a CDC quickstart utility

2024-07-19 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867228#comment-17867228 ] yux commented on FLINK-35634: - Seems Paimon / Kafka sink are missing. Will add them soon. >

[jira] [Commented] (FLINK-35852) When used through the transform function, the decimal(10,2) type field value in the MySQL source table becomes 100 times the original value after being transferred to

2024-07-16 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866290#comment-17866290 ] yux commented on FLINK-35852: - After some quick debugging I noticed that this has been resol

[jira] [Commented] (FLINK-35852) When used through the transform function, the decimal(10,2) type field value in the MySQL source table becomes 100 times the original value after being transferred to

2024-07-15 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866255#comment-17866255 ] yux commented on FLINK-35852: - Thanks for [~zheng_shengsheng]'s detailed report, I will nves

[jira] [Commented] (FLINK-35491) [JUnit5 Migration] Module: Flink CDC modules

2024-07-15 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866214#comment-17866214 ] yux commented on FLINK-35491: - I'd like to take this ticket if needed. > [JUnit5 Migration]

[jira] [Commented] (FLINK-35834) Update Doris Dependency to 1.6.2 to use group commit.

2024-07-14 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865828#comment-17865828 ] yux commented on FLINK-35834: - +1, bumping doris connector to 1.6.2 should also resolve FLIN

[jira] [Created] (FLINK-35813) Transform schema operator failed to trigger checkpoint with bounded source

2024-07-11 Thread yux (Jira)
yux created FLINK-35813: --- Summary: Transform schema operator failed to trigger checkpoint with bounded source Key: FLINK-35813 URL: https://issues.apache.org/jira/browse/FLINK-35813 Project: Flink Iss

[jira] [Created] (FLINK-35805) Add "OpType" metadata column in transform

2024-07-10 Thread yux (Jira)
yux created FLINK-35805: --- Summary: Add "OpType" metadata column in transform Key: FLINK-35805 URL: https://issues.apache.org/jira/browse/FLINK-35805 Project: Flink Issue Type: Improvement Com

[jira] [Commented] (FLINK-35783) Flink CDC Could not start the yaml Job

2024-07-08 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863766#comment-17863766 ] yux commented on FLINK-35783: - It is probably because pipeline jar & SQL jar has overlapping

[jira] [Resolved] (FLINK-35077) Add package license check for Flink CDC modules.

2024-07-08 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux resolved FLINK-35077. - Fix Version/s: cdc-3.1.1 Release Note: Fixed in https://github.com/apache/flink-cdc/commit/ca1470d5dd48f923

[jira] [Commented] (FLINK-35783) Flink CDC Could not start the yaml Job

2024-07-08 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863759#comment-17863759 ] yux commented on FLINK-35783: - Hi [~layhuts], As you're submitting a pipeline job, `flink-sq

[jira] [Created] (FLINK-35781) Make pipeline parallelism config optional

2024-07-07 Thread yux (Jira)
yux created FLINK-35781: --- Summary: Make pipeline parallelism config optional Key: FLINK-35781 URL: https://issues.apache.org/jira/browse/FLINK-35781 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-35762) Cache hashCode for immutable map key classes

2024-07-04 Thread yux (Jira)
yux created FLINK-35762: --- Summary: Cache hashCode for immutable map key classes Key: FLINK-35762 URL: https://issues.apache.org/jira/browse/FLINK-35762 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35736) Add E2e migration scripts for Flink CDC

2024-07-01 Thread yux (Jira)
yux created FLINK-35736: --- Summary: Add E2e migration scripts for Flink CDC Key: FLINK-35736 URL: https://issues.apache.org/jira/browse/FLINK-35736 Project: Flink Issue Type: Improvement Compo

[jira] [Commented] (FLINK-35615) CDC3.0, the pipeline of mysql-doris , do not support the MySQL field type timestamp(6)

2024-06-28 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860925#comment-17860925 ] yux commented on FLINK-35615: - I could reproduce this issue by inserting a timestamp with no

[jira] [Commented] (FLINK-35654) Add Flink CDC verification guide in docs

2024-06-26 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860289#comment-17860289 ] yux commented on FLINK-35654: - Hi [~m.orazow], I've submitted a PR for this. Are you interes

  1   2   >