Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-8520

Expansion of _CombinePerKeyWithHotKeyFanout has no typehints

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • sdk-py-core
    • None

    Description

      The expansion of _CombinePerKeyWithHotKeyFanout, which is used by CombinePerKey.with_hot_key_fanout(), uses DoFns (SplitHotCold) and CombineFns (PreCombineFn, PostCombineFn) and a lambda (SplitNonce) that have no typehints. If the user specified a typehints on the original CombineFn, the typehints are lost. This means that the fallback coder rather than the user specified coder.

      Attachments

        Activity

          People

            Unassigned Unassigned
            myffical@gmail.com Yifan Mai
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: