[FLINK-27212] Failed to CAST('abcde', VARBINARY)

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.15.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Marios Trivyzas
• Reporter: Shengkai Fang
• Created: 13/Apr/22 03:00
• Updated: 20/Apr/22 03:37
• Resolved: 19/Apr/22 15:33

Description

Please add test in the CalcITCase

@Test
  def testCalc(): Unit = {
    val sql =
      """
        |SELECT CAST('abcde' AS VARBINARY(6))
        |""".stripMargin
    val result = tEnv.executeSql(sql)
    print(result.getResolvedSchema)
    result.print()
  }

The exception is

Caused by: org.apache.flink.table.api.TableException: Odd number of characters.
	at org.apache.flink.table.utils.EncodingUtils.decodeHex(EncodingUtils.java:203)
	at StreamExecCalc$33.processElement(Unknown Source)
	at org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:99)
	at org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:80)
	at org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)
	at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
	at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
	at org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:418)
	at org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:513)
	at org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:103)
	at org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:92)
	at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
	at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
	at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:332)

Issue Links

• links to: GitHub Pull Request #19507
• links to: GitHub Pull Request #19516