[BEAM-6352] Watch PTransform is broken

• Type: Bug
• Status: Resolved
• Priority: P0
• Resolution: Fixed
• Affects Version/s: 2.9.0
• Fix Version/s: 2.10.0
• Component/s: sdk-java-core
• Labels: Done
• Assignee: Scott Wegner
• Reporter: Gleb Kanterov
• Created: 03/Jan/19 15:36
• Updated: 06/Oct/20 21:55
• Resolved: 18/Jan/19 21:36

Description

List of affected tests:
org.apache.beam.sdk.transforms.WatchTest > testSinglePollMultipleInputsWithSideInput FAILED
org.apache.beam.sdk.transforms.WatchTest > testMultiplePollsWithKeyExtractor FAILED
org.apache.beam.sdk.transforms.WatchTest > testSinglePollMultipleInputs FAILED
org.apache.beam.sdk.transforms.WatchTest > testMultiplePollsWithTerminationDueToTerminationCondition FAILED
org.apache.beam.sdk.transforms.WatchTest > testMultiplePollsWithManyResults FAILED
org.apache.beam.sdk.transforms.WatchTest > testSinglePollWithManyResults FAILED
org.apache.beam.sdk.transforms.WatchTest > testMultiplePollsStopAfterTimeSinceNewOutput org.apache.beam.sdk.transforms.WatchTest > testMultiplePollsWithTerminationBecauseOutputIsFinal FAILED
org.apache.beam.sdk.io.AvroIOTest$NeedsRunnerTests > testContinuouslyWriteAndReadMultipleFilepatterns[0: true] FAILED
org.apache.beam.sdk.io.AvroIOTest$NeedsRunnerTests > testContinuouslyWriteAndReadMultipleFilepatterns[1: false] FAILED
org.apache.beam.sdk.io.FileIOTest > testMatchWatchForNewFiles FAILED
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest > testReadWatchForNewFiles FAILED

java.lang.IllegalArgumentException: org.apache.beam.sdk.transforms.Watch$WatchGrowthFn, @ProcessElement process(ProcessContext, GrowthTracker): Has tracker type Watch.GrowthTracker<OutputT, KeyT, TerminationStateT>, but the DoFn's tracker type must be of type RestrictionTracker.

Relevant pull requests:

• https://github.com/apache/beam/pull/6467
• https://github.com/apache/beam/pull/7374

Now tests are marked with @Ignore referencing this JIRA issue

Issue Links

• links to: GitHub Pull Request #7520
• links to: GitHub Pull Request #7540
• links to: GitHub Pull Request #7575