Uploaded image for project: 'Apache Nemo'
  1. Apache Nemo
  2. NEMO-302

One-to-one communication when GBKW is after FlattenTransform

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • None

    Description

      Beam Nexmark query 7 has hotkey fanout. When Nemo translates Query7 DAG, it does not shuffle (key partitioning) in hotkey fanout. 

      See the attached file: 

      edge14 and 15 should be shuffle, but it is one-to-one. We should fix the PipelineTranslator

       

      +

       

      Query4 has the similar pattern with Query7. 

      Nemo should shuffle data before FlattenTransform (vertex14). 

       

       

       

      Attachments

        1. f9af95e5368c475c8067e79b03f2141c.svg
          105 kB
          Tae-Geon Um
        2. query4.svg
          136 kB
          Tae-Geon Um

        Activity

          People

            Unassigned Unassigned
            taegeonum Tae-Geon Um
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: