X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FShardTransaction.java;h=613b3749e086abc8cdea38fd322872f656235a91;hb=f97618f25dfc073d1de5d883f1794eefdb3e5c16;hp=1e2386ae1bb8ea4ae6075266bbf12f56600c0516;hpb=fddfe9fc95e2d0807ea943d5c1c6af6a970ef34c;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java index 1e2386ae1b..613b3749e0 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java @@ -129,12 +129,12 @@ public abstract class ShardTransaction extends AbstractUntypedActorWithMetering try { final CheckedFuture>, ReadFailedException> future = transaction.read(path); Optional> optional = future.checkedGet(); - ReadDataReply readDataReply = new ReadDataReply(optional.orNull()); + ReadDataReply readDataReply = new ReadDataReply(optional.orNull(), clientTxVersion); - sender().tell((returnSerialized ? readDataReply.toSerializable(clientTxVersion): readDataReply), self()); + sender().tell((returnSerialized ? readDataReply.toSerializable(): readDataReply), self()); } catch (Exception e) { - LOG.error(String.format("Unexpected error reading path %s", path), e); + LOG.debug(String.format("Unexpected error reading path %s", path), e); shardStats.incrementFailedReadTransactionsCount(); sender().tell(new akka.actor.Status.Failure(e), self()); }