소스 검색

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

Romain 6 년 전
부모
커밋
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:
     try:
       return func(*args, **kwargs)
       return func(*args, **kwargs)
     except RestException as e:
     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)
       raise QueryError(message)
     except Exception as e:
     except Exception as e:
       message = force_unicode(str(e))
       message = force_unicode(str(e))