a11dev commented on issue #6800:
URL: https://github.com/apache/seatunnel/issues/6800#issuecomment-2102154575
Again:
2024-05-09 08:16:48,437 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:202)
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:234)
at
org.apache.seatunnel.engine.core.parse.ConnectorInstanceLoader.loadSinkInstance(ConnectorInstanceLoader.java:77)
at
org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSink(JobConfigParser.java:159)
at
org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSinks(JobConfigParser.java:135)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:517)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:200)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:88)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:156)
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:149)
... 2 more
The point is, which jar is missing and where must be distributed.
since I'm using Zeta engine I should locate it into the seatunnel .\lib.
I added there the mongodb-driver-sync-5.1.0.jar.
Mongo db sink:
MongoDB {
source_table_name = "assignments"
uri = ***@***.***
:27017/dbname?readPreference=secondary&slaveOk=true"
database = "dbname"
collection = "assignments"
upsert-enable = true
primary-key = ["w6key"]
}
thanks
Alessandro
Il giorno gio 9 mag 2024 alle ore 05:44 Jia Fan ***@***.***>
ha scritto:
> Could you try with 2.3.5? It should be fixed by #6551
> <https://github.com/apache/seatunnel/pull/6551>
>
> —
> Reply to this email directly, view it on GitHub
> <https://github.com/apache/seatunnel/issues/6800#issuecomment-2101877591>,
> or unsubscribe
>
<https://github.com/notifications/unsubscribe-auth/AI2V56Z6AEJEY23ZCJHATVDZBLWJHAVCNFSM6AAAAABHI7W73CVHI2DSMVQWIX3LMV43OSLTON2WKQ3PNVWWK3TUHMZDCMBRHA3TONJZGE>
> .
> You are receiving this because you authored the thread.Message ID:
> ***@***.***>
>
--
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]
