a11dev commented on issue #7058:
URL: https://github.com/apache/seatunnel/issues/7058#issuecomment-2205847226
Hi Jia,
sorry if I'm disturbing you!
I hope you could help me.
from docs sink jars must be put into lib folder in case of zeta engine.
Mine configuration is like this one:
jdbc {
source_table_name = ["fake"]
# if you would use json or jsonb type insert please add jdbc url
stringtype=unspecified option
url = "jdbc:postgresql://localhost:5432/NWFMLOGMON"
driver = "org.postgresql.Driver"
user = user
password = pwd
query = "insert into test_table(name,age) values(?,?)"
}
and lib folder contains the postgres jar file.
Still I have this 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: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='jdbc'} 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
Where exactly should I put the jar?
thanks a lot
Alessandro
Il giorno mar 25 giu 2024 alle ore 12:59 Jia Fan ***@***.***>
ha scritto:
> The config should be:
>
> transform {
> Sql {
> source_table_name = "assignments"
> result_table_name = "mongoassignments"
> query = "select CAST(W6KEY as INT) as w6key,
CAST(IFNULL(TASK,0),INT) as task from w6assignments"
> }
> }
>
> use cast (name as int) not cast(name,int)
>
> —
> Reply to this email directly, view it on GitHub
> <https://github.com/apache/seatunnel/issues/7058#issuecomment-2188628344>,
> or unsubscribe
>
<https://github.com/notifications/unsubscribe-auth/AI2V567U46XSM6HYVDY64J3ZJFERXAVCNFSM6AAAAABJ3LG5OCVHI2DSMVQWIX3LMV43OSLTON2WKQ3PNVWWK3TUHMZDCOBYGYZDQMZUGQ>
> .
> 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]
