You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/27 03:27:00 UTC

[jira] [Created] (FLINK-22486) Wrong results of the IN operator

Shengkai Fang created FLINK-22486:
-------------------------------------

             Summary: Wrong results of the IN operator
                 Key: FLINK-22486
                 URL: https://issues.apache.org/jira/browse/FLINK-22486
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Planner
    Affects Versions: 1.13.0
            Reporter: Shengkai Fang


Please add the following test in the {{CalcITCase}}.
{code:java}
@Test
  def testSimpleProject(): Unit = {
    val myTableDataId = TestValuesTableFactory.registerData(Seq(row("HC809")))
    val ddl =
      s"""
         |CREATE TABLE SimpleTable (
         |  content String
         |) WITH (
         |  'connector' = 'values',
         |  'data-id' = '$myTableDataId',
         |  'bounded' = 'true'
         |)
         |""".stripMargin
    tEnv.executeSql(ddl)

    val sql =
      """
        |SELECT content from SimpleTable where content in (
        |'CTNBSmokeSensor','H388N',
        |'H389N',
        |'GHL-IRD','JY-BF-20YN','HC809',
        |'DH-9908N-AEP','DH-9908N'
        |)
        |
        |""".stripMargin

    checkResult(
      sql,
      Seq(row("HC809"))
    )
  }
{code}

It should return the result but nothing return



--
This message was sent by Atlassian Jira
(v8.3.4#803005)