Synchronization task mysql2mysql shows' Plugin Plugin Identifier {engineType='seatunnel ', pluginType='source', pluginName='Jdbc '} not found' #9203
Replies: 1 comment
-
Please use version >= You should install SeaTunnel step by step as follows. In this case, you only need to download the related connector plugins and place them in the ${SEATUNNEL_HOME}/connectors/ directory or execute |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
source: mysql
target : mysql
engine: spark3
seatunnel: 2.3.2
concepts:
`env {
execution.parallelism = 2
job.mode = "BATCH"
}
source{
Jdbc {
url = "jdbc:mysql://localhost/test_0418?useUnicode=true&characterEncoding=UTF-8"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
user = "root"
password = "111111"
query = "select * from test_0418.aa limit 16"
}
}
sink {
jdbc {
url = "jdbc:mysql://localhost/test_0418?useUnicode=true&characterEncoding=UTF-8"
driver = "com.mysql.cj.jdbc.Driver"
user = "root"
password = "111111"
# Automatically generate sql statements based on database table names
generate_sink_sql = true
database = test_0418
table = aa
}
}`
connectors

error msg:

25/04/19 17:07:16 INFO YarnClientSchedulerBackend: SchedulerBackend is ready for scheduling beginning after reached minRegisteredResourcesRatio: 0.8
25/04/19 17:07:16 INFO BlockManagerMasterEndpoint: Registering block manager wj-test-002:45859 with 366.3 MiB RAM, BlockManagerId(2, wj-test-002, 45859, None)
25/04/19 17:07:16 INFO BlockManagerMasterEndpoint: Registering block manager wj-test-003:46833 with 366.3 MiB RAM, BlockManagerId(1, wj-test-003, 46833, None)
25/04/19 17:07:16 INFO AbstractPluginDiscovery: Load SeaTunnelSource Plugin from /opt/tmp/seatunnel-2.3.3/connectors/seatunnel
25/04/19 17:07:16 INFO AbstractPluginDiscovery: Discovery plugin jar: Jdbc at: file:/opt/tmp/seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.2-sources.jar
25/04/19 17:07:16 ERROR SparkTaskExecuteCommand: Run SeaTunnel on spark failed.
java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} not found.
at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:223)
at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:178)
at org.apache.seatunnel.core.starter.spark.execution.SourceExecuteProcessor.initializePlugins(SourceExecuteProcessor.java:103)
at org.apache.seatunnel.core.starter.spark.execution.SparkAbstractPluginExecuteProcessor.(SparkAbstractPluginExecuteProcessor.java:49)
at org.apache.seatunnel.core.starter.spark.execution.SourceExecuteProcessor.(SourceExecuteProcessor.java:51)
at org.apache.seatunnel.core.starter.spark.execution.SparkExecution.(SparkExecution.java:57)
at org.apache.seatunnel.core.starter.spark.command.SparkTaskExecuteCommand.execute(SparkTaskExecuteCommand.java:59)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at org.apache.seatunnel.core.starter.spark.SeaTunnelSpark.main(SeaTunnelSpark.java:35)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52)
at org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:958)
at org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:180)
at org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:203)
at org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:90)
at org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1046)
at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1055)
at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)
25/04/19 17:07:16 ERROR SeaTunnel:
Beta Was this translation helpful? Give feedback.
All reactions