[NIFI-2674] QueryDatabaseTable should catch avro exceptions

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Assignee: Bryan Rosander
• Reporter: Bryan Rosander
• Created: 25/Aug/16 21:04
• Updated: 26/Aug/16 01:23
• Resolved: 26/Aug/16 01:23

Description

If avro throws an org.apache.avro.file.DataFileWriter$AppendWriteException during JdbcCommon.convertToAvroStream(), the exception is uncaught and the error in the log looks like the processor doesn't have a selected relationship for the flowfile rather than the real cause.

Was able to repro this using https://github.com/brosander/dev-dockerfiles/tree/master/sample-data/nyc_traffic_violations/mysql

docker build -t nyc_traffic_violations_mysql .
docker run --name nyc_traffic_violations_mysql -e MYSQL_ROOT_PASSWORD=my-secret-pw -e MYSQL_DATABASE=test -d -p 3306:3306 nyc_traffic_violations_mysql

Issue Links

• links to: GitHub Pull Request #953