[prism] Using Real Time, when operating in "production" mode.

[prism] Using Real Time, when operating in "production" mode.

Skip to content

apache / beam Public

Notifications You must be signed in to change notification settings
Fork 4.5k
Star 8.5k

Closed

Assignees

Labels

P2 go prism stale streamingIssues pertaining to streaming functionality

Milestone

2.70.0 Release

Description

opened

on Oct 15, 2024

Set processing Time timers and ProcessContinuations to be scheduled via a Real Time clock for a "quasi production" mode.

Requires per-pipeline configuration to be plumbed into the Element manager to toggle this line:

https://github.com/apache/beam/blob/master/sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go#L1640

Metadata

Metadata

Assignees

shunping

Labels

P2 go prism stale streamingIssues pertaining to streaming functionality

Type

No type

Projects

No projects

Milestone

2.70.0 Release

Relationships

None yet

Development

No branches or pull requests

Issue actions