如何在flinksql中进行计数

Question

我想在flink SQL中执行count(0(，但它给出了类似的异常

org.apache.flink.client.program.ProgramInvocationException：主要方法导致错误：SQL解析失败。DDL中的UDT还不受支持。

不知道有什么不对劲吗？

预期输出应该工作良好

INSERT INTO request_join
select requestId,count(0) from requests
GROUP BY TUMBLE(rowtime, INTERVAL '1' HOUR),requestId;

表的模式在这里

name: request_join
schema:
- '`requestId` VARCHAR'
- '`count` LONG'
properties:
'connector.type': 'kafka'
'connector.version': 'universal'
'connector.topic': 'request_join_test'
'connector.startup-mode': 'latest-offset'
'connector.properties.0.key': 'zookeeper.connect'
'connector.properties.0.value': '10.XXXXXXXXX'
'connector.properties.1.key': 'bootstrap.servers'
'connector.properties.1.value': '10.XXXXXXXXX'
'connector.properties.2.key': 'group.id'
'connector.properties.2.value': 'request_join_test'
'update-mode': 'append'
'format.type': 'json'
'format.json-schema': '{type: "object", properties: {requestId: { type: "string"},count:{type: 
"number"}}}'

没有发现任何错误，但它就是不起作用，如果我不计算并从模式中删除计数，它会很好地工作，所以我相信sql本身是好的。

我检查了flink sql，它说DDL中不支持某些函数，所以flink支持不算数吗？我从例子中可以看出，它非常支持SUM。

Answer 1

您的模式有问题，架构：-'requestIdVARCHAR'-'countBIGINT'