[HOPSWORKS-1058] [ePipe] wrong event ordering during recovery (#14)

logicalclocks · Apr 26, 2019 · c424f2b · c424f2b
1 parent 12766fb
commit c424f2b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/FsMutationsTableTailer.cpp b/src/FsMutationsTableTailer.cpp
@@ -97,7 +97,7 @@ void FsMutationsTableTailer::pushToQueue(FSpq* curr) {
 
 void FsMutationsTableTailer::pushToQueue(FSv* curr) {
   std::sort(curr->begin(), curr->end(), FsMutationRowComparator());
-  for (FSv::iterator it = curr->begin(); it != curr->end(); ++it) {
+  for (FSv::reverse_iterator it = curr->rbegin(); it != curr->rend(); ++it) {
     mQueue->push(*it);
   }
   delete curr;

diff --git a/src/ProvenanceTableTailer.cpp b/src/ProvenanceTableTailer.cpp
@@ -73,7 +73,7 @@ void ProvenanceTableTailer::pushToQueue(PRpq *curr) {
 
 void ProvenanceTableTailer::pushToQueue(Pv* curr) {
   std::sort(curr->begin(), curr->end(), ProvenanceRowComparator());
-  for (Pv::iterator it = curr->begin(); it != curr->end(); ++it) {
+  for (Pv::reverse_iterator it = curr->rbegin(); it != curr->rend(); ++it) {
     mQueue->push(*it);
   }
   delete curr;