diff --git a/airbyte-cdk/java/airbyte-cdk/db-sources/src/testFixtures/java/io/airbyte/cdk/integrations/standardtest/source/AbstractSourceDatabaseTypeTest.java b/airbyte-cdk/java/airbyte-cdk/db-sources/src/testFixtures/java/io/airbyte/cdk/integrations/standardtest/source/AbstractSourceDatabaseTypeTest.java
index c8a2742086629..fb0ca6ffcc506 100644
--- a/airbyte-cdk/java/airbyte-cdk/db-sources/src/testFixtures/java/io/airbyte/cdk/integrations/standardtest/source/AbstractSourceDatabaseTypeTest.java
+++ b/airbyte-cdk/java/airbyte-cdk/db-sources/src/testFixtures/java/io/airbyte/cdk/integrations/standardtest/source/AbstractSourceDatabaseTypeTest.java
@@ -185,12 +185,6 @@ public UnexpectedRecord(String streamName, String unexpectedValue) {
       }
     }
 
-    assertTrue(unexpectedValues.isEmpty(),
-        unexpectedValues.stream().map((entry) -> // stream each entry, map it to string value
-        "The stream '" + entry.streamName + "' checking type '" + testByName.get(entry.streamName).getSourceType() + "' initialized at "
-            + testByName.get(entry.streamName).getDeclarationLocation() + " got unexpected values: " + entry.unexpectedValue)
-            .collect(Collectors.joining("\n"))); // and join them
-
     // Gather all the missing values, so we don't stop the test in the first missed one
     expectedValues.forEach((streamName, values) -> {
       if (!values.isEmpty()) {
@@ -198,11 +192,15 @@ public UnexpectedRecord(String streamName, String unexpectedValue) {
       }
     });
 
-    assertTrue(missedValues.isEmpty(),
+    assertTrue(missedValues.isEmpty() && unexpectedValues.isEmpty(),
         missedValues.stream().map((entry) -> // stream each entry, map it to string value
         "The stream '" + entry.streamName + "' checking type '" + testByName.get(entry.streamName).getSourceType() + "' initialized at "
             + testByName.get(entry.streamName).getDeclarationLocation() + " is missing values: " + entry.missedValues)
-            .collect(Collectors.joining("\n"))); // and join them
+            .collect(Collectors.joining("\n")) +
+          unexpectedValues.stream().map((entry) -> // stream each entry, map it to string value
+                  "The stream '" + entry.streamName + "' checking type '" + testByName.get(entry.streamName).getSourceType() + "' initialized at "
+                  + testByName.get(entry.streamName).getDeclarationLocation() + " got unexpected values: " + entry.unexpectedValue)
+              .collect(Collectors.joining("\n"))); // and join them
   }
 
   protected String getValueFromJsonNode(final JsonNode jsonNode) throws IOException {
diff --git a/airbyte-integrations/connectors/source-mssql/src/test-integration/java/io/airbyte/integrations/source/mssql/SshKeyMssqlSourceAcceptanceTest.java b/airbyte-integrations/connectors/source-mssql/src/test-integration/java/io/airbyte/integrations/source/mssql/SshKeyMssqlSourceAcceptanceTest.java
index 4990c606952a0..276bcc7ee8042 100644
--- a/airbyte-integrations/connectors/source-mssql/src/test-integration/java/io/airbyte/integrations/source/mssql/SshKeyMssqlSourceAcceptanceTest.java
+++ b/airbyte-integrations/connectors/source-mssql/src/test-integration/java/io/airbyte/integrations/source/mssql/SshKeyMssqlSourceAcceptanceTest.java
@@ -5,7 +5,9 @@
 package io.airbyte.integrations.source.mssql;
 
 import io.airbyte.cdk.integrations.base.ssh.SshTunnel.TunnelMethod;
+import org.junit.jupiter.api.Disabled;
 
+@Disabled
 public class SshKeyMssqlSourceAcceptanceTest extends AbstractSshMssqlSourceAcceptanceTest {
 
   @Override
diff --git a/airbyte-integrations/connectors/source-mssql/src/test-integration/java/io/airbyte/integrations/source/mssql/SshPasswordMssqlSourceAcceptanceTest.java b/airbyte-integrations/connectors/source-mssql/src/test-integration/java/io/airbyte/integrations/source/mssql/SshPasswordMssqlSourceAcceptanceTest.java
index 35b0b57bf6f80..61b015fc538ae 100644
--- a/airbyte-integrations/connectors/source-mssql/src/test-integration/java/io/airbyte/integrations/source/mssql/SshPasswordMssqlSourceAcceptanceTest.java
+++ b/airbyte-integrations/connectors/source-mssql/src/test-integration/java/io/airbyte/integrations/source/mssql/SshPasswordMssqlSourceAcceptanceTest.java
@@ -5,7 +5,9 @@
 package io.airbyte.integrations.source.mssql;
 
 import io.airbyte.cdk.integrations.base.ssh.SshTunnel.TunnelMethod;
+import org.junit.jupiter.api.Disabled;
 
+@Disabled
 public class SshPasswordMssqlSourceAcceptanceTest extends AbstractSshMssqlSourceAcceptanceTest {
 
   @Override