You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/04/13 03:00:01 UTC
[jira] [Created] (FLINK-27212) Failed to CAST('abcde', VARBINARY)
Shengkai Fang created FLINK-27212:
-------------------------------------
Summary: Failed to CAST('abcde', VARBINARY)
Key: FLINK-27212
URL: https://issues.apache.org/jira/browse/FLINK-27212
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 1.16.0
Reporter: Shengkai Fang
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)
```
--
This message was sent by Atlassian Jira
(v8.20.1#820001)