-
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-8358][Sort] Add kafka connector on flink 1.15 #8713
Conversation
759516a
to
c06aa51
Compare
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.
Please add a end to end test under sort-end-to-end-tests to test the code thx ~
ok |
@hnrainll please fix the conflicts, thanks. |
OK |
095ca3c
to
a2d54ed
Compare
421cc85
to
29154a6
Compare
Sorry but there should be UT for this feature, any problem with implementing it ? |
No problem, I'm in the process of implementing UT's functionality. |
6b2f47b
to
a106ef8
Compare
...s/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/KafkaE2EITCase.java
Outdated
Show resolved
Hide resolved
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
Prepare a Pull Request
Motivation
Add kafka connector on flink 1.15
Modifications
Add kafka connector on flink 1.15