[jira] [Updated] (FLINK-35242) Add per-type schema evolution behavior configuration

[ https://issues.apache.org/jira/browse/FLINK-35242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35242: Description: > Update: Changed `fine grained` terminology to avoid confusion between > fine-grained job resource

[jira] [Commented] (FLINK-35261) Flink CDC pipeline transform doesn't support decimal-type comparison

[ https://issues.apache.org/jira/browse/FLINK-35261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854308#comment-17854308 ] yux commented on FLINK-35261: - Thanks for [~wink] 's clarification! I'll put this ticket as

[jira] [Updated] (FLINK-35261) Flink CDC pipeline transform doesn't support decimal-type comparison

[ https://issues.apache.org/jira/browse/FLINK-35261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35261: Parent: FLINK-34877 Issue Type: Sub-task (was: Improvement) > Flink CDC pipeline transform doesn't suppor

[jira] [Created] (FLINK-35633) Early verification and clearer error message of pipeline YAML definition

yux created FLINK-35633: --- Summary: Early verification and clearer error message of pipeline YAML definition Key: FLINK-35633 URL: https://issues.apache.org/jira/browse/FLINK-35633 Project: Flink Issu

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

yux created FLINK-35634: --- Summary: Add a CDC quickstart utility Key: FLINK-35634 URL: https://issues.apache.org/jira/browse/FLINK-35634 Project: Flink Issue Type: New Feature Components: Flin

[jira] [Created] (FLINK-35647) Pipeline route rule supports placeholder replacement

yux created FLINK-35647: --- Summary: Pipeline route rule supports placeholder replacement Key: FLINK-35647 URL: https://issues.apache.org/jira/browse/FLINK-35647 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35648) Pipeline job doesn't support multiple routing

yux created FLINK-35648: --- Summary: Pipeline job doesn't support multiple routing Key: FLINK-35648 URL: https://issues.apache.org/jira/browse/FLINK-35648 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35651) Unable to call argument-less built-in functions with parentheses

yux created FLINK-35651: --- Summary: Unable to call argument-less built-in functions with parentheses Key: FLINK-35651 URL: https://issues.apache.org/jira/browse/FLINK-35651 Project: Flink Issue Type: B

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

yux created FLINK-35654: --- Summary: Add Flink CDC verification guide in docs Key: FLINK-35654 URL: https://issues.apache.org/jira/browse/FLINK-35654 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-35664) Flink CDC pipeline transform supports mask function

[ https://issues.apache.org/jira/browse/FLINK-35664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856665#comment-17856665 ] yux commented on FLINK-35664: - Hi [~melin], just to confirm, are you suggesting adding built

[jira] [Created] (FLINK-35700) Loosen CDC pipeline options validation

yux created FLINK-35700: --- Summary: Loosen CDC pipeline options validation Key: FLINK-35700 URL: https://issues.apache.org/jira/browse/FLINK-35700 Project: Flink Issue Type: Bug Components: Fl

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

[ 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

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

[ 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] [Created] (FLINK-35736) Add E2e migration scripts for Flink CDC

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] [Created] (FLINK-35762) Cache hashCode for immutable map key classes

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-35781) Make pipeline parallelism config optional

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] [Commented] (FLINK-35783) Flink CDC Could not start the yaml Job

[ 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] [Resolved] (FLINK-35077) Add package license check for Flink CDC modules.

[ 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

[ 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] [Created] (FLINK-35805) Add "OpType" metadata column in transform

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] [Created] (FLINK-35813) Transform schema operator failed to trigger checkpoint with bounded source

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] [Commented] (FLINK-35834) Update Doris Dependency to 1.6.2 to use group commit.

[ 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] [Commented] (FLINK-35491) [JUnit5 Migration] Module: Flink CDC modules

[ 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-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

[ 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-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

[ 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-35634) Add a CDC quickstart utility

[ 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-35634) Add a CDC quickstart utility

[ 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] [Created] (FLINK-35868) Bump Mongo driver version to support Mongo 7.0+

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

[ 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] [Commented] (FLINK-35883) Wildcard projection inserts column at wrong place

[ 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] [Created] (FLINK-35883) Wildcard projection inserts column at wrong place

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-35889) mongo cdc restore from expired resume token and job status still running but expect failed

[ 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] [Comment Edited] (FLINK-35889) mongo cdc restore from expired resume token and job status still running but expect failed

[ 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] [Created] (FLINK-35912) SqlServer CDC doesn't chunk UUID-typed columns correctly

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] [Created] (FLINK-35980) Add transform test coverage in Integrated / E2e tests

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-35981) Transform rule doesn't support referencing one column more than once

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-35982) Transform metadata config doesn't work if no projection block was provided

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-35983) Job crashes when using wildcard (*) match with metadata column

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-35984) Job crashes when metadata column names present in transform rules

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-35985) SUBSTRING function not available in transform rules

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-35986) NULL literal is not supported in Transform rules

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-35991) Resolve conflicting definitions in transform SqlFunctionTable definition

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-36006) Add documentations for Flink CDC CLI

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] [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

[ 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] [Commented] (FLINK-35774) The cache of transform is not updated after process schema change event

[ 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-35615) CDC3.0, the pipeline of mysql-doris , do not support the MySQL field type timestamp(6)

[ 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] [Created] (FLINK-36034) Remove dependencies of Flink table planner in Transform module

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-36034) Remove dependencies of Flink table planner in Transform module

[ 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] [Commented] (FLINK-35985) SUBSTRING function not available in transform rules

[ 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] [Created] (FLINK-36041) Eliminate Calcite dependency during runtime

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] [Created] (FLINK-36092) Transform doesn't fully support with schema evolution

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] [Commented] (FLINK-36092) Transform doesn't fully support with schema evolution

[ 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-36093) PreTransform operator wrongly filters out columns when multiple transform rules were defined

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] [Created] (FLINK-36105) CDC pipeline job could not restore from state in Flink 1.20

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-36114) Schema registry should block when handling existing requests

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-36128) Promote LENIENT mode as the default schema evolution behavior

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] [Updated] (FLINK-36128) Promote LENIENT mode as the default schema evolution behavior

[ 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] [Updated] (FLINK-36128) Promote LENIENT mode as the default schema evolution behavior

[ 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-36114) Schema registry should block when handling existing requests

[ 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-36105) CDC pipeline job could not restore from state in Flink 1.20

[ 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

[ 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] [Created] (FLINK-36151) Add documentations for Schema Evolution related options

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] [Created] (FLINK-36153) MySQL fails to handle schema change events In Timestamp or Earliest Offset startup mode

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

[ 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] [Updated] (FLINK-36153) MySQL fails to handle schema change events In Timestamp or Earliest Offset startup mode

[ 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-36183) Lenient mode doesn't work with route blocks

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] [Created] (FLINK-36184) Transform Operator swallows schema changes from tables not present in transform rules

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-36193) Allow applying new SchemaChangeEvents to sink connectors

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] [Commented] (FLINK-36214) Error log when building flink-cdc-pipeline-udf-examples from source code

[ 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-36219) Add Flink compatibility matrix of CDC releases

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] [Created] (FLINK-36221) Add specification about CAST ... AS ... built-in functions

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] [Updated] (FLINK-35120) Add Doris Pipeline connector integration test cases

[ https://issues.apache.org/jira/browse/FLINK-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35120: Fix Version/s: cdc-3.2.0 > Add Doris Pipeline connector integration test cases > -

[jira] [Updated] (FLINK-35092) Add integrated test for Doris / Starrocks sink pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35092: Fix Version/s: cdc-3.2.0 > Add integrated test for Doris / Starrocks sink pipeline connector > ---

[jira] [Updated] (FLINK-35090) Doris sink fails to create table when database does not exist

[ https://issues.apache.org/jira/browse/FLINK-35090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35090: Fix Version/s: cdc-3.2.0 > Doris sink fails to create table when database does not exist > ---

[jira] [Updated] (FLINK-35072) Doris pipeline sink does not support applying AlterColumnTypeEvent

[ https://issues.apache.org/jira/browse/FLINK-35072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35072: Fix Version/s: cdc-3.2.0 > Doris pipeline sink does not support applying AlterColumnTypeEvent > --

[jira] [Created] (FLINK-35242) Add fine-grained schema evolution strategy

yux created FLINK-35242: --- Summary: Add fine-grained schema evolution strategy Key: FLINK-35242 URL: https://issues.apache.org/jira/browse/FLINK-35242 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-35243) Carry pre-schema payload with SchemaChangeEvents

yux created FLINK-35243: --- Summary: Carry pre-schema payload with SchemaChangeEvents Key: FLINK-35243 URL: https://issues.apache.org/jira/browse/FLINK-35243 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35256) Pipeline transform ignores column type nullability

yux created FLINK-35256: --- Summary: Pipeline transform ignores column type nullability Key: FLINK-35256 URL: https://issues.apache.org/jira/browse/FLINK-35256 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-35256) Pipeline transform ignores column type nullability

[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35256: Description: Flink CDC 3.1.0 brought transform feature, allowing column type / value transformation prior to data

[jira] [Created] (FLINK-35261) Flink CDC pipeline transform doesn't support decimal comparison

yux created FLINK-35261: --- Summary: Flink CDC pipeline transform doesn't support decimal comparison Key: FLINK-35261 URL: https://issues.apache.org/jira/browse/FLINK-35261 Project: Flink Issue Type: Im

[jira] [Updated] (FLINK-35261) Flink CDC pipeline transform doesn't support decimal-type comparison

[ https://issues.apache.org/jira/browse/FLINK-35261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35261: Summary: Flink CDC pipeline transform doesn't support decimal-type comparison (was: Flink CDC pipeline transform

[jira] [Created] (FLINK-35264) Flink CDC Pipeline transform rules do not take effect

yux created FLINK-35264: --- Summary: Flink CDC Pipeline transform rules do not take effect Key: FLINK-35264 URL: https://issues.apache.org/jira/browse/FLINK-35264 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35272) Pipeline Transform job supports omitting / renaming calculation column

yux created FLINK-35272: --- Summary: Pipeline Transform job supports omitting / renaming calculation column Key: FLINK-35272 URL: https://issues.apache.org/jira/browse/FLINK-35272 Project: Flink Issue T

[jira] [Commented] (FLINK-35272) Pipeline Transform job supports omitting / renaming calculation column

[ https://issues.apache.org/jira/browse/FLINK-35272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842212#comment-17842212 ] yux commented on FLINK-35272: - [~renqs] I'm willing to implement this. > Pipeline Transform

[jira] [Created] (FLINK-35304) Mongo ITCase fails due to duplicate records after resuming

yux created FLINK-35304: --- Summary: Mongo ITCase fails due to duplicate records after resuming Key: FLINK-35304 URL: https://issues.apache.org/jira/browse/FLINK-35304 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35308) StarRocks sink maps TINYINT type to BOOLEAN incorrectly

yux created FLINK-35308: --- Summary: StarRocks sink maps TINYINT type to BOOLEAN incorrectly Key: FLINK-35308 URL: https://issues.apache.org/jira/browse/FLINK-35308 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-35308) MySQL to StarRocks pipeline job maps TINYINT type to BOOLEAN incorrectly

[ https://issues.apache.org/jira/browse/FLINK-35308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35308: Summary: MySQL to StarRocks pipeline job maps TINYINT type to BOOLEAN incorrectly (was: StarRocks sink maps TINYI

[jira] [Created] (FLINK-35312) Insufficient number of arguments were supplied for the procedure or function cdc.fn_cdc_get_all_changes_

yux created FLINK-35312: --- Summary: Insufficient number of arguments were supplied for the procedure or function cdc.fn_cdc_get_all_changes_ Key: FLINK-35312 URL: https://issues.apache.org/jira/browse/FLINK-35312

[jira] [Created] (FLINK-35316) Add CDC e2e test case for on Flink 1.19

yux created FLINK-35316: --- Summary: Add CDC e2e test case for on Flink 1.19 Key: FLINK-35316 URL: https://issues.apache.org/jira/browse/FLINK-35316 Project: Flink Issue Type: Bug Components: F

[jira] [Created] (FLINK-35317) Flink CDC CLI Supports submitting multiple YAML job at once

yux created FLINK-35317: --- Summary: Flink CDC CLI Supports submitting multiple YAML job at once Key: FLINK-35317 URL: https://issues.apache.org/jira/browse/FLINK-35317 Project: Flink Issue Type: Improv

[jira] [Updated] (FLINK-35316) Add CDC e2e test case for on Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35316: Issue Type: Improvement (was: Bug) > Add CDC e2e test case for on Flink 1.19 > --

[jira] [Updated] (FLINK-35316) Add CDC e2e test case for on Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35316: Priority: Minor (was: Major) > Add CDC e2e test case for on Flink 1.19 > ---

[jira] [Closed] (FLINK-35312) Insufficient number of arguments were supplied for the procedure or function cdc.fn_cdc_get_all_changes_

[ https://issues.apache.org/jira/browse/FLINK-35312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux closed FLINK-35312. --- Resolution: Done This ticket has been resolved by https://github.com/apache/flink-cdc/pull/2551. > Insufficient num

[jira] [Commented] (FLINK-35329) Support modify table/column comments

[ https://issues.apache.org/jira/browse/FLINK-35329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845203#comment-17845203 ] yux commented on FLINK-35329: - Hi [~melin], I'm trying to add AlterTableCommentEvent / Alter

[jira] [Commented] (FLINK-35385) upgrader flink dependency version to 1.19

[ https://issues.apache.org/jira/browse/FLINK-35385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848411#comment-17848411 ] yux commented on FLINK-35385: - Seems https://github.com/apache/flink-cdc/issues/3327 was cau

[jira] [Created] (FLINK-35415) CDC Fails to create sink with Flink 1.19

yux created FLINK-35415: --- Summary: CDC Fails to create sink with Flink 1.19 Key: FLINK-35415 URL: https://issues.apache.org/jira/browse/FLINK-35415 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-35441) Add CDC upgrade compatibility tests

yux created FLINK-35441: --- Summary: Add CDC upgrade compatibility tests Key: FLINK-35441 URL: https://issues.apache.org/jira/browse/FLINK-35441 Project: Flink Issue Type: Bug Components: Flink

[jira] [Commented] (FLINK-35441) Add CDC upgrade compatibility tests

[ https://issues.apache.org/jira/browse/FLINK-35441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849142#comment-17849142 ] yux commented on FLINK-35441: - [~renqs] I'd love to take this ticket if needed. > Add CDC u

[jira] [Updated] (FLINK-35441) Add CDC upgrade compatibility tests

[ https://issues.apache.org/jira/browse/FLINK-35441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yux updated FLINK-35441: Issue Type: Improvement (was: Bug) > Add CDC upgrade compatibility tests > --- >

[jira] [Created] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

yux created FLINK-35464: --- Summary: Flink CDC 3.1 breaks operator state compatiblity Key: FLINK-35464 URL: https://issues.apache.org/jira/browse/FLINK-35464 Project: Flink Issue Type: Bug Comp

  1   2   >