[FLINK-20323] CorrelateSortToRankRule cannot deal with multiple groupings

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.14.0
• Component/s: Table SQL / Planner
• Labels: auto-deprioritized-major pull-request-available
• Assignee: Shuo Cheng
• Reporter: Timo Walther
• Created: 24/Nov/20 14:16
• Updated: 28/Aug/21 12:23
• Resolved: 27/Jul/21 08:55

Description

Fix the following test case in CorrelateSortToRankRuleTest:

  @Test // TODO: this is a valid case to support
  def testMultipleGroupingsNotSupported(): Unit = {
    val query =
      s"""
         |SELECT f0, f2
         |FROM
         |  (SELECT DISTINCT f0, f1 FROM t1) t2,
         |  LATERAL (
         |    SELECT f2
         |    FROM t1
         |    WHERE f0 = t2.f0 AND f1 = t2.f1
         |    ORDER BY f2
         |    DESC LIMIT 3
         |  )
      """.stripMargin
    util.verifyPlan(query)
  }

Currently, we only support one equal condition not f0 = t2.f0 AND f1 = t2.f1.

Issue Links

• is related to: FLINK-18988 Continuous query with LATERAL and LIMIT produces wrong result
• links to: GitHub Pull Request #16503