The partitioned beat pipe currently filters out all low watermarks since it only processes non-deleted data events (bitvector entry is not set) or if vother is long.MinValue (per-partition punctuation), but neglects low watermarks (vother==-1). Fixing these to check for < 0 (common check for either punctuation or low watermark used throughout the code) rather than == long.MinValue resolves the issue.
The partitioned beat pipe currently filters out all low watermarks since it only processes non-deleted data events (bitvector entry is not set) or if vother is long.MinValue (per-partition punctuation), but neglects low watermarks (vother==-1). Fixing these to check for < 0 (common check for either punctuation or low watermark used throughout the code) rather than == long.MinValue resolves the issue.