thesumery opened a new issue, #4764: URL: https://github.com/apache/inlong/issues/4764
### Description - We use testcontainer to mock end to end test. We will start four container(e.g. test for kafka): `flink:1.13.5-scala_2.11(jobmanager)`、`flink:1.13.5-scala_2.11(taskmanager)`、`confluentinc/cp-kafka:6.2.1(kafka server)`、`mysql:5.7(mock input data and output data)`. - Data flow is： ```mysql input table -> kafka -> mysql output table``` so we start two insert task in one flink job, we test kafka load node and extract node in the same time. - input data it sql file e.g.: ``` ``` ### Use case ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) ### Use case - test load data into kafka-inlong by goup json file - test extract data into kafka-inlong by goup json file ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
