flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "zhijiang (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-9913) Improve output serialization only once in RecordWriter
Date Mon, 23 Jul 2018 03:33:00 GMT
zhijiang created FLINK-9913:
-------------------------------

             Summary: Improve output serialization only once in RecordWriter
                 Key: FLINK-9913
                 URL: https://issues.apache.org/jira/browse/FLINK-9913
             Project: Flink
          Issue Type: Improvement
          Components: Network
    Affects Versions: 1.6.0
            Reporter: zhijiang
            Assignee: zhijiang
             Fix For: 1.6.0


Currently the {{RecordWriter}} emits output into multi channels via {{ChannelSelector}} 
or broadcasts output to all channels directly. Each channel has a separate {{RecordSerializer}}
for serializing outputs, that means the output will be serialized as many times as the number
of selected channels.

As we know, data serialization is a high cost operation, so we can get good benefits by improving the
serialization only once.

I would suggest the following changes for realizing it.
 # Only one {{RecordSerializer}} is created in {{RecordWriter}} for all the channels.
 # The output is serialized into the intermediate data buffer only once for different channels.
 # The intermediate serialization results are copied into different {{BufferBuilder}}s for
different channels.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message