Skip to content

[Bug] kafka_sync_database can only auto create one table per topic. #7581

@peng-xin

Description

@peng-xin

Search before asking

  • I searched in the issues and found nothing similar.

Paimon version

paimon-flink-1.20-1.2.0.jar

Compute Engine

flink-dist-1.20.3.jar

Minimal reproduce step

Using an empty warehouse and database: When consuming a topic with multiple tables, only one table is automatically created; the others will report a non-existent error. If the other tables are created manually, the task will execute normally.

What doesn't meet your expectations?

If each topic has only one table, the task can be executed normally, and all tables will be created automatically.

Anything else?

Does a parameter exist that can handle a single topic (containing multiple tables) and automatically create all tables?

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