请问如何在生产环境使用SQL来实现DELETE

[MrHHYang]

请问，不使用TestValuesTableFactor的情况下，是否支持SQL方式执行删除操作。感谢解答！如图：

[MrHHYang]

自己已解决。只要是Flink标准Source，写入到sink时，op为-D就是Rowkind.DELETE。跑了下单元测试，明白了。