beam icon indicating copy to clipboard operation
beam copied to clipboard

[Bug]: FlinkRunner does not emit watermark with empty source

Open je-ik opened this issue 1 year ago • 1 comments

What happened?

If unbounded source is empty, watermarks are not sent from the source to downstream operators.

Issue Priority

Priority: 3 (minor)

Issue Components

  • [ ] Component: Python SDK
  • [ ] Component: Java SDK
  • [ ] Component: Go SDK
  • [ ] Component: Typescript SDK
  • [ ] Component: IO connector
  • [ ] Component: Beam YAML
  • [ ] Component: Beam examples
  • [ ] Component: Beam playground
  • [ ] Component: Beam katas
  • [ ] Component: Website
  • [ ] Component: Spark Runner
  • [X] Component: Flink Runner
  • [ ] Component: Samza Runner
  • [ ] Component: Twister2 Runner
  • [ ] Component: Hazelcast Jet Runner
  • [ ] Component: Google Cloud Dataflow Runner

je-ik avatar May 24 '24 09:05 je-ik

Related to #31085.

je-ik avatar May 24 '24 10:05 je-ik