[Bug]: When flink specifies sink parallelism, does it have to specify the primary key?

[qiunanx]

What happened?

Flink specifies sink parallelism, and SQL verification reports errors.

configured sink parallelism is: 8, while the input parallelism is: -1. Since configured parallelism is different from input parallelism and the changelog mode contains [INSERT,UPDATE_AFTER,DELETE], which is not INSERT_ONLY mode, primary key is required but no primary key is found!

Affects Versions

1.18

What are you seeing the problem on?

No response

How to reproduce

No response

Relevant log output

No response

Anything else

No response

Are you willing to submit a PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct