[BEAM-11193] Fix KeyedTimerData

• Type: Task
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: Missing
• Component/s: runner-samza
• Assignee: Unassigned
• Reporter: Ke Wu
• Created: 05/Nov/20 00:12
• Updated: 13/Jan/22 22:48
• Resolved: 12/Jan/22 17:37

Description

outputTimestamp was added to KeyedTimerDataCoder and encoded in the middle of stream. This is not a backward compatible changes for stateful jobs. 

All new fields in KeyedTimerData should be appended to the last in KeyedTimerDataCoder

Issue Links

• links to: GitHub Pull Request #13294