如果是个 bug,建议在社区开个 issue 跟踪下这个问题。

Shengkai Fang <[email protected]> 于2021年11月16日周二 下午12:37写道:

> 能分享下具体是什么错误类型吗?
>
> 我看了下代码,感觉不太好支持。具体的序列化器是由
> `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会报错。
>>
>

回复