Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Bug][Agent] The connector of SQLServer is closed #7387

Closed
2 tasks done
haifxu opened this issue Feb 17, 2023 · 0 comments · Fixed by #7388
Closed
2 tasks done

[Bug][Agent] The connector of SQLServer is closed #7387

haifxu opened this issue Feb 17, 2023 · 0 comments · Fixed by #7388
Assignees
@haifxu
Labels
type/bug Something is wrong
Milestone
1.6.0

Comments

@haifxu
Copy link
Contributor

haifxu commented Feb 17, 2023 •
edited

What happened

2023-02-17 00:59:43.420 -ERROR  [               task-job_69_1-6] o.a.i.a.c.t.TaskWrapper       :211 error while running wrapper
java.lang.NullPointerException: null value for key job.sqlserverJob.serverName
        at org.apache.inlong.agent.conf.AbstractConfiguration.get(AbstractConfiguration.java:233) ~[agent-common-1.6.0-SNAPSHOT.jar:1.6.0-SNAPSHOT]
        at org.apache.inlong.agent.plugin.sources.reader.SQLServerReader.init(SQLServerReader.java:203) ~[agent-plugins-1.6.0-SNAPSHOT.jar:1.6.0-SNAPSHOT]
        at org.apache.inlong.agent.core.task.Task.init(Task.java:77) ~[agent-core-1.6.0-SNAPSHOT.jar:1.6.0-SNAPSHOT]
        at org.apache.inlong.agent.core.task.TaskWrapper.run(TaskWrapper.java:203) ~[agent-core-1.6.0-SNAPSHOT.jar:1.6.0-SNAPSHOT]
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_322]
        at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_322]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_322]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_322]
        at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_322]

2023-02-16 23:43:09.973 -ERROR  [                 job-job_66-11] o.a.i.a.c.j.JobWrapper        :194 Create task for profile(org.apache.inlong.agent.conf.TriggerProfile@616c0c5b) failed
java.lang.NullPointerException: null
        at java.security.MessageDigest.update(MessageDigest.java:338) ~[?:1.8.0_322]
        at java.security.MessageDigest.digest(MessageDigest.java:413) ~[?:1.8.0_322]
        at org.apache.commons.codec.digest.DigestUtils.md5(DigestUtils.java:468) ~[commons-codec-1.15.jar:1.15]
        at org.apache.commons.codec.digest.DigestUtils.md5(DigestUtils.java:493) ~[commons-codec-1.15.jar:1.15]
        at org.apache.commons.codec.digest.DigestUtils.md5Hex(DigestUtils.java:529) ~[commons-codec-1.15.jar:1.15]
        at org.apache.inlong.agent.core.job.JobWrapper.submit(JobWrapper.java:189) ~[agent-core-1.6.0-SNAPSHOT.jar:1.6.0-SNAPSHOT]
        at org.apache.inlong.agent.core.job.JobWrapper.run(JobWrapper.java:216) ~[agent-core-1.6.0-SNAPSHOT.jar:1.6.0-SNAPSHOT]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_322]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_322]
        at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_322]

2023-02-17 01:20:35.837 -ERROR  [hange-event-source-coordinator] i.d.p.ErrorHandler            :31 Producer failure
io.debezium.DebeziumException: com.microsoft.sqlserver.jdbc.SQLServerException: Invalid object name 'cdc.lsn_time_mapping'.
        at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85) ~[debezium-core-1.8.0.Final.jar:1.8.0.Final]
        at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:153) ~[debezium-core-1.8.0.Final.jar:1.8.0.Final]
        at io.debezium.connector.sqlserver.SqlServerChangeEventSourceCoordinator.executeChangeEventSources(SqlServerChangeEventSourceCoordinator.java:69) ~[debezium-connector-sqlserver-1.8.0.Final.jar:1.8.0.Final]
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108) ~[debezium-core-1.8.0.Final.jar:1.8.0.Final]
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_322]
        at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_322]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_322]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_322]
        at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_322]
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Invalid object name 'cdc.lsn_time_mapping'.
        at com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDatabaseError(SQLServerException.java:262) ~[mssql-jdbc-7.2.2.jre8.jar:?]
        at com.microsoft.sqlserver.jdbc.SQLServerResultSet$FetchBuffer.nextRow(SQLServerResultSet.java:5427) ~[mssql-jdbc-7.2.2.jre8.jar:?]
        at com.microsoft.sqlserver.jdbc.SQLServerResultSet.fetchBufferNext(SQLServerResultSet.java:1758) ~[mssql-jdbc-7.2.2.jre8.jar:?]
        at com.microsoft.sqlserver.jdbc.SQLServerResultSet.next(SQLServerResultSet.java:1016) ~[mssql-jdbc-7.2.2.jre8.jar:?]
        at io.debezium.jdbc.JdbcConnection.lambda$singleResultMapper$7(JdbcConnection.java:1423) ~[debezium-core-1.8.0.Final.jar:1.8.0.Final]
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:645) ~[debezium-core-1.8.0.Final.jar:1.8.0.Final]
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:513) ~[debezium-core-1.8.0.Final.jar:1.8.0.Final]
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:234) ~[debezium-connector-sqlserver-1.8.0.Final.jar:1.8.0.Final]
        at io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource.determineSnapshotOffset(SqlServerSnapshotChangeEventSource.java:168) ~[debezium-connector-sqlserver-1.8.0.Final.jar:1.8.0.Final]
        at io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource.determineSnapshotOffset(SqlServerSnapshotChangeEventSource.java:33) ~[debezium-connector-sqlserver-1.8.0.Final.jar:1.8.0.Final]
        at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:110) ~[debezium-core-1.8.0.Final.jar:1.8.0.Final]
        at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76) ~[debezium-core-1.8.0.Final.jar:1.8.0.Final]
        ... 8 more

What you expected to happen

Fix the agent of the SqlServer connector.

How to reproduce

Use the SqlServer source.

Environment

No response

InLong version

master

InLong Component

InLong Agent

Are you willing to submit PR?

  • Yes, I am willing to submit a PR!

Code of Conduct
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@haifxu haifxu

Labels
type/bug Something is wrong
Projects
None yet
Milestone
1.6.0
Development

Successfully merging a pull request may close this issue.

[INLONG-7387][Agent] Fix error of SqlServer connector haifxu/inlong
2 participants
@dockerzhang @haifxu