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

Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record

    XMLWordPrintableJSON

Details

    Description

      Reproduce:

      Analysis:

      • `org.apache.flink.formats.csv.CsvBulkWriter#addElement` will flush per record.

      Solution:

      • I think maybe we can disable `FLUSH_AFTER_WRITE_VALUE` to avoid flush when a record added.

      Attachments

        1. image-2024-04-26-00-23-29-975.png
          201 kB
          Zhongqiang Gong
        2. screenshot-1.png
          88 kB
          Zhongqiang Gong
        3. image-2024-04-26-17-16-07-925.png
          115 kB
          Alexander Fedulov
        4. image-2024-04-26-17-16-20-647.png
          163 kB
          Alexander Fedulov
        5. image-2024-04-26-17-16-30-293.png
          163 kB
          Alexander Fedulov

        Issue Links

          Activity

            People

              gongzhongqiang Zhongqiang Gong
              gongzhongqiang Zhongqiang Gong
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: