​
SeaTunnel文档 https://seatunnel.apache.org/zh-CN/docs/2.3.11/connector-v2/sink/Paimon

文档中有教程 跟着部署就可以

使用对应数据源的时候 最好看一下文档 还有的说放在${SEATUNNEL_HOME}/plugins/jdbc/lib 下面 都放了
​

问题1 闪退

windows上使用\ linux上使用/

.\bin\seatunnel-cluster.cmd -d --role master 加上-r 或者 --role 就闪退

文件存在问题 直接将seatunnel-cluster.cmd中的 set "NODE_ROLE=master_and_worker"改成 set “NODE_ROLE=master” 再复制一个 改成 set “NODE_ROLE=worker” 不加角色的启动

问题2 报错 java.util.LinkedHashMap cannot be cast to java.util.ArrayList

可能是使用了source_table_name 的原因 虽然有些文档上是这么写的 但是应该改成 plugin_input 和plugin_output 参数

问题3 Discovery plugin jar for: PluginIdentifier{engineType=‘seatunnel’, pluginType=‘sink’, pluginName=‘Jdbc’}

这样的报错 有些确实是缺少jar包 但是有些可能不是!!!!! 可能是任务的语句有问题 如果可以直接使用项目去启动 可能会直接找到问题在哪里。。。。

使用项目启动 需要先打包

项目中有一些类不存在 打包之后可以运行
src/main/java/org/apache/seatunnel/example/engine/SeaTunnelEngineLocalExample.java 启动类
jar包放在项目对应文件下 但是找不到 可能是 org.apache.seatunnel.common.config.Common 这个类的原因 appRootDir 中Paths.get(path).getParent().getParent() 改成 Paths.get(path).getParent().getParent().getParent() 直接找根节点
​

Logo

北京人形旗下天工造物具身智能开源社区,聚焦具身天工与慧思开物两大平台

更多推荐