[FLINK-34128] oracle jdbc connector bug. When the oracle table field is of type float, the type obtained by jdbc is bigdecimal. error is 'java.lang.ClassCastException: java.math.BigDecimal cannot be cast to java.lang.Float'

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: jdbc-3.0.0, jdbc-3.1.0
• Component/s: Connectors / JDBC
• Labels: pull-request-available

Environment

All current versions of flinks-jdbc-connector

• Assignee: Unassigned
• Reporter: blackpighe
• Created: 17/Jan/24 06:40
• Updated: 19/Jan/24 10:46
• Resolved: 19/Jan/24 10:46

Description

create oracle table contain float field and execute sql occurred error.

java.lang.ClassCastException: java.math.BigDecimal cannot be cast to java.lang.Float

 

Locate the cause of the error:

org/apache/flink/connector/jdbc/converter/AbstractJdbcRowConverter.java

Object field = resultSet.getObject(pos + 1);

this method for oracle jdbc produce bug. 

expect：float value

actual： bigdecimal value

 

Suggest this modification：

Object field =
resultSet.getObject(pos + 1, rowType.getTypeAt(pos).getDefaultConversion());

Specify the type explicitly according to the schema.but mock test case is error.Let's talk about it and see what we can do about it.

 

 

 

Issue Links

• links to: GitHub Pull Request #91