Skip to content

[Bug] cdc filter pattern does not handle special character #7617

@ziyanTOP

Description

@ziyanTOP

Search before asking

  • I searched in the issues and found nothing similar.

Paimon version

1.4.1-rc1

Compute Engine

flink 1.20.3

Minimal reproduce step

create a mysql table with $ in name

create database if not exists `test_database`;

use `test_database`;

create table if not exists `test_table_0` (
    id int not null primary key,
    key varchar(50) null
);
create table if not exists `test_table_1_$` (
    id int not null primary key,
    key varchar(50) null
);

then use paimon flink action mysql_sync_database combine mode to synchronized mysql database

flink run paimon-flink-action-1.4.1.jar \
    mysql_sync_database \
    --mode combined \
    --warehouse s3://bucket/path --database test_db \
    --mysql_conf hostname=mysql_host \
    --mysql_conf username=mysql_user --mysql_conf password=mysql_pass \
    --mysql_conf database-name=test_database \
    --catalog_conf metastore=filesystem \
    --catalog_conf s3.endpoint=s3_endpoint --catalog_conf s3.access-key=s3_ak \
    --catalog_conf s3.secret-key=s3_sk --catalog_conf s3.region=s3_region \
    --excluding_tables test_table_1.*

What doesn't meet your expectations?

the table which name matches the excluding_tables pattern still be synchronized

Anything else?

No response

Are you willing to submit a PR?

  • I'm willing to submit a PR!

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions