kyehe commented on code in PR #3734:
URL:
https://github.com/apache/incubator-seatunnel/pull/3734#discussion_r1056925481
##########
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java:
##########
@@ -107,6 +108,10 @@ public void write(SeaTunnelRow seaTunnelRow) throws
FileConnectorException {
if (currentBatchSize >= batchSize) {
this.partId++;
currentBatchSize = 0;
+ if (beingWrittenFile.size() == 1) {
Review Comment:
Code is updated now.
- HashMap was changed to HashSet.
- the `size == 1` logic is to avoid any confluence may made by my code.
`writtenFileStatusSet` need add the finished file name before the
`beingWrittenFile` clear in `AbstractWriteStrategy` class, the file close logic
actually was wrote into `OrcWriteStrategy`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
