[FLINK-11282] Merge StreamRecordWriter into RecordWriter

• Type: Sub-task
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.8.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 08/Jan/19 08:05
• Updated: 23/Jan/19 17:38
• Resolved: 23/Jan/19 17:38

Description

StreamRecordWriter is only used for streaming job which extends RecordWriter. The only difference in StreamRecordWriter is maintaining the OutputFlusher thread which can be migrated into RecordWriter because the flushAlways property in RecordWriter has relationship with OutputFlusher.

To do so, we can introduce the special BroadcastRecordWriter which extends RecordWriter for improving broadcast selector for FLINK-10662 . And the RecordWriter division is unified for both streaming and batch jobs.

Issue Links

• links to: GitHub Pull Request #7438