有人在使用Flink的JDBC连接器进行sink操作时删除数据**。Flink的JDBC连接器支持多种数据库操作,包括插入、更新和删除等DML查询。在创建JDBC Sink时,可以通过指定SQL语句来实现删除数据的操作。同时,也需要提供JdbcStatementBuilder来根据每个查询在java.sql.PreparedStatement上设置参数。因此,使用Flink的JDBC连接器进行sink操作时,确实可以删除数据。
但请注意,删除操作通常需要谨慎处理,以避免误删重要数据或造成数据不一致。在执行删除操作之前,建议仔细检查和验证SQL语句和参数,确保它们能够正确地识别并删除目标数据。同时,也可以考虑在删除操作之前先备份相关数据,以防万一出现错误或意外情况。
此外,还需要注意Flink的版本和所连接数据库的版本,确保它们之间的兼容性和稳定性。在使用Flink的JDBC连接器进行sink操作时,建议查阅相关的官方文档和社区资源,以获取更详细的信息和最佳实践。