-
Notifications
You must be signed in to change notification settings - Fork 1.9k
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
[Imporve][Connector-V2] Imporve iceberg source connector #2865
Conversation
7c46b58
to
e0ffe4e
Compare
@ashulin PTAL |
e0ffe4e
to
d38ddb7
Compare
...he/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergBatchSplitEnumerator.java
Show resolved
Hide resolved
83ff631
to
190f12e
Compare
...e/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergStreamSplitEnumerator.java
Outdated
Show resolved
Hide resolved
190f12e
to
fbdee90
Compare
fbdee90
to
66d61ea
Compare
0e1c5bd
to
ec38fd0
Compare
ec38fd0
to
95a0bfa
Compare
95a0bfa
to
ce4c5dd
Compare
901cb4d
to
3b219cf
Compare
47a5814
to
cce8cbb
Compare
@@ -124,6 +126,7 @@ public void testIcebergSource(TestContainer container) throws IOException, Inter | |||
} | |||
|
|||
private void initializeIcebergTable() { | |||
FileUtil.fullyDelete(new File(CATALOG_DIR)); |
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.
Would this be a problem if it wasn't completely deleted?
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.
Test cases can interfere with each other
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.
Generally LGTM
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 resolve the conflict
cce8cbb
to
06071cd
Compare
* Lock output row and update offset in pollNext method to support at-least-once * Add `synchronized` to IcebergStreamSplitEnumerator#run method to avoid update conflicts with readers access `handleSplitRequest` * Fix duplicate read splits when batch job state restore * Fix assign split owner(negative number)
06071cd
to
9ac1b64
Compare
Purpose of this pull request
synchronized
to IcebergStreamSplitEnumerator#run method to avoid update conflicts with readers accesshandleSplitRequest
Check list
New License Guide