Skip to content
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.

Sign up for GitHub

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

Jump to bottom

[flink][flink-cdc] Add FLOAT type adaptation to HAVE_SCALE_LIST #3281

Closed
wants to merge 3 commits into from
Closed

[flink][flink-cdc] Add FLOAT type adaptation to HAVE_SCALE_LIST #3281

wants to merge 3 commits into from

Commits on Apr 28, 2024

  1. fix kafka-cdc with canal-json, when use float, the running exception … 

    …is :java.lang.NumberFormatException: For input string: "10,2"
    Burning committed Apr 28, 2024
    Configuration menu
    Copy the full SHA
    d4fad6b View commit details
    Browse the repository at this point in the history

Commits on May 4, 2024

  1. fix kafka-cdc getPrecision error, like FLOAT(4),DOUBLE(8)... 

    the test error example is org.apache.paimon.flink.action.cdc.kafka.KafkaCanalSyncTableActionITCase >> java.lang.StringIndexOutOfBoundsException: String index out of range: -7
    Burning committed May 4, 2024
    Configuration menu
    Copy the full SHA
    8265990 View commit details
    Browse the repository at this point in the history

Commits on May 7, 2024

  1. fix kafka-cdc getScale error,.when there is no COMMA return zero, lik… 

    …e FLOAT(4),DOUBLE(8)..
    Burning committed May 7, 2024
    Configuration menu
    Copy the full SHA
    72dd5fe View commit details
    Browse the repository at this point in the history