diff --git a/config/alfresco/authentication-services-context.xml b/config/alfresco/authentication-services-context.xml
index b9fc315b62..18953cd5f0 100644
--- a/config/alfresco/authentication-services-context.xml
+++ b/config/alfresco/authentication-services-context.xml
@@ -89,7 +89,10 @@
        </property>
        <property name="searchService">
            <ref bean="admSearchService" />
-       </property>
+       </property>       
+      <property name="retryingTransactionHelper">
+          <ref bean="retryingTransactionHelper"/>
+      </property>
        <property name="userNamesAreCaseSensitive">
           <value>${user.name.caseSensitive}</value>
        </property>
diff --git a/source/java/org/alfresco/repo/domain/hibernate/Transaction.hbm.xml b/source/java/org/alfresco/repo/domain/hibernate/Transaction.hbm.xml
index 9cd5c2a291..2786c018d5 100644
--- a/source/java/org/alfresco/repo/domain/hibernate/Transaction.hbm.xml
+++ b/source/java/org/alfresco/repo/domain/hibernate/Transaction.hbm.xml
@@ -65,6 +65,17 @@
          server.ipAddress = :ipAddress
    </query>
 
+   <query name="txn.GetTxnById">
+      select
+         txn
+      from
+         org.alfresco.repo.domain.hibernate.TransactionImpl as txn
+      where
+         txn.id = :txnId
+      order by
+         txn.commitTimeMs
+   </query>
+
    <query name="txn.GetTxnsByCommitTimeAsc">
       <![CDATA[
       select
diff --git a/source/java/org/alfresco/repo/node/db/hibernate/HibernateNodeDaoServiceImpl.java b/source/java/org/alfresco/repo/node/db/hibernate/HibernateNodeDaoServiceImpl.java
index 6529f13f4e..7fea90d079 100644
--- a/source/java/org/alfresco/repo/node/db/hibernate/HibernateNodeDaoServiceImpl.java
+++ b/source/java/org/alfresco/repo/node/db/hibernate/HibernateNodeDaoServiceImpl.java
@@ -1515,6 +1515,7 @@ public class HibernateNodeDaoServiceImpl extends HibernateDaoSupport implements
     /*
      * Queries for transactions
      */
+    private static final String QUERY_GET_TXN_BY_ID = "txn.GetTxnById";
     private static final String QUERY_GET_TXNS_BY_COMMIT_TIME_ASC = "txn.GetTxnsByCommitTimeAsc";
     private static final String QUERY_GET_TXNS_BY_COMMIT_TIME_DESC = "txn.GetTxnsByCommitTimeDesc";
     private static final String QUERY_GET_TXN_UPDATE_COUNT_FOR_STORE = "txn.GetTxnUpdateCountForStore";
@@ -1523,9 +1524,21 @@ public class HibernateNodeDaoServiceImpl extends HibernateDaoSupport implements
     private static final String QUERY_GET_TXN_CHANGES_FOR_STORE = "txn.GetTxnChangesForStore";
     private static final String QUERY_GET_TXN_CHANGES = "txn.GetTxnChanges";
     
-    public Transaction getTxnById(long txnId)
+    public Transaction getTxnById(final long txnId)
     {
-        return (Transaction) getSession().get(TransactionImpl.class, new Long(txnId));
+        HibernateCallback callback = new HibernateCallback()
+        {
+            public Object doInHibernate(Session session)
+            {
+                Query query = session.getNamedQuery(QUERY_GET_TXN_BY_ID);
+                query.setLong("txnId", txnId)
+                     .setReadOnly(true);
+                return query.uniqueResult();
+            }
+        };
+        Transaction txn = (Transaction) getHibernateTemplate().execute(callback);
+        // done
+        return txn;
     }
     
     @SuppressWarnings("unchecked")
diff --git a/source/java/org/alfresco/repo/node/index/IndexTransactionTracker.java b/source/java/org/alfresco/repo/node/index/IndexTransactionTracker.java
index 02c426eb4e..80aea03e93 100644
--- a/source/java/org/alfresco/repo/node/index/IndexTransactionTracker.java
+++ b/source/java/org/alfresco/repo/node/index/IndexTransactionTracker.java
@@ -257,6 +257,18 @@ found:
                 }
                 continue;
             }
+            else if (voidTxn.getCommitTimeMs() == null)
+            {
+                // http://issues.alfresco.com/browse/AR-2041
+                // An object was found, but sometimes it is still not fully formed.
+                // Perhaps it's the direct request by ID that gives back an uncommitted transaction.
+                // So this transaction is very likely to become live soon but we just leave it until it does.
+                // When the issue has been seen, there have not been any committed transactions with null commit times.
+                if (logger.isDebugEnabled())
+                {
+                    logger.debug("Void is visible but not live: " + voidTxn);
+                }
+            }
             else
             {
                 if (logger.isDebugEnabled())
diff --git a/source/java/org/alfresco/repo/security/authentication/RepositoryAuthenticationDao.java b/source/java/org/alfresco/repo/security/authentication/RepositoryAuthenticationDao.java
index 2a8b828a39..e79bb51187 100644
--- a/source/java/org/alfresco/repo/security/authentication/RepositoryAuthenticationDao.java
+++ b/source/java/org/alfresco/repo/security/authentication/RepositoryAuthenticationDao.java
@@ -40,8 +40,10 @@ import net.sf.acegisecurity.providers.encoding.PasswordEncoder;
 import org.alfresco.error.AlfrescoRuntimeException;
 import org.alfresco.model.ContentModel;
 import org.alfresco.repo.tenant.TenantService;
+import org.alfresco.repo.transaction.RetryingTransactionHelper;
 import org.alfresco.service.cmr.dictionary.DictionaryService;
 import org.alfresco.service.cmr.repository.ChildAssociationRef;
+import org.alfresco.service.cmr.repository.InvalidNodeRefException;
 import org.alfresco.service.cmr.repository.NodeRef;
 import org.alfresco.service.cmr.repository.NodeService;
 import org.alfresco.service.cmr.repository.StoreRef;
@@ -68,6 +70,8 @@ public class RepositoryAuthenticationDao implements MutableAuthenticationDao
     private DictionaryService dictionaryService;
 
     private SearchService searchService;
+    
+    private RetryingTransactionHelper retryingTransactionHelper;
 
     private PasswordEncoder passwordEncoder;
 
@@ -97,6 +101,11 @@ public class RepositoryAuthenticationDao implements MutableAuthenticationDao
     {
         this.nodeService = nodeService;
     }
+    
+    public void setRetryingTransactionHelper(RetryingTransactionHelper retryingTransactionHelper)
+    {
+        this.retryingTransactionHelper = retryingTransactionHelper;
+    }
 
     public void setTenantService(TenantService tenantService)
     {
@@ -175,7 +184,7 @@ public class RepositoryAuthenticationDao implements MutableAuthenticationDao
             for (ResultSetRow row : rs)
             {
 
-                NodeRef nodeRef = row.getNodeRef();
+                final NodeRef nodeRef = row.getNodeRef();
                 if (nodeService.exists(nodeRef))
                 {
                     String realUserName = DefaultTypeConverter.INSTANCE.convert(String.class, nodeService.getProperty(
@@ -191,7 +200,26 @@ public class RepositoryAuthenticationDao implements MutableAuthenticationDao
                             }
                             else
                             {
-                                throw new AlfrescoRuntimeException("Found more than one user for "+searchUserName+ " (case sensitive)");
+                                try
+                                {
+                                    this.retryingTransactionHelper.doInTransaction(
+                                        new RetryingTransactionHelper.RetryingTransactionCallback<Object>()
+                                        {
+                                            public Object execute()
+                                                    throws Throwable
+                                            {
+                                                // Delete the extra user node references
+                                                RepositoryAuthenticationDao.this.nodeService.deleteNode(nodeRef);
+                                                
+                                                return null;
+                                            }
+                                            
+                                        }, false, true);
+                                }
+                                catch (InvalidNodeRefException exception)
+                                {
+                                    // Ignore this exception as the node has already been deleted
+                                }
                             }
                         }
                     }
@@ -205,7 +233,26 @@ public class RepositoryAuthenticationDao implements MutableAuthenticationDao
                             }
                             else
                             {
-                                throw new AlfrescoRuntimeException("Found more than one user for "+searchUserName+ " (case insensitive)");
+                                try
+                                {
+                                    this.retryingTransactionHelper.doInTransaction(
+                                        new RetryingTransactionHelper.RetryingTransactionCallback<Object>()
+                                        {
+                                            public Object execute()
+                                                    throws Throwable
+                                            {
+                                                // Delete the extra user node references
+                                                RepositoryAuthenticationDao.this.nodeService.deleteNode(nodeRef);
+                                                
+                                                return null;
+                                            }
+                                            
+                                        }, false, true);
+                                }
+                                catch (InvalidNodeRefException exception)
+                                {
+                                    // Ignore this exception as the node has already been deleted
+                                }
                             }
                         }
                     }