Index: oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/CompactionAndCleanupIT.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/CompactionAndCleanupIT.java	(revision 16d83929468c0fca4c0aaa44efb5e688937af3d3)
+++ oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/CompactionAndCleanupIT.java	(revision )
@@ -322,29 +322,33 @@
 
         final AtomicReference<Boolean> run = new AtomicReference<Boolean>(true);
         final List<Integer> failedCommits = newArrayList();
-        Thread t = new Thread(new Runnable() {
+        Thread[] threads = new Thread[10];
+        for (int k = 0; k < threads.length; k++) {
+            threads[k] = new Thread(new Runnable() {
-            @Override
-            public void run() {
-                for (int k = 0; run.get(); k++) {
-                    try {
-                        NodeBuilder root = nodeStore.getRoot().builder();
-                        root.setChildNode("b" + k);
-                        nodeStore.merge(root, EmptyHook.INSTANCE, CommitInfo.EMPTY);
-                        Thread.sleep(5);
-                    } catch (CommitFailedException e) {
-                        failedCommits.add(k);
-                    } catch (InterruptedException e) {
-                        Thread.interrupted();
-                        break;
-                    }
-                }
-            }
-        });
+                @Override
+                public void run() {
+                    for (int k = 0; run.get(); k++) {
+                        try {
+                            NodeBuilder root = nodeStore.getRoot().builder();
+                            root.setChildNode("b" + k);
+                            nodeStore.merge(root, EmptyHook.INSTANCE, CommitInfo.EMPTY);
+                            Thread.sleep(5);
+                        } catch (CommitFailedException e) {
+                            failedCommits.add(k);
+                        } catch (InterruptedException e) {
+                            Thread.interrupted();
+                            break;
+                        }
+                    }
+                }
+            });
-        t.start();
-
+            threads[k].start();
+        }
         store.compact();
         run.set(false);
+        for (Thread t : threads) {
-        t.join();
+            t.join();
+        }
 
         assertTrue(failedCommits.isEmpty());