bitifi2019 opened a new issue, #9397:
URL: https://github.com/apache/seatunnel/issues/9397
seatunnel: 2.3.8
OS: openEuler 20.03 (LTS-SP3)
SQLServer: 2012
DBName: 2025_AI
同步任务conf如下：
env {
job.mode = "BATCH"
parallelism = 2
checkpoint.interval = 10000
checkpoint.timeout = 720000
}
source {
Jdbc {
driver = com.microsoft.sqlserver.jdbc.SQLServerDriver
url =
"jdbc:sqlserver://*:*;encrypt=false;trustServerCertificate=true"
user = ***
password = "******"
fetch_size = 1000
split.size = 10000
"table_path"="2025_AI.dbo.books"
}
}
sink {
Doris {
fenodes = "*:8030"
query-port = 9030
username = ********
password = "*********"
parallelism = 2
schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST"
data_save_mode = "APPEND_DATA"
database = "testdb"
table = "books"
sink.enable-2pc = "true"
sink.enable-delete = "false"
sink.label-prefix = "mss_books"
doris.config = {
format="json"
read_json_by_line="true"
}
}
}
报错内容如下：
2025-06-05 13:13:53,518 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
===============================================================================
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:213)
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: org.apache.seatunnel.api.table.factory.FactoryException:
ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to
create a source for identifier 'Jdbc'
. at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:101)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:375)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:209)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182)
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:160)
... 2 more
Caused by: org.apache.seatunnel.common.utils.SeaTunnelException: Failed to
querySQLResult
at
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.tableExists(AbstractJdbcCatalog.java:391)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getTable(AbstractJdbcCatalog.java:166)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.utils.JdbcCatalogUtils.getCatalogTable(JdbcCatalogUtils.java:200)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.utils.JdbcCatalogUtils.getTables(JdbcCatalogUtils.java:84)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.<init>(JdbcSource.java:57)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceFactory.lambda$createSource$0(JdbcSourceFactory.java:80)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:113)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:74)
... 7 more
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Incorrect syntax
near '2025'.
at
com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDatabaseError(SQLServerException.java:270)
at
com.microsoft.sqlserver.jdbc.SQLServerStatement.getNextResult(SQLServerStatement.java:1778)
at
com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement.doExecutePreparedStatement(SQLServerPreparedStatement.java:703)
at
com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement$PrepStmtExecCmd.doExecute(SQLServerPreparedStatement.java:622)
at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7775)
at
com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:4408)
at
com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:293)
at
com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:263)
at
com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement.executeQuery(SQLServerPreparedStatement.java:537)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.querySQLResultExists(AbstractJdbcCatalog.java:610)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.tableExists(AbstractJdbcCatalog.java:374)
... 14 more
--
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]
