Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Bug] 2.4版本下的sqlserver cdc 会监听所有同名不同库的表 #2333

Closed
1 of 2 tasks
yangrenqing opened this issue Jul 21, 2023 · 1 comment
Closed
1 of 2 tasks
Labels
bug Something isn't working

Comments

@yangrenqing
Copy link

Search before asking

  • I searched in the issues and found nothing similar.

Flink version

1.7.0

Flink CDC version

2.4

Database and its version

sqlserver 2012 SP4

Minimal reproduce step

首先准备一个sqlserver 实例。
在实例下建A、B俩个数据库。
在A、B数据库下建立 同名的表 比如 test_tb, 并且都开启CDC。

启动一个flink job监听 sqlserver, sink我使用了kafka
代码片段如下:
...
.databaseList("A")
.tableList("dbo.test_tb")
...

What did you expect to see?

kafka 中有A数据库下的 dbo.test_tb的表的实时监听数据。

What did you see instead?

kafka 中发现 A、B数据库下的 dbo.test_tb的表的数据都被监听了。
实际上B数据库下的表并不需要。

Anything else?

No response

Are you willing to submit a PR?

  • I'm willing to submit a PR!
@GOODBOY008
Copy link
Member

Thanks for your report this issue , it had fixed in 2.4.1.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

No branches or pull requests

2 participants