tobezhou33 commented on pull request #1598: URL: https://github.com/apache/incubator-seatunnel/pull/1598#issuecomment-1080513751
i have used table.excuteinsert to do it ,but i find it submit two jobs. because excuteinsert will execEnv.executeAsync() to submit a job named 'insert-into_', and if use old planner ,it will send two same msg to sink.  i think tableenv.excute and StreamExecutionEnvironment().execute() only can excute once. the kafkatable.java is used jsonFormatDescriptor. maybe we can use datatestream api FlinkKafkaProducer and JsonRowSerializationSchema . -- 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]
