能分享下具体是什么错误类型吗？ 我看了下代码，感觉不太好支持。具体的序列化器是由 `AbstractJdbcRowConverter`#createExternalConverter 决定的。 根据你的描述，当前的序列化器不够通用导致了这个问题，可能需要改动下源码才能支持。
Best, Shengkai Ada Luna <[email protected]> 于2021年11月12日周五 上午11:25写道： > Oracle中有VARCHAR 和 CLOB > 如果我在Flink SQL JDBC Sink中配置STRING那么只能写VARCHAR 写CLOB会报错。 > 我想扩展FlinkSQL DDL的类型有什么办法吗。是用RAW类型还是有其他更好办法。 > Oracle中VARCHAR和CLOB是两种不同的String，我需要在Sink写出的时候根据DDL的类型，调用不同的转换方法 > > Ada Luna <[email protected]> 于2021年11月12日周五 上午11:23写道： > > > > Oracle中有VARCHAR 和 CLOB > > 如果我在Flink SQL JDBC Sink中配置STRING那么只能写VARCHAR 写CLOB会报错。 >
