看日志中提示required字段没有给全:
Reason: Required context properties mismatch.
The following properties are requested:
connector.type=redis
host=localhost
port=6379
schema.0.data-type=VARCHAR(2147483647)
schema.0.name=username
schema.1.data-type=VARCHAR(2147483647)
schema.1.name=c
你的requiredOptions()函数中是不是添
你好,还有完整信息么?一般逻辑是,先找文件,然后匹配属性。麻烦将完整日志输出出来看看。
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Sorry, 工程下路径是没错的,是我发邮件时打错了,还可能是什么原因导致的呢?谢谢
src/main/resources/META-INF/services
| |
MOBIN
|
签名由网易邮箱大师定制
在2021年06月2日 17:05,Leonard Xu 写道:
路径错了
在 2021年6月2日,17:02,MOBIN <18814118...@163.com> 写道:
META-INF.services/org.apache.flink.table.factories.Factory
=> META-INF/services/org.apache.flink.t
路径错了
> 在 2021年6月2日,17:02,MOBIN <18814118...@163.com> 写道:
>
> META-INF.services/org.apache.flink.table.factories.Factory
=> META-INF/services/org.apache.flink.table.factories.Factory
祝好
Leonard
请教下,在自定义connector,IDEA上直接运demo时报了以下的错误:
org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a
suitable table factory for 'org.apache.flink.table.factories.TableSinkFactory'
in
the classpath.
工程的resource目录也准确引入了META-INF.services/org.apache.flink.table.factories.Factory,但