classify mysql client transient error

Author: jgao54

flow/shared/exceptions/mysql.go

@@ -72,8 +72,7 @@ func NewMySQLStreamingError(err error) *MySQLStreamingError {
 		return &MySQLStreamingError{err, true}
 	}
 
-	var recordHeaderError tls.RecordHeaderError
-	if errors.As(err, &recordHeaderError) {
+	if recordHeaderError, ok := errors.AsType[tls.RecordHeaderError](err); ok {
 		if recordHeaderError.Msg == "first record does not look like a TLS handshake" {
 			return &MySQLStreamingError{err, true}
 		}
@@ -83,6 +82,10 @@ func NewMySQLStreamingError(err error) *MySQLStreamingError {
 		return &MySQLStreamingError{err, true}
 	}
 
+	if strings.Contains(err.Error(), "handleAuthResult: ReadPacket: invalid sequence") {
+		return &MySQLStreamingError{err, true}
+	}
+
 	return &MySQLStreamingError{err, false}
 }