[jira] [Created] (FLINK-18938) Throw better exception message for quering sink-only connector

[Shang Yuanchun (Jira)]

Jark Wu created FLINK-18938:
-------------------------------

             Summary: Throw better exception message for quering sink-only connector
                 Key: FLINK-18938
                 URL: https://issues.apache.org/jira/browse/FLINK-18938
             Project: Flink
          Issue Type: Improvement
            Reporter: Jark Wu


Currently, if we are quering a sink-only connector, for example: {{SELECT * FROM elasticsearch_sink}}, a following exception will be thrown:


{code}
Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'elasticsearch-7' that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory' in the classpath.

Available factory identifiers are:

datagen
{code}


The above exception is very misleading, it sounds like that the elasticsearch jar is not loaded, however the elasticsearch jar is in the lib directory of Flink cluster.

We can improve the exception that explicitly telling users the found connector only support as sink, can't be used as a source.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)