diff --git a/plugins/dbgate-plugin-mongo/src/backend/driver.js b/plugins/dbgate-plugin-mongo/src/backend/driver.js
index 23aca12b6..9c10ba8eb 100644
--- a/plugins/dbgate-plugin-mongo/src/backend/driver.js
+++ b/plugins/dbgate-plugin-mongo/src/backend/driver.js
@@ -266,6 +266,11 @@ const driver = {
       pass.write(transformMongoData(row));
     });
 
+    // propagate error
+    cursorStream.on('error', (err) => {
+      pass.emit('error', err);
+    });
+
     // Called once the cursor is fully read
     cursorStream.on('end', () => {
       pass.emit('end');