Re: flink自定义connector相关报错

2021-06-04 文章 Zorro
看日志中提示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()函数中是不是添

Re: flink自定义connector相关报错

2021-06-02 文章 chenlei677
你好,还有完整信息么?一般逻辑是,先找文件,然后匹配属性。麻烦将完整日志输出出来看看。 -- Sent from: http://apache-flink.147419.n8.nabble.com/

回复: flink自定义connector相关报错

2021-06-02 文章 MOBIN
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

Re: flink自定义connector相关报错

2021-06-02 文章 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.table.factories.Factory 祝好 Leonard

flink自定义connector相关报错

2021-06-02 文章 MOBIN
请教下,在自定义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,但