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

Sum of FlinkSql after two table union all.The value is too large.

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 1.7.0
    • Fix Version/s: 1.7.0
    • Component/s: Table SQL / API
    • Labels:
    • Flags:
      Important

      Description

      SELECT k AS KEY, SUM(p) AS pv
      FROM (
      SELECT tumble_start(stime, INTERVAL '1' minute) AS k
      , COUNT AS p
      FROM flink_test1
      GROUP BY tumble(stime, INTERVAL '1' minute)
      UNION ALL
      SELECT tumble_start(stime, INTERVAL '1' minute) AS k
      , COUNT AS p
      FROM flink_test2
      GROUP BY tumble(stime, INTERVAL '1' minute)
      ) t
      GROUP BY k

      The Result of executing this sql is about 7000 per minute and keeping increasing.But the result is 60 per minute for per table.Is there an error in my SQL statement?

        Attachments

        1. image-2019-01-02-14-18-33-890.png
          31 kB
          jiwei
        2. image-2019-01-02-14-18-43-710.png
          17 kB
          jiwei
        3. screenshot-1.png
          31 kB
          jiwei

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              jiweiautohome jiwei
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: