Skip to content

Commit 329fa10

Browse files
authored
Pipe: Removed the useless ban on async file transfer for non realtime-first pipes
1 parent 623532a commit 329fa10

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
@@ -455,7 +455,7 @@ private void transfer(final PipeTransferTsFileHandler pipeTransferTsFileHandler)
455455
},
456456
transferTsFileClientManager.getExecutor());
457457

458-
if (PipeConfig.getInstance().isTransferTsFileSync() || !isRealtimeFirst) {
458+
if (PipeConfig.getInstance().isTransferTsFileSync()) {
459459
try {
460460
completableFuture.get();
461461
} catch (final Exception e) {

0 commit comments

Comments
 (0)