Flink CDC中oracle cdc FLOAT NUMBER字段类型输出值是 字节数组 怎？

在Flink CDC中，Oracle CDC模块会将Oracle数据库中的FLOAT和NUMBER类型字段值转换为字节数组形式输出。

这是因为在Oracle数据库中，FLOAT和NUMBER类型的字段值在存储时是以二进制形式存储的，而不是以字符串形式存储的。因此，当Flink CDC从Oracle数据库中读取这些字段时，需要将它们转换为字节数组形式，以便在Flink中进行处理和转换。

在Flink中，可以使用相应的反序列化器将这些字节数组转换回FLOAT或NUMBER类型的值。例如，可以使用Flink的org.apache.flink.api.common.typein

在Flink CDC中，如果Oracle CDC任务中的FLOAT和NUMBER字段类型输出为字节数组，您可以使用Java的相应方法或工具类将其转换回原始数据类型。

对于FLOAT字段，您可以使用Float.intBitsToFloat()方法将字节数组转换为浮点数。示例代码如下：

byte[] floatBytes = ...; // 字节数组
float floatValue = Float.intBitsToFloat(ByteBuffer.wrap(floatBytes).getInt());

对于NUMBER字段，您需要根据NUMBER字段的具体定义和存储格式进行解析。一般而言，它可能会包含整数部分、小数部分、符号等信息。您可以使用Java的BigDecimal类来处理这种情况，示例代码如下：

byte[] numberBytes = ...; // 字节数组
BigInteger numberInteger = new BigInteger(numberBytes);
BigDecimal numberValue = new BigDecimal(numberInteger);

关于BLOB字段直接为null的问题，可能是由于配置不正确或源表中的数据没有正确写入导致的。请检查CDC任务的配置，确保正确指定了源表中的BLOB字段，并检查源表的数据是否包含有效的BLOB值。

如果仍然无法解决问题，您可以尝试使用Flink的自定义反序列化器来处理特殊数据类型，以便更灵活地控制数据的转换过程。