flink
flink copied to clipboard
[FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format
Changes:
- Disable
FLUSH_AFTER_WRITE_VALUE - Use
ObjectWriter#writeValue(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator, java.lang.Object)instead ofObjectWriter#writeValue(java.io.OutputStream, java.lang.Object) - Manual flush
JsonGenerator
CI report:
- 4d835f9272304bd5535f1d0ac96261e8e92eece9 Azure: SUCCESS
Bot commands
The @flinkbot bot supports the following commands:@flinkbot run azurere-run the last Azure build
@robobario Thanks for your kind suggestions. PR is updated, PTAL~
@afedulov @robobario I had added unit test for this. Thank you @afedulov for giving draft it unit test to me.
@leonardBang PTAL
CI Passed Merging.