-
Notifications
You must be signed in to change notification settings - Fork 1.7k
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
[Feature][Connector] add IT for Assert Sink in e2e module #2036
Conversation
PTAL @ruanwenjun Thx! |
@lhyundeadsoul Is there any count rule? e.g. I want to assert the batch row count is 4. |
|
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.
+1
The IT failed. |
seatunnel-e2e/seatunnel-flink-e2e/src/test/resources/assertion/fakesource_to_assert.conf
Outdated
Show resolved
Hide resolved
amend assert config to fit FakeSource config
Could you please make the ci pass. |
Both console and assert e2e IT failed.
|
In your local? |
Maybe it's in my local. I find the root cause : There is no
Have you ever had this? |
Yes, also confusion me😭 |
Wow~ I am not the only one~ |
I doubt it is caused by |
Maybe. Sometimes it work, sometimes it fail. Occur randomly. |
if you package success local, everything will be fine. |
So this error have any progress? |
a new error occur after package successfully.
I working on it |
...nnector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/sink/AssertSink.java
Outdated
Show resolved
Hide resolved
...nnector-flink-assert/src/main/java/org/apache/seatunnel/flink/assertion/sink/AssertSink.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
@Hisoka-X PTAL |
Purpose of this pull request
add IT to test Assert Sink plugin
#2034
Check list
New License Guide