-
Notifications
You must be signed in to change notification settings - Fork 1.8k
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][Connectors-v2]Paimon version upgrade to 0.8.2 #8074
base: dev
Are you sure you want to change the base?
Conversation
0a369d4
to
0292734
Compare
0292734
to
853960f
Compare
@@ -636,7 +636,7 @@ public void testChangelogLookup(TestContainer container) throws Exception { | |||
.collect(Collectors.toList()); | |||
log.info("paimon records: {}", actual2); | |||
Assertions.assertEquals(2, actual2.size()); | |||
Assertions.assertEquals(Arrays.asList("[+U, 1, Aa, 200]", "[+I, 2, Bb, 90]"), actual2); | |||
Assertions.assertEquals(Arrays.asList("[+I, 1, Aa, 200]", "[+I, 2, Bb, 90]"), actual2); |
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.
why change this?
@@ -19,7 +19,7 @@ | |||
###### | |||
|
|||
env { | |||
parallelism = 2 | |||
parallelism = 1 |
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.
ditto
@@ -636,7 +636,7 @@ public void testChangelogLookup(TestContainer container) throws Exception { | |||
.collect(Collectors.toList()); | |||
log.info("paimon records: {}", actual2); | |||
Assertions.assertEquals(2, actual2.size()); | |||
Assertions.assertEquals(Arrays.asList("[+U, 1, Aa, 200]", "[+I, 2, Bb, 90]"), actual2); | |||
Assertions.assertEquals(Arrays.asList("[+I, 1, Aa, 200]", "[+I, 2, Bb, 90]"), actual2); |
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.
I think your test case may be not all right. Your test case which paimon to paimon in streaming mode only read the data files. Currently, We have not supported read the changelog file in paimon source reader. We just only support streaming read. If you want to read changelog file, you should use it like this:
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.
stream read is not equivalent to reading the changelog file, I will commmit a Pr for read the changelog file.
Purpose of this pull request
doris has so far supported the Piamon .
doris-paimon
, Paimon version upgrade to 0.8.2 .Does this PR introduce any user-facing change?
How was this patch tested?
Check list
New License Guide
release-note
.