Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-34285 [Umbrella] Test Flink Release 1.19
  3. FLINK-34348

Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input

    XMLWordPrintableJSON

Details

    Description

      Window TVF aggregation supports changelog stream  is ready for testing. User can add a window tvf aggregation as a down stream after CDC source or some nodes that will produce cdc records.

      Someone can verify this feature with:

      1. Prepare a mysql table, and insert some data at first.
      2. Start sql-client and prepare ddl for this mysql table as a cdc source.
      3. You can verify the plan by `EXPLAIN PLAN_ADVICE` to check if there is a window aggregate node and the changelog contains "UA" or "UB" or "D" in its upstream. 
      4. Use different kinds of window tvf to test window tvf aggregation while updating the source data to check the data correctness.

      Attachments

        1. 截屏2024-02-07 16.21.37.png
          94 kB
          Feng Jin
        2. 截屏2024-02-07 16.21.55.png
          43 kB
          Feng Jin
        3. 截屏2024-02-07 16.22.24.png
          481 kB
          Feng Jin
        4. 截屏2024-02-07 16.23.12.png
          443 kB
          Feng Jin
        5. 截屏2024-02-07 16.23.27.png
          530 kB
          Feng Jin
        6. 截屏2024-02-07 16.23.38.png
          544 kB
          Feng Jin
        7. 截屏2024-02-07 16.29.09.png
          322 kB
          Feng Jin
        8. 截屏2024-02-07 16.29.21.png
          60 kB
          Feng Jin
        9. 截屏2024-02-07 16.29.34.png
          26 kB
          Feng Jin
        10. 截屏2024-02-07 16.46.12.png
          192 kB
          Feng Jin
        11. 截屏2024-02-07 16.46.23.png
          51 kB
          Feng Jin
        12. 截屏2024-02-07 16.46.37.png
          36 kB
          Feng Jin
        13. 截屏2024-02-07 16.53.37.png
          295 kB
          Feng Jin
        14. 截屏2024-02-07 16.53.47.png
          77 kB
          Feng Jin
        15. 截屏2024-02-07 16.54.01.png
          52 kB
          Feng Jin
        16. 截屏2024-02-07 16.59.22.png
          278 kB
          Feng Jin
        17. 截屏2024-02-07 16.59.33.png
          41 kB
          Feng Jin
        18. 截屏2024-02-07 16.59.42.png
          52 kB
          Feng Jin

        Issue Links

          Activity

            People

              hackergin Feng Jin
              xuyangzhong xuyang
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: