[Feature][Spark] Support flow control in Spark

[zhilinli123]

Purpose of this pull request

Check list

SubTask:#5504

• Code changed are covered with tests, or it does not need tests for reason:
• If any new Jar binary package adding in your PR, please add License Notice according
  New License Guide
• If necessary, please update the documentation to describe the new feature. https://github.com/apache/seatunnel/tree/dev/docs
• If you are contributing the connector code, please check that the following files are updated:
  1. Update change log that in connector document. For more details you can refer to connector-v2
  2. Update plugin-mapping.properties and add new connector information in it
  3. Update the pom file of seatunnel-dist
• Update the release-note.

[zhilinli123]

Spark 2

Spark 3

[hailin0]

Why add this dependency?

[zhilinli123]

sorry, my prolem

[hailin0]

How to test this logic, this e2e is disabled on spark

https://github.com/apache/seatunnel/pull/5509/files#diff-7df030b675701262f339e58e388d7dbeb914e0cb186968f0ff10341df568895dR26
https://github.com/apache/seatunnel/blob/dev/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/MysqlCDCIT.java#L58

[zhilinli123]

How to test this logic, this e2e is disabled on spark

https://github.com/apache/seatunnel/pull/5509/files#diff-7df030b675701262f339e58e388d7dbeb914e0cb186968f0ff10341df568895dR26 https://github.com/apache/seatunnel/blob/dev/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/MysqlCDCIT.java#L58

@hailin0 I tested it with Kafkae2e

[zhilinli123]

PTAL: @Hisoka-X @hailin0

[Hisoka-X]

Thanks @zhilinli123 and @hailin0 for review.