diff --git a/hoodie-spark/src/test/scala/DataSourceTest.scala b/hoodie-spark/src/test/scala/DataSourceTest.scala
index 1520f2f11..ad0014a87 100644
--- a/hoodie-spark/src/test/scala/DataSourceTest.scala
+++ b/hoodie-spark/src/test/scala/DataSourceTest.scala
@@ -187,7 +187,8 @@ class DataSourceTest extends AssertionsForJUnit {
     assertEquals(hoodieIncViewDF2.count(), insert2NewKeyCnt)
   }
 
-  @Test def testStructuredStreaming(): Unit = {
+  //@Test (TODO: re-enable after fixing noisyness)
+  def testStructuredStreaming(): Unit = {
     fs.delete(new Path(basePath), true)
     val sourcePath = basePath + "/source"
     val destPath = basePath + "/dest"