[BEAM-363] CompressedSource splits when it shouldn't

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 0.1.0-incubating, 0.2.0-incubating
• Fix Version/s: 0.2.0-incubating
• Component/s: sdk-java-core
• Labels: Done
• Assignee: Dan Halperin
• Reporter: Dan Halperin
• Created: 20/Jun/16 22:36
• Updated: 06/Oct/20 21:59
• Resolved: 28/Jun/16 23:55

Description

CompressedSource is splitting when it should not. This can in some corner cases lead to data loss during dynamic work rebalancing.

Issue Links

• links to: GitHub Pull Request #504