the question is as follow

[codeseeking]

Traceback (most recent call last):
File "", line 6, in
File "/data/python3/anaconda3/lib/python3.7/site-packages/pyflink/table/table_environment.py", line 858, in sql_query
j_table = self._j_tenv.sqlQuery(query)
File "/data/python3/anaconda3/lib/python3.7/site-packages/py4j/java_gateway.py", line 1286, in call
answer, self.gateway_client, self.target_id, self.name)
File "/data/python3/anaconda3/lib/python3.7/site-packages/pyflink/util/exceptions.py", line 146, in deco
return f(*a, **kw)
File "/data/python3/anaconda3/lib/python3.7/site-packages/py4j/protocol.py", line 328, in get_return_value
format(target_id, ".", name), value)
py4j.protocol.Py4JJavaError: An error occurred while calling o82.sqlQuery.
: org.apache.flink.table.api.ValidationException: Unable to create a source for reading table 'default_catalog.default_database.source'.