for (Map.Entry<String, SourceInfo> entry : _trackedSources.entrySet())
{
SourceInfo srcinfo = entry.getValue();
if (srcinfo.getNumRows() >= _maxRowsInLog)
{
srcinfo.switchLogFile(getConnection());
setLogPosition(srcinfo.getCurrLogId(), 0, _newWindowScn, entry.getKey());
// getConnection().commit();
_bootstrapDao.createNewLogTable(srcinfo.getSrcId());
}
}