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

Question

I am trying to get the count from MySql Database using ExecuteSQL Processor. However everytime I do that I am getting following error.

Error:

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

Following is the configuration

If I change the query to select everything it works fine, like below.

Select * from temp.test

Answer 1

Keep alias name for the count(*) as count or cnt ..etc,

then use the query with alias name for count(*) in you execute sql processor.

Example:-

Select count(*) count from temp.test

(or)

Select count(*) as count from temp.test