[BEAM-1779] Port UnboundedSourceWrapperTest to use Flink operator test harness

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.1.0
• Component/s: runner-flink
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 22/Mar/17 10:42
• Updated: 24/Jul/20 20:16
• Resolved: 07/Jun/17 17:51

Description

Currently, the test manually invokes the operator. This can be improved by using a harness, which emulates how Flink invokes operators.

Issue Links

• links to: GitHub Pull Request #2286