[DB source errors] : Handle common transient errors

airbyte-cdk/java/airbyte-cdk/core/src/main/kotlin/io/airbyte/cdk/integrations/util/ConnectorExceptionUtil.kt

@@ -9,6 +9,7 @@ import io.airbyte.commons.exceptions.ConfigErrorException
 import io.airbyte.commons.exceptions.ConnectionErrorException
 import io.airbyte.commons.exceptions.TransientErrorException
 import io.airbyte.commons.functional.Either
+import java.io.EOFException
 import java.sql.SQLException
 import java.sql.SQLSyntaxErrorException
 import java.util.stream.Collectors
@@ -25,6 +26,8 @@ object ConnectorExceptionUtil {
     const val RECOVERY_CONNECTION_ERROR_MESSAGE: String =
         "We're having issues syncing from a Postgres replica that is configured as a hot standby server. " +
             "Please see https://go.airbyte.com/pg-hot-standby-error-message for options and workarounds"
+    const val DATABASE_CONNECTION_ERROR: String =
+        "Encountered an error while connecting to the database error"
 
     @JvmField val HTTP_AUTHENTICATION_ERROR_CODES: List<Int> = ImmutableList.of(401, 403)
 
@@ -35,7 +38,10 @@ object ConnectorExceptionUtil {
     }
 
     fun isTransientError(e: Throwable?): Boolean {
-        return isTransientErrorException(e) || isRecoveryConnectionException(e)
+        return isTransientErrorException(e) ||
+            isRecoveryConnectionException(e) ||
+            isTransientEOFException(e) ||
+            isTransientSQLException(e)
     }
 
     fun getDisplayMessage(e: Throwable?): String? {
@@ -49,6 +55,8 @@ object ConnectorExceptionUtil {
             RECOVERY_CONNECTION_ERROR_MESSAGE
         } else if (isUnknownColumnInFieldListException(e)) {
             e!!.message
+        } else if (isTransientError(e)) {
+            DATABASE_CONNECTION_ERROR
         } else {
             String.format(
                 COMMON_EXCEPTION_MESSAGE_TEMPLATE,
@@ -137,6 +145,16 @@ object ConnectorExceptionUtil {
         return e is ConnectionErrorException
     }
 
+    private fun isTransientEOFException(e: Throwable?): Boolean {
+        return (e is EOFException) &&
+            e.message!!.lowercase().contains("connection was unexpectedly lost")
+    }
+
+    private fun isTransientSQLException(e: Throwable?): Boolean {
+        return (e is SQLException) &&
+            e.message!!.lowercase().contains("An I/O error occurred while sending to the backend")
+    }
+
     private fun isRecoveryConnectionException(e: Throwable?): Boolean {
         return e is SQLException &&
             e.message!!.lowercase().contains("due to conflict with recovery")

airbyte-integrations/connectors/source-mysql/build.gradle

@@ -8,7 +8,7 @@ plugins {
 airbyteJavaConnector {
     cdkVersionRequired = '0.33.1'
     features = ['db-sources']
-    useLocalCdk = false
+    useLocalCdk = true
 }
 
 java {

airbyte-integrations/connectors/source-mysql/metadata.yaml

@@ -9,7 +9,7 @@ data:
   connectorSubtype: database
   connectorType: source
   definitionId: 435bb9a5-7887-4809-aa58-28c27df0d7ad
-  dockerImageTag: 3.4.2
+  dockerImageTag: 3.4.3
   dockerRepository: airbyte/source-mysql
   documentationUrl: https://docs.airbyte.com/integrations/sources/mysql
   githubIssueLabel: source-mysql

docs/integrations/sources/mysql.md

@@ -230,6 +230,7 @@ Any database or table encoding combination of charset and collation is supported
 
 | Version | Date       | Pull Request                                               | Subject                                                                                                                                         |
 |:--------|:-----------| :--------------------------------------------------------- |:------------------------------------------------------------------------------------------------------------------------------------------------|
+| 3.4.3   | 2024-05-13 | [38104](https://github.com/airbytehq/airbyte/pull/38104)   | Handle transient error messages.                                                                                                                |
 | 3.4.2   | 2024-05-07 | [38046](https://github.com/airbytehq/airbyte/pull/38046)   | Resumeable refresh should run only if there is source defined pk.                                                                               |
 | 3.4.1   | 2024-05-03 | [37824](https://github.com/airbytehq/airbyte/pull/37824)   | Fixed a bug on Resumeable full refresh where cursor based source throw NPE.                                                                     |
 | 3.4.0   | 2024-05-02 | [36932](https://github.com/airbytehq/airbyte/pull/36932)   | Resumeable full refresh. Note please upgrade your platform - minimum platform version is 0.58.0.                                                |