Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-15313

Can not insert decimal with precision into sink using TypeInformation

    XMLWordPrintableJSON

    Details

      Description

      Sink DDL:

       

      val sinkDDL =
        s"""
          |CREATE TABLE T2 (
          |  d DECIMAL(10, 2),
          |  cnt INT
          |) with (
          |  'connector.type' = 'filesystem',
          |  'connector.path' = '$sinkFilePath',
          |  'format.type' = 'csv',
          |  'format.field-delimiter' = ','
          |)
        """.stripMargin
      

      Using blink with batch mode. (ensure insert BinaryRow into sink table)

       

      In FLINK-15124 , but we still use wrong precision to construct DataFormatConverter. This will lead to exception when inserting BinaryRow. (BinaryRow need correct precision to get)

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                jark Jark Wu
                Reporter:
                lzljs3620320 Jingsong Lee
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m