Browse Source

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

Romain 5 năm trước cách đây
mục cha
commit
bf32ab86e0

+ 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))