[Task]: fix a potential bug in TimeRangeTracker - Githubissues

apache / beam

Apache Beam is a unified programming model for Batch and Streaming data processing.

https://beam.apache.org/

Apache License 2.0

7.76k stars 4.21k forks source link

[Task]: fix a potential bug in TimeRangeTracker #31894

Open tianz101 opened 1 month ago

tianz101 commented 1 month ago

What needs to happen?

For SpannerIO.readChangeStream, do not split the time range if the split point is less or equal to the start of the time range.

Issue Priority

Priority: 2 (default / most normal work should be filed as P2)

Issue Components

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

tianz101 commented 1 month ago

.take-issue