Details
-
Bug
-
Resolution: Won't Do
-
Major
-
None
-
2.2.1.Final
-
None
-
False
-
None
-
False
Description
As mentioned in the chat room conversation
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:72)
at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.executeIteration(SqlServerStreamingChangeEventSource.java:334)
at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.executeIteration(SqlServerStreamingChangeEventSource.java:60)
at io.debezium.connector.sqlserver.SqlServerChangeEventSourceCoordinator.executeChangeEventSources(SqlServerChangeEventSourceCoordinator.java:105)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.lang.IllegalStateException: SQL Server Agent running status query must return exactly one value
at io.debezium.jdbc.JdbcConnection.lambda$singleResultMapper$8(JdbcConnection.java:1466)
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:627)
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:495)
at io.debezium.connector.sqlserver.SqlServerConnection.isAgentRunning(SqlServerConnection.java:622)
at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.executeIteration(SqlServerStreamingChangeEventSource.java:163)
... 8 more
Can the localization of multiple languages be supported when executing the following query? This problem does not exist in debezium1.x version, but this problem occurs in debezium2.x version
SELECT CASE WHEN dss.[status]=4 THEN 1 ELSE 0 END AS isRunning
FROM sys.dm_server_services dss WHERE dss.[servicename] LIKE N'SQL Server 代理 (%'
or dss.[servicename] LIKE N'SQL Server Agent (%';