Loading...

XML

Word

Printable

JSON

Type: Task
Resolution: Fixed
Priority: Major - P3
Fix Version/s: 8.1.0-rc0
Affects Version/s: None
Component/s: None
Labels:
None

Assigned Teams:

Atlas Streams
Backwards Compatibility:
Fully Compatible
Sprint:
Sprint 66, Sprint 67
Confidence Status:
None
Work Order:
3
CAR Domain/s:
None

Aha! Reference:
None
Tracking Level:
None
Risk Status:
None
Exec Notes:
None
Goal Name(s):
None
Goal Link:
None

The changes required here will be minimal after having added support for the ChangeStreamOperator. In the KafkaConsumerOperator case, add additional tests to ensure that the per partition watermark is also being updated correctly with processingTime timestamps
Add tests with checkpoints in the middle

has to be done after

SERVER-98430 Processing time window impl for change stream source operator

Closed

SERVER-99061 Rename fields for processing time windows

Closed

SERVER-99063 Rename fields for processing time windows

Closed

SERVER-99408 Processing time window impl for generated data source operator

Closed

is related to

SERVER-100121 Throw error if $source.timeField is specified with a processing time window

Closed

Assignee:: Jada Lilleboe
Reporter:: Mayuresh Kulkarni
Participants:: Jada Lilleboe, Mayuresh Kulkarni
Votes:: 0 Vote for this issue
Watchers:: 1 Start watching this issue

Created:: Dec 13 2024 03:40:49 AM UTC
Updated:: Feb 07 2025 10:25:39 PM UTC
Resolved:: Feb 07 2025 10:25:37 PM UTC