-
Notifications
You must be signed in to change notification settings - Fork 530
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.
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
[INLONG-10289][Agent] Update the SQLServer Source #10735
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Hello @zoy0, thank you for submitting a PR to InLong 💖 We will respond as soon as possible ⏳
This seems to be your first PR 🌠 Please be sure to follow our Contribution Guidelines.
If you have any questions in the meantime, you can also ask us on the InLong Discussions 🔍
Run 'mvn spotless:apply' to fix these violations. |
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/SQLServerTask.java
Outdated
Show resolved
Hide resolved
...gent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/SQLServerSource.java
Show resolved
Hide resolved
done |
@zoy0 please click |
please rebase the master to resolve conflicting files |
done |
@haifxu @justinwwhuang PTAL, thanks. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Fixes #10289
Motivation
Update the SQLServer Source for agent
Modifications
Start a Debezium thread to collect change data from SQLServer and convert time fields to string. Then put sourceData into a queue. The agent will regularly read data from this queue and send it to DataProxy.
Verifying this change