Skip to content

Commit 5d4277a

Browse files
authored
Pipe: Removed the useless ban on async file transfer for non realtime-first pipes (#17785)
1 parent ca52520 commit 5d4277a

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -431,7 +431,7 @@ private void transfer(final PipeTransferTsFileHandler pipeTransferTsFileHandler)
431431
},
432432
transferTsFileClientManager.getExecutor());
433433

434-
if (PipeConfig.getInstance().isTransferTsFileSync() || !isRealtimeFirst) {
434+
if (PipeConfig.getInstance().isTransferTsFileSync()) {
435435
try {
436436
completableFuture.get();
437437
} catch (final Exception e) {

0 commit comments

Comments
 (0)