Re: Flink jdbc Connector 特殊类型问题

2021-11-16 文章 Ada Luna
这指定不是个Bug。Flink SQL 类型是有限的。有限的类型囊括不了JDBC的数据源各种数据源的类型。 Shengkai Fang 于2021年11月16日周二 下午12:38写道: > > 如果是个 bug,建议在社区开个 issue 跟踪下这个问题。 > > Shengkai Fang 于2021年11月16日周二 下午12:37写道: > > > 能分享下具体是什么错误类型吗? > > > > 我看了下代码,感觉不太好支持。具体的序列化器是由 > > `AbstractJdbcRowConverter`#createExternalConverter 决定的。 > >

Re: Flink jdbc Connector 特殊类型问题

2021-11-15 文章 Shengkai Fang
如果是个 bug,建议在社区开个 issue 跟踪下这个问题。 Shengkai Fang 于2021年11月16日周二 下午12:37写道: > 能分享下具体是什么错误类型吗? > > 我看了下代码,感觉不太好支持。具体的序列化器是由 > `AbstractJdbcRowConverter`#createExternalConverter 决定的。 > 根据你的描述,当前的序列化器不够通用导致了这个问题,可能需要改动下源码才能支持。 > > Best, > Shengkai > > Ada Luna 于2021年11月12日周五 上午11:25写道: > >>

Re: Flink jdbc Connector 特殊类型问题

2021-11-15 文章 Shengkai Fang
能分享下具体是什么错误类型吗? 我看了下代码,感觉不太好支持。具体的序列化器是由 `AbstractJdbcRowConverter`#createExternalConverter 决定的。 根据你的描述,当前的序列化器不够通用导致了这个问题,可能需要改动下源码才能支持。 Best, Shengkai Ada Luna 于2021年11月12日周五 上午11:25写道: > Oracle中有VARCHAR 和 CLOB > 如果我在Flink SQL JDBC Sink中配置STRING那么只能写VARCHAR 写CLOB会报错。 > 我想扩展FlinkSQL

Re: Flink jdbc Connector 特殊类型问题

2021-11-11 文章 Ada Luna
Oracle中有VARCHAR 和 CLOB 如果我在Flink SQL JDBC Sink中配置STRING那么只能写VARCHAR 写CLOB会报错。 我想扩展FlinkSQL DDL的类型有什么办法吗。是用RAW类型还是有其他更好办法。 Oracle中VARCHAR和CLOB是两种不同的String,我需要在Sink写出的时候根据DDL的类型,调用不同的转换方法 Ada Luna 于2021年11月12日周五 上午11:23写道: > > Oracle中有VARCHAR 和 CLOB > 如果我在Flink SQL JDBC Sink中配置STRING那么只能写VARCHAR