You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "liufangliang (Jira)" <ji...@apache.org> on 2020/08/20 11:50:00 UTC
[jira] [Commented] (FLINK-18938) Throw better exception message for
quering sink-only connector
[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181135#comment-17181135 ]
liufangliang commented on FLINK-18938:
--------------------------------------
Hi [~jark], Can you assign it to me ?
The following tips are very complete and precise, I think there is no need to optimize.
{code:java}
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.
{code}
Tips（support as sink or source） can follow the identifier. For example:
{code:java}
Available factory identifiers are:
datagen (source,sink)
elasticsearch-7 (sink-only)
test-connector (source-only)
{code}
[~jark] [~lzljs3620320] What do you think of my solution?
> 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
> Priority: Major
>
> 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)