[
https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447766#comment-17447766
]
Shuo Cheng commented on FLINK-24997:
------------------------------------
[~zouyunhe] you can follow the similar Jira FLINK-17484
> count(null) not supported in flink sql query
> --------------------------------------------
>
> Key: FLINK-24997
> URL: https://issues.apache.org/jira/browse/FLINK-24997
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Client, Table SQL / Planner
> Affects Versions: 1.14.0
> Reporter: zouyunhe
> Priority: Major
>
> I use sql client to submit a sql query to flink session cluster, the sql is
> {code:java}
> select count(null);{code}
> it submit failed and throws the exception
> {code:java}
> org.apache.flink.table.client.gateway.SqlExecutionException: Could not
> execute SQL statement.
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:211)
> ~[flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor.executeQuery(LocalExecutor.java:231)
> ~[flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.cli.CliClient.callSelect(CliClient.java:532)
> ~[flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:423)
> ~[flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.cli.CliClient.lambda$executeStatement$1(CliClient.java:332)
> [flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at java.util.Optional.ifPresent(Optional.java:183) ~[?:?]
> at
> org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:325)
> [flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:297)
> [flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:221)
> [flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151)
> [flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95)
> [flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187)
> [flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)
> [flink-sql-client_2.12-1.14.0.jar:1.14.0]
> Caused by: java.lang.UnsupportedOperationException: Unsupported type 'NULL'
> to get internal serializer
> at
> org.apache.flink.table.runtime.typeutils.InternalSerializers.createInternal(InternalSerializers.java:125)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.runtime.typeutils.InternalSerializers.create(InternalSerializers.java:55)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
> ~[?:?]
> at
> java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
> ~[?:?]
> at
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?]
> at
> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
> ~[?:?]
> at
> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) ~[?:?]
> at
> java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260)
> ~[?:?]
> at
> java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) ~[?:?]
> at
> org.apache.flink.table.runtime.typeutils.RowDataSerializer.<init>(RowDataSerializer.java:73)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.runtime.typeutils.InternalSerializers.createInternal(InternalSerializers.java:109)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.runtime.typeutils.InternalSerializers.create(InternalSerializers.java:55)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.runtime.typeutils.InternalTypeInfo.of(InternalTypeInfo.java:83)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:106)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:134)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:250)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecExchange.translateToPlanInternal(StreamExecExchange.java:75)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:134)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:250)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
