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 65
Confidence Status:
None
Work Order:
3

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

Rename the existing minEventTimestampMs and maxEventTimestampMs fields in StreamDocument to instead be minDocTimestampMs and maxDocTimestampMs. These will hold the timestamp of an event and will either be the processingTime timestamp or the eventTime timestamp.
Make watermarks work - rename the eventTimeWatermarkMs field in the watermark control message to watermarkTimestampMs and populate it with the right timestamp.

has to be done before

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

Closed

SERVER-98431 Add support for KafkaConsumerOperator for processingTime windows and add checkpointing tests

Closed

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

Created:: Jan 07 2025 07:55:39 PM UTC
Updated:: Jan 15 2025 04:08:13 PM UTC
Resolved:: Jan 08 2025 04:32:23 PM UTC