[X] I had searched in the issues and found no similar issues.
English problem description
SeaTunnel connector development document seatunnel connectors v2/README. zh. md There is an error in the description of the development document for a new connector.The article mentions
Create Sink and Create Source are methods for creating Source and Sink, respectively, and currently do not need to be implemented
Actually, they should be implemented, otherwise it will cause an exception Plugin Plugin Identifier {engineType='seattunnel ', pluginType='source', pluginName='XXXXXX'} not found
In addition, there is no mention of the need to implement creatSink and creatSource in the creation of a new seatunnel v2 connector
实际上他们应该被实现，不然会引起异常 Plugin PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='XXXXXX'} not found
另外在 创建新的seatunnel v2 connector 中也没提及需要实现 createSink 和 createSource
SeaTunnel Version
DEV
SeaTunnel Config
无
Running Command
无
Error Exception
Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:226)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at org.apache.seatunnel.example.engine.SeaTunnelEngineLocalExample.main(SeaTunnelEngineLocalExample.java:48)
Caused by: java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='OceanBase-CDC'} not found.
at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:237)
at org.apache.seatunnel.engine.core.parse.ConnectorInstanceLoader.loadSourceInstance(ConnectorInstanceLoader.java:61)
at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:79)
at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:370)
at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:209)
at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114)
at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182)
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:163)
... 2 more
YOMO-Lee
commented
3 weeks ago
Search before asking
English problem description
SeaTunnel connector development document seatunnel connectors v2/README. zh. md There is an error in the description of the development document for a new connector.The article mentions
Actually, they should be implemented, otherwise it will cause an exception Plugin Plugin Identifier {engineType='seattunnel ', pluginType='source', pluginName='XXXXXX'} not found
In addition, there is no mention of the need to implement creatSink and creatSource in the creation of a new seatunnel v2 connector
中文问题描述
SeaTunnel连接器开发文档 seatunnel-connectors-v2/README.zh.md 关于一个新连接器的开发文档描述有错误 文中提到
实际上他们应该被实现，不然会引起异常 Plugin PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='XXXXXX'} not found 另外在 创建新的seatunnel v2 connector 中也没提及需要实现 createSink 和 createSource
SeaTunnel Version
DEV
SeaTunnel Config
Running Command
Error Exception
Zeta or Flink or Spark Version
No response
Java or Scala Version
No response
Screenshots
Are you willing to submit PR?
Code of Conduct