svn commit: r1878856 - /jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java

[tomekr]

Author: tomekr
Date: Mon Jun 15 12:57:49 2020
New Revision: 1878856

URL: http://svn.apache.org/viewvc?rev=1878856&view=rev
Log:
OAK-9113 - Make the migrateGraph and migrateBinaryRef more resilient to timeouts

- Adding runwithRetry before performing write

Modified:
    
jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java

Modified: 
jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java?rev=1878856&r1=1878855&r2=1878856&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java
 Mon Jun 15 12:57:49 2020
@@ -198,7 +198,7 @@ public class SegmentStoreMigrator implem
         Buffer binaryReferences = future.get();
         if (binaryReferences != null) {
             byte[] array = fetchByteArray(binaryReferences);
-            writer.writeBinaryReferences(array);
+            runWithRetry(() -> {writer.writeBinaryReferences(array); return 
null;}, 16, 5);
         }
     }
 
@@ -213,7 +213,7 @@ public class SegmentStoreMigrator implem
         Buffer graph = future.get();
         if (graph != null) {
             byte[] array = fetchByteArray(graph);
-            writer.writeGraph(array);
+            runWithRetry(() -> {writer.writeGraph(array); return null;}, 16, 
5);
         }
     }