【 使用环境 】ob2.7
【 OB or 其他组件 】
【 使用版本 】
【问题描述】在flinksql中创建了一行connector=‘oceanbase’的表,作为lookup join的源表,但是执行时报错 connector ‘oceanbase’ only can be used a sink,it cannot be used a source
OceanBase 可以用的 Flink 连接器有很多个,可以参考这个文档:https://github.com/oceanbase/flink-connector-oceanbase/blob/main/README_CN.md
对于源表或者维表,可以用 Flink Jdbc Connector。使用该连接器时,除了要手动加入 oceanbase-client jar 包后,还需要设置这两个参数:
- url:需要以 jdbc:oceanbase 开头
- compatible-mode:需要填 mysql 或 oracle