realdengziqi commented on pull request #1598: URL: https://github.com/apache/incubator-seatunnel/pull/1598#issuecomment-1081090818
@CalvinKirs @BenJFan @tobezhou33 Thanks for your help, after trying it, I confirmed that `executeInsert` does cause two flink jobs to be submitted. So, I followed tobezhou33's advice and used datastream, FlinkKafkaProducer and JsonRowSerializationSchema to solve this problem. I tested it on my own cluster and it works fine. new commits at [9ea79fd](https://github.com/apache/incubator-seatunnel/commit/9ea79fdb027d6584369cbebf8cf92f470a7d995f) -- 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]
