Browse Source

HUE-9280 [flink] Properly send back SQL error messages

Romain 5 years ago
parent
commit
bf32ab86e0
1 changed files with 5 additions and 1 deletions
  1. 5 1
      desktop/libs/notebook/src/notebook/connectors/flink_sql.py

+ 5 - 1
desktop/libs/notebook/src/notebook/connectors/flink_sql.py

@@ -41,7 +41,11 @@ def query_error_handler(func):
     try:
       return func(*args, **kwargs)
     except RestException as e:
-      message = force_unicode(json.loads(e.message)['errors'])
+      try:
+        message = force_unicode(json.loads(e.message)['errors'])
+      except:
+        message = e.message
+      message = force_unicode(message)
       raise QueryError(message)
     except Exception as e:
       message = force_unicode(str(e))