Sync between 2 clusters using mongosync throw exception during bulk insert

Hi guys,
I am trying to sync data between two self-managed clusters, it run first but then throw error like below. How can i resolve this one?

{
   "level":"fatal",
   "serverID":"2e9f6305",
   "mongosyncID":"coordinator",
   "stack":[
      {
         "func":"(*Mongosync).runInserterServiceForPartition",
         "line":"311",
         "source":"/data/mci/d774acdbfd0609e0248dfa6c592e1410/src/github.com/10gen/mongosync/internal/mongosync/collection_copy.go"
      },
      {
         "func":"(*Mongosync).runPartitionCopier.func3",
         "line":"186",
         "source":"/data/mci/d774acdbfd0609e0248dfa6c592e1410/src/github.com/10gen/mongosync/internal/mongosync/collection_copy.go"
      },
      {
         "func":"(*MongoErrGroup).NewRoutine.func2",
         "line":"46",
         "source":"/data/mci/d774acdbfd0609e0248dfa6c592e1410/src/github.com/10gen/mongosync/internal/mongosync/util/routines.go"
      },
      {
         "func":"(*Group).Go.func1",
         "line":"75",
         "source":"/data/mci/d774acdbfd0609e0248dfa6c592e1410/src/github.com/10gen/mongosync/vendor/golang.org/x/sync/errgroup/errgroup.go"
      },
      {
         "func":"goexit",
         "line":"1594",
         "source":"/opt/golang/go1.19/src/runtime/asm_amd64.s"
      }
   ],
   "error":"failed to run inserter service for partition &{Key:{SourceUUID:1e324607-e094-47c7-9a38-8df2adac82e5 MongosyncID:coordinator Lower:ObjectID(\"5e575492c95874dddca78616\")} Ns:0xc0005148c0 Phase:not started Upper:ObjectID(\"5e599ba863e32e8eb4165b42\") IsCapped:false} on namespace profiling.profile_by_social: encountered a problem during bulk insertion: retryable function did not succeed after 2 attempt(s) over 604.26 second(s) with a last seen error: connection(mongo:27017[-177]) incomplete read of message header: context deadline exceeded",
   "time":"2023-06-15T03:11:30.130639308Z",
   "message":"Error during replication"
}

Thank guys!