apache-nifi - NIFI QueryDatabaes org.apache.avro.SchemaParseException : Illegal character in: COUNT(*);

Question

我正在尝试使用 ExecuteSQL 处理器从 MySql 数据库中获取计数。但是每次我这样做时都会出现以下错误。

错误:

org.apache.avro.SchemaParseException: Illegal character in: COUNT(*);

配置如下

如果我更改查询以选择所有内容，它会正常工作，如下所示。

Select * from temp.test

Answer 1

保留计数的别名(*) 作为计数或 cnt ..等，

然后在执行 sql 处理器时使用别名为 count(*) 的查询。

示例:-

Select count(*) count from temp.test

(或)

Select count(*) as count from temp.test