a11dev opened a new issue, #6800: URL: https://github.com/apache/seatunnel/issues/6800
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened simple seatunnel configuration , designed to sink oracle to mongodb. Oracle to postgres is working. I added a new sink ``` MongoDB { source_table_name = "source" uri = "mongodb://user:pwd@ipaddress:27017/dbname?readPreference=secondary&slaveOk=true" database = "dbname" collection = "destcollection" upsert-enable = true primary-key = ["pkname"] } ``` it ends with this exception. Is related to mongodb java library, but which and where must it be installed. I've done it but no solution I tried is working. I tried with : ``` mongodb-driver-core-5.1.0 mongodb-java-driver-5.1.0 ``` and as alternative: ``` mongodb-driver-sync-5.1.0 ``` placing it into: seatunnel_home\lib plugins\MongoDB\lib connectors\seatunnel documentation link to the right download is failing. ### SeaTunnel Version 2.3.4 ### SeaTunnel Config ```conf #Also into the first attachment: env { parallelism = 2 job.mode=STREAMING job.name=SeaTunnel_Job read_limit.bytes_per_second=7000000 read_limit.rows_per_second=400 } Oracle-CDC { result_table_name = "tab1" base-url = "jdbc:oracle:thin:user/password@ip:1521/service_name" source.reader.close.timeout = 120000 username = "user" password = "password" database-names = ["DBNAME"] # real db name DBNAME.domain.local ( it works with DBNAME ) schema-names = ["SCHEMA"] startup.mode = "INITIAL" table-names = ["DBNAME.SCHEMA.TABLE1"] } } sink { MongoDB { source_table_name = "source" uri = "mongodb://user:pwd@ipaddress:27017/dbname?readPreference=secondary&slaveOk=true" database = "dbname" collection = "destcollection" upsert-enable = true primary-key = ["pkname"] } } ``` ``` ### Running Command ```shell java -Dlog4j2.configurationFile=E:\programmi\apache-seatunnel-2.3.4\config\log4j2_client.properties -Dhazelcast.client.config=E:\programmi\apache-seatunnel-2.3.4\config\hazelcast-client.yaml -Dseatunnel.config=E:\programmi\apache-seatunnel-2.3.4\config\seatunnel.yaml -Dhazelcast.config=E:\programmi\apache-seatunnel-2.3.4\config\hazelcast.yaml -Dseatunnel.logs.file_name=seatunnel-starter-clienttest -Xms256m -Xmx512m -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=E:\programmi\apache-seatunnel-2.3.4\dump\zeta-client -cp E:\programmi\apache-seatunnel-2.3.4\lib\*;E:\programmi\apache-seatunnel-2.3.4\starter\seatunnel-starter.jar org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient --config .\config\v2.batch.config.template -m local ``` ### Error Exception ```log 2024-05-06 13:42:06,610 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2024-05-06 13:42:06,611 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2024-05-06 13:42:06,612 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2024-05-06 13:42:06,614 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:199) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='MongoDB'} not found. at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:231) at org.apache.seatunnel.engine.core.parse.ConnectorInstanceLoader.loadSinkInstance(ConnectorInstanceLoader.java:77) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSink(JobConfigParser.java:194) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSinks(JobConfigParser.java:170) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:531) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:193) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:88) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:161) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:146) ... 2 more ``` ### Zeta or Flink or Spark Version Zeta ### Java or Scala Version JAva ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
