GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/2805
Flink 5059
Only serialise events once in RecordWriter#broadcastEvent.
While adapting this, also clean up some related APIs which is now unused or
used similar patterns.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/NicoK/flink FLINK-5059
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2805.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2805
----
commit 4f036f4e2fcc89cb7879e5f4c4bc4449e8075405
Author: Nico Kruber <[email protected]>
Date: 2016-11-14T15:16:30Z
[FLINK-5059] only serialise events once during RecordWriter#broadcastEvent
commit e8f045c27740af49660878d44e4c9f215bc87d23
Author: Nico Kruber <[email protected]>
Date: 2016-11-14T17:48:49Z
[FLINK-5059] cleanup: remove ResultPartitionWriter#writeEvent()
commit 00ef77d05b997bfaadc9183beb7931cac70e234f
Author: Nico Kruber <[email protected]>
Date: 2016-11-14T18:01:23Z
[FLINK-5059] cleanup: remove ResultPartitionWriter#writeEndOfSuperstep and
RecordWriter#sendEndOfSuperstep
commit a0debb7cadb029be95142ab71928dd052a443cb4
Author: Nico Kruber <[email protected]>
Date: 2016-11-14T18:20:36Z
[FLINK-5059] cleanup: remove ResultPartitionWriter#writeEventToAllChannels
* also apply the "serialise once for all channels/sub-partitions" pattern
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
