Maximilian Michels created BEAM-6964:
----------------------------------------
Summary: Simplify key context handling in
ExecutableStageDoFnOperator
Key: BEAM-6964
URL: https://issues.apache.org/jira/browse/BEAM-6964
Project: Beam
Issue Type: Improvement
Components: runner-flink
Reporter: Maximilian Michels
Assignee: Maximilian Michels
The code is a bit hard to understand because of multiple keys being set in
different contexts, for 1) state requests 2) timers setting 3) timer firing.
This should be simplified.
We can also introduce a helper class for key encoding/decoding to achieve
consistency across all places which use a key serializer.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
