Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
The SDK's streaming tests actually use a BoundedReadFromUnboundedSource while "forcing" a streaming pipeline (although the input is Read.Bounded).
The TestSparkRunner should be able to use the underlying UnboundedSource to execute a streaming pipeline.
Attachments
Issue Links
- relates to
-
BEAM-920 Support triggers, panes and watermarks.
- Resolved
- links to