Flink Source need to check tableId on recovery in case that table is removed and created.

[loserwang1024]

Search before asking

• I searched in the issues and found nothing similar.

Fluss version

0.8.0 (latest release)

Please describe the bug 🐞

Now, if we removed a table and recreated a same name table, fluss will read new table with old table's split. Thus, If we founded tableId in fluss different with split, just throw exception

Solution

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!