You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2019/04/01 19:23:00 UTC

[jira] [Created] (BEAM-6964) Simplify key context handling in ExecutableStageDoFnOperator

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)