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

AggregateQueryOperations produces wrong asSerializableString representation

    XMLWordPrintableJSON

Details

    Description

      A table API query:

              env.fromValues(1, 2, 3)
                      .as("number")
                      .select(col("number").count())
                      .insertInto(TEST_TABLE_API)
      

      produces

      INSERT INTO `default`.`timo_eu_west_1`.`table_api_basic_api` SELECT `EXPR$0` FROM (
          SELECT (COUNT(`number`)) AS `EXPR$0` FROM (
              SELECT `f0` AS `number` FROM (
                  SELECT `f0` FROM (VALUES 
                      (1),
                      (2),
                      (3)
                  ) VAL$0(`f0`)
              )
          )
          GROUP BY 
      )
      

      which is missing a grouping expression

      Attachments

        Issue Links

          Activity

            People

              dwysakowicz Dawid Wysakowicz
              dwysakowicz Dawid Wysakowicz
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: