diff --git a/storage/mysql/68-mysql.js b/storage/mysql/68-mysql.js
index 87dad1b3..17f8bfdc 100644
--- a/storage/mysql/68-mysql.js
+++ b/storage/mysql/68-mysql.js
@@ -145,6 +145,7 @@ module.exports = function(RED) {
                                     status = { fill: "red", shape: "ring", text: RED._("mysql.status.error") + ": " + err.code };
                                     node.status(status);
                                     node.error(err, msg);
+                                    send([null, { query: msg.topic, payload: 'ERROR', error: err }]);
                                 }
                                 else {
                                     msg.payload = rows;