SAMZA-1182 - Commenting out some of the flaky tests

Author: navina <navina@apache.org> Reviewers: Prateek Maheshwari <pmaheshwari@linkedin.com>, Jagadish Venkataraman <vjagadish1989@gmail.com> Closes apache#107 from navina/SAMZA-1182
becketqin · Mar 31, 2017 · 944c708 · 944c708
1 parent 9db47b8
commit 944c708
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/samza-core/src/test/java/org/apache/samza/task/TestAsyncRunLoop.java b/samza-core/src/test/java/org/apache/samza/task/TestAsyncRunLoop.java
@@ -237,7 +237,8 @@ public void testProcessMultipleTasks() throws Exception {
     assertEquals(2L, containerMetrics.processes().getCount());
   }
 
-  @Test
+  // TODO: Fix in SAMZA-1183
+  //@Test
   public void testProcessInOrder() throws Exception {
     AsyncRunLoop runLoop = createRunLoop();
     when(consumerMultiplexer.choose(false)).thenReturn(envelope0).thenReturn(envelope3).thenReturn(envelope1).thenReturn(null);
@@ -519,7 +520,8 @@ public void testEndOfStreamOffsetManagement() throws Exception {
     callbackExecutor.awaitTermination(100, TimeUnit.MILLISECONDS);
   }
 
-  @Test
+  // TODO: Fix in SAMZA-1183
+  // @Test
   public void testCommitBehaviourWhenAsyncCommitIsEnabled() throws InterruptedException {
     commitRequest = TaskCoordinator.RequestScope.CURRENT_TASK;
     maxMessagesInFlight = 2;

diff --git a/samza-rest/src/test/java/org/apache/samza/monitor/TestLocalStoreMonitor.java b/samza-rest/src/test/java/org/apache/samza/monitor/TestLocalStoreMonitor.java
@@ -83,7 +83,8 @@ public void cleanUp() throws Exception {
     FileUtils.deleteDirectory(taskStoreDir);
   }
 
-  @Test
+  // TODO: Fix in SAMZA-1183
+  //@Test
   public void shouldDeleteLocalTaskStoreWhenItHasNoOffsetFile() throws Exception {
     localStoreMonitor.monitor();
     assertTrue("Task store directory should not exist.", !taskStoreDir.exists());
@@ -132,7 +133,8 @@ public void shouldDoNothingWhenTheJobIsRunning() throws Exception {
     assertEquals(0, localStoreMonitorMetrics.diskSpaceFreedInBytes.getCount());
   }
 
-  @Test
+  // TODO: Fix in SAMZA-1183
+  //@Test
   public void shouldDeleteTaskStoreWhenTaskPreferredStoreIsNotLocalHost() throws Exception {
     Task task = new Task("notLocalHost", "test-task", 0,
                          new ArrayList<>(), ImmutableList.of("test-store"));