diff --git a/lib/blazer/adapters/drill_adapter.rb b/lib/blazer/adapters/drill_adapter.rb
index 896be3b28..1ff5ba06c 100644
--- a/lib/blazer/adapters/drill_adapter.rb
+++ b/lib/blazer/adapters/drill_adapter.rb
@@ -17,8 +17,12 @@ def run_statement(statement, comment)
 
         begin
           response = JSON.parse(http.post(uri.request_uri, data.to_json, header).body)
-          columns = response["columns"]
-          rows = response["rows"].map { |r| r.values }
+          if response["errorMessage"]
+            error = response["errorMessage"]
+          else
+            columns = response["columns"]
+            rows = response["rows"].map { |r| r.values }
+          end
         rescue => e
           error = e.message
         end