im getting below error in seatunnel version 2.3.1
Caused by:
org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException:
java.lang.RuntimeException: One ormore fetchers have encountered exception
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcherManager.checkErrors(SpitFetcherManager.java:147)
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.getNextFetch(SourceReaderase.java:159)
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.pollNext(SourceReaderBasejava:92)
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.pollNext(IncrementalSourceeader.java:92)config
file
========
env {
job.mode = "STREAMING"
}
source {
MySQL-CDC {
result_table_name="mysql-cdc"
parallelism = 1
server-id = 5656
username = "xxxxxxx"
password = "xxxxxxxx"
database-names = ["TEST"]
table-names = ["TEST.SOURCE_USER"]
base-url = "jdbc:mysql://xx.xx.xx.xx:3306/TEST"
}
}
transform
{}
sink{
Console
{
source_table_name="mysql-cdc"
}
jdbc {
source_table_name="mysql-cdc"
url = "jdbc:mysql://xx.xx.xx.xx:3306/test"
driver = "com.mysql.cj.jdbc.Driver"
user = "xxxxxx"
password = "xxxxxxx"
database = "test"
primary_keys = ["ID"]
table = SINK_USER}}
<<<<
Can you show more logs? Some key message is lost.
<<<<
the issue is fixed when i added parallelism=2 in env .thanks
<<<<
That’s great, but I still hope you can send us a detailed log, which can
help us identify potential bugs. In theory, there should be no errors
--
Best Regards
------------
EricJoy2048
[email protected]
