Hi， 基本类似的，具体拼delete sql会根据 pk 来, 可以看下delete executor的代码[1]
祝好， Leonard Xu 【1】https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/BufferReduceStatementExecutor.java#L89 <https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/BufferReduceStatementExecutor.java#L89> > 在 2020年7月15日，11:05，小学生 <[email protected]> 写道： > > 嗯嗯，谢谢大佬的理解，还有一个问题，就是除了update，这个我看新性能也支持delete的，但是没找到相关的部分，delete这个是否类似：delete > table1 where score=1;烦请大佬帮忙解答下，不胜感激。
