Преглед изворни кода

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

Romain пре 5 година
родитељ
комит
bf32ab86e0
1 измењених фајлова са 5 додато и 1 уклоњено
  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))