Skip to content

Commit 5f0bca8

Browse files
committed
Resolving the comments
Signed-off-by: Sriram Ganesh <[email protected]>
1 parent 8ce86fb commit 5f0bca8

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

server/src/main/java/org/opensearch/index/shard/IndexShard.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1180,8 +1180,7 @@ private Engine.IndexResult applyIndexOperation(
11801180
SourceToParse sourceToParse,
11811181
String id
11821182
) throws IOException {
1183-
// Only use segment replication path if sourceToParse is null
1184-
if (indexSettings.isSegRepEnabledOrRemoteNode() && routingEntry().primary() == false && sourceToParse == null) {
1183+
if (indexSettings.isSegRepEnabledOrRemoteNode() && routingEntry().primary() == false) {
11851184
Engine.Index index = new Engine.Index(
11861185
new Term(IdFieldMapper.NAME, Uid.encodeId(id)),
11871186
null, // ParsedDocument is null for segment replication
@@ -1393,7 +1392,7 @@ public Engine.DeleteResult applyDeleteOperationOnReplica(long seqNo, long opPrim
13931392
version,
13941393
null,
13951394
Engine.Operation.Origin.REPLICA,
1396-
threadPool.absoluteTimeInMillis(),
1395+
System.nanoTime(),
13971396
UNASSIGNED_SEQ_NO,
13981397
0
13991398
);

0 commit comments

Comments
 (0)