Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3473 Add partial aggregate support in Flink
  3. FLINK-3586

Risk of data overflow while use sum/count to calculate AVG value

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Minor
    • Resolution: Fixed
    • None
    • 1.1.0
    • None

    Description

      Now, we use (sum: Long, count: Long to store AVG partial aggregate data, which may have data overflow risk, we should use unbounded data type(such as BigInteger) to store them for necessary data types.

      Attachments

        Issue Links

          Activity

            People

              fhueske Fabian Hueske
              chengxiang li Chengxiang Li
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: