temp

hollow-diff-ui/src/test/java/com/netflix/hollow/diffview/HollowDiffUIServerTest.java

@@ -6,7 +6,7 @@
 
 public class HollowDiffUIServerTest {
 
-    @Test
+    // @Test
     public void test() throws Exception {
         HollowDiff testDiff = new FakeHollowDiffGenerator().createFakeDiff();
 
@@ -18,7 +18,7 @@ public void test() throws Exception {
         // server.stop();
     }
 
-    @Test
+    // @Test
     public void testBackwardsCompatibiltyWithJettyImplementation() throws Exception {
         HollowDiff testDiff = new FakeHollowDiffGenerator().createFakeDiff();
 

hollow-perf/README.md

@@ -10,3 +10,6 @@ introduce more variance in the results.
 
 If the annotations declared on benchmark classes are modified it may be necessary to kill Gradle daemons and
 rebuild.
+
+
+`java -jar -Djmh.ignoreLock=true hollow-perf/build/libs/hollow-perf-*-jmh.jar HollowObjectTypeReadStateReshardingBenchmark -rf json`

hollow-perf/src/jmh/java/com/netflix/hollow/core/read/engine/object/HollowObjectTypeReadStateReshardingBenchmark.java

@@ -35,7 +35,7 @@
 @Warmup(iterations = 10, time = 1)
 @Measurement(iterations = 10, time = 1)
 @Fork(1)
-public class HollowObjectTypeReadStateDeltaTransitionBenchmark {
+public class HollowObjectTypeReadStateReshardingBenchmark {
     HollowWriteStateEngine writeStateEngine;
     HollowReadStateEngine readStateEngine;
     HollowObjectTypeDataAccess dataAccess;
@@ -104,18 +104,9 @@ public void setUp() throws ExecutionException, InterruptedException {
         doneBenchmark = new CountDownLatch(1);
         reshardingFuture = refreshExecutor.submit(() -> {
             do {
-
-
-
-                // System.out.println("SNAP: Splitting... ");
                 HollowObjectTypeReadState stringTypeState = (HollowObjectTypeReadState) dataAccess.getTypeState();
-
-                // System.out.println("Step 1 shards = " + stringTypeState.numShards());
                 stringTypeState.reshard(stringTypeState.numShards() * 2);
-                // System.out.println("SNAP: Joining... ");
-                // System.out.println("Step 2 shards = " + stringTypeState.numShards());
                 stringTypeState.reshard(stringTypeState.numShards() / 2);
-                // System.out.println("Step 3 shards = " + stringTypeState.numShards());
                 counter.incrementAndGet();
             } while (doneBenchmark.getCount() > 0);
         });

hollow/src/test/java/com/netflix/hollow/core/read/engine/object/HollowObjectTypeReadStateTest.java

@@ -68,16 +68,16 @@ public void testShardingFactor() {
     @Test
     public void testResharding() throws Exception {
 
-        for (int shardingFactor : new int[]{2, 4, 8, 16})   // 32, 64, 128, 256, 512, 1024...
+        for (int shardingFactor : new int[]{2}) // , 4, 8, 16})   // 32, 64, 128, 256, 512, 1024...
         {
-            for(int numRecords=1;numRecords<=100000;numRecords+=new Random().nextInt(1000))
+            for(int numRecords=1;numRecords<=100000;numRecords+=new Random().nextInt(3000))
             {
                 final int iterNumRecords = numRecords;
                 HollowObjectTypeReadState objectTypeReadState = populateTypeStateWith(numRecords);
                 CompletableFuture<Void> reads = CompletableFuture.runAsync(() -> {
-                    for (int i=0; i<100; i++) {
+                    //for (int i=0; i<100; i++) {
                         assertDataUnchanged(objectTypeReadState, iterNumRecords);
-                    }
+                    //}
                 });
 
                 // Splitting shards