[flink] Bubble up autocomplete errors
@@ -204,7 +204,6 @@ class FlinkSqlApi(Api):
def autocomplete(self, snippet, database=None, table=None, column=None, nested=None):
response = {}
- try:
if database is None:
response['databases'] = self.show_databases()
elif table is None:
@@ -219,13 +218,6 @@ class FlinkSqlApi(Api):
}
for col in columns
]
- else:
- response = {}
-
- except Exception as e:
- LOG.warn('Autocomplete data fetching error: %s' % e)
- response['code'] = 500
- response['error'] = str(e)
return response
