-
Notifications
You must be signed in to change notification settings - Fork 1.8k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[oracle] Fix Numeric type #560
Conversation
3dc58c6
to
cc5d897
Compare
I'm glad to review. |
Thanks @ashulin for the contribution. Could you describe what bug you want to fix? And could you also add a test which can reproduce the bug? |
cc5d897
to
66c498e
Compare
@luoyuxia Please take a look. |
@leonardBang Please take a look. |
...in/java/com/ververica/cdc/connectors/oracle/table/OracleDeserializationConverterFactory.java
Show resolved
Hide resolved
...racle-cdc/src/test/java/com/ververica/cdc/connectors/oracle/table/OracleConnectorITCase.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @ashulin for the update, LGTM
The failed MongoDB test is not related to this PR, merging... |
When the field type of oracle table is NUMBER or FLOAT type, it is processed as
io.debezium.data.VariableScaleDecimal
in debezium. In this case, the mapping will throw an exception for flink's INT/FLOAT and other numeric types.