啟動FLINK SQL Client的時候

$FLINK_HOME/bin/sql-client.sh embedded -d $FLINK_HOME/conf/sql.my.yaml -l /home/appleyuchi/bigdata/flink-1.12/lib

出現下面的報錯:

Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue.
?? ?at org.apache.flink.table.client.SqlClient.main(SqlClient.java:213)
Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could not create execution context.
?? ?at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:818)
?? ?at org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:227)
?? ?at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108)
?? ?at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException:

Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in
the classpath.

Reason: Required context properties mismatch.

The matching candidates:
org.apache.flink.table.sources.CsvAppendTableSourceFactory
Mismatched properties:
'connector.type' expects 'filesystem', but is 'kafka'
'format.type' expects 'csv', but is 'json'

?

最后兩句啥意思:

報錯信息	sql.my.yaml中具體位置
'connector.type' expects 'filesystem', but is 'kafka'
'format.type' expects 'csv', but is 'json'

?

解決方案[1]:

$FLINK_HOME/conf/sql.my.yaml中的kafka版本修改為universal

Reference:

[1]Flink編程報錯集錦

?

總結

以上是生活随笔為你收集整理的Could not find a suitable table factory for ‘org.apache.flink.table.factories.TableSourceFactory‘的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。