Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-11074

Improve the harness test to make it possible test with state backend

    XMLWordPrintableJSON

Details

    Description

      Currently, the harness test can only test without state backend. If you use a DataView in the accumulator of the aggregate function, the DataView is a java object and held in heap, not replaced with StateMapView/StateListView which values are actually held in the state backend. We should improve the harness test to make it possible to test with state backend. Otherwise, issues such as FLINK-10674 could have never been found. With this harness test available, we could test the built-in aggregate functions which use the DataView more fine grained.

      Attachments

        Issue Links

          Activity

            People

              dian.fu Dian Fu
              dian.fu Dian Fu
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: