File tree Expand file tree Collapse file tree
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2424import org .apache .iotdb .commons .concurrent .IoTThreadFactory ;
2525import org .apache .iotdb .commons .concurrent .ThreadName ;
2626import org .apache .iotdb .commons .concurrent .threadpool .WrappedThreadPoolExecutor ;
27+ import org .apache .iotdb .commons .conf .CommonDescriptor ;
2728import org .apache .iotdb .commons .consensus .DataRegionId ;
2829import org .apache .iotdb .commons .consensus .SchemaRegionId ;
2930import org .apache .iotdb .commons .consensus .index .ProgressIndex ;
@@ -376,7 +377,8 @@ public void stopAllPipesWithCriticalExceptionAndTrackException(
376377 ///////////////////////// Heartbeat /////////////////////////
377378
378379 public void collectPipeMetaList (final TDataNodeHeartbeatResp resp ) throws TException {
379- if (!tryReadLockWithTimeOut (2 )) {
380+ if (!tryReadLockWithTimeOutInMs (
381+ CommonDescriptor .getInstance ().getConfig ().getDnConnectionTimeoutInMS () * 2L / 3 )) {
380382 return ;
381383 }
382384 try {
You can’t perform that action at this time.
0 commit comments