NIFI QueryDatabase org.apache.avro.SchemaParseException: 非法字符: COUNT(*);

Question

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

错误：

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

配置如下

如果我将查询更改为 select，一切正常，如下所示。

Select * from temp.test

Answer 1

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

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

例子：-

Select count(*) count from temp.test

(或)

Select count(*) as count from temp.test

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