[destination-mssql] no exit code issue

[plovegro]

Connector Name

destination-mssql

Connector Version

2.2.15

What step the error happened?

During the sync

Relevant information

During running a large sync (Source = Hubspot, but it does it with lots of sources) i am repeatably getting this error. The sync then starts another attempt and goes round in circles. Some data is being written to the database.
The new attempt then starts with this -

2026-04-07 10:51:22 platform INFO Retry State: RetryManager(completeFailureBackoffPolicy=BackoffPolicy(minInterval=PT10S, maxInterval=PT30M, base=3), partialFailureBackoffPolicy=null, successiveCompleteFailureLimit=5, successivePartialFailureLimit=1000, totalCompleteFailureLimit=10, totalPartialFailureLimit=20, successiveCompleteFailures=0, successivePartialFailures=2, totalCompleteFailures=0, totalPartialFailures=2)
2026-04-07 10:51:22 platform WARN Backing off for: 0 seconds.

The Active streams section also shows some strange values -

Database at time of screenshot had 400k rows.

Relevant log output

2026-04-07 10:28:44 replication-orchestrator WARN Failed to wait for exit value file /dest/exitCode.txt to be found.
2026-04-07 10:29:44 replication-orchestrator WARN Failed to wait for exit value file /source/exitCode.txt to be found.
2026-04-07 10:29:44 replication-orchestrator INFO Closing StateCheckSumCountEventHandler
2026-04-07 10:29:44 replication-orchestrator INFO sync summary: {"status" : "failed",
  "recordsSynced" : 30528,
  "bytesSynced" : 20969590,
  "startTime" : 1775520644057,
  "endTime" : 1775521784699,
  "totalStats" : {
    "bytesCommitted" : 20969590,
    "bytesEmitted" : 458247829,
    "destinationStateMessagesEmitted" : 1,
    "destinationWriteEndTime" : 0,
    "destinationWriteStartTime" : 1775520644154,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 1,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 152,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 152,
    "recordsEmitted" : 982068,
    "recordsCommitted" : 30528,
    "recordsFilteredOut" : 0,
    "bytesFilteredOut" : 0,
    "replicationEndTime" : 1775521784697,
    "replicationStartTime" : 1775520644057,
    "sourceReadEndTime" : 0,
    "sourceReadStartTime" : 1775520644155,
    "sourceStateMessagesEmitted" : 1
  },
  "streamStats" : [ {
    "streamName" : "email_events",
    "stats" : {
      "bytesCommitted" : 20969590,
      "bytesEmitted" : 458247829,
      "recordsEmitted" : 982068,
      "recordsCommitted" : 30528,
      "recordsFilteredOut" : 0,
      "bytesFilteredOut" : 0
    }
  } ],
  "performanceMetrics" : {
    "processFromSource" : {
      "elapsedTimeInNanos" : 5852570696,
      "executionCount" : 982071,
      "avgExecTimeInNanos" : 5959.417084915449
    },
    "readFromSource" : {
      "elapsedTimeInNanos" : 1018918770091,
      "executionCount" : 982122,
      "avgExecTimeInNanos" : 1037466.5979287706
    },
    "processFromDest" : {
      "elapsedTimeInNanos" : 1651634,
      "executionCount" : 1,
      "avgExecTimeInNanos" : 1651634.0
    },
    "writeToDest" : {
      "elapsedTimeInNanos" : 10222280723,
      "executionCount" : 981102,
      "avgExecTimeInNanos" : 10419.182432611491
    },
    "readFromDest" : {
      "elapsedTimeInNanos" : 1019731145703,
      "executionCount" : 122252,
      "avgExecTimeInNanos" : 8341222.603335733
    }
  }
}2026-04-07 10:29:44 replication-orchestrator INFO failures: [ {
  "failureOrigin" : "destination",
  "internalMessage" : "Destination process message delivery failed",
  "externalMessage" : "Something went wrong within the destination connector",
  "metadata" : {
    "attemptNumber" : 0,
    "jobId" : 139039,
    "connector_command" : "write"
  },
  "stacktrace" : "io.airbyte.workers.internal.exception.DestinationException: Destination process message delivery failed\n\tat io.airbyte.workers.general.BufferedReplicationWorker.writeToDestination(BufferedReplicationWorker.java:454)\n\tat io.airbyte.workers.general.BufferedReplicationWorker.lambda$runAsyncWithTimeout$5(BufferedReplicationWorker.java:244)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\nCaused by: java.io.IOException: Broken pipe\n\tat java.base/sun.nio.ch.UnixFileDispatcherImpl.write0(Native Method)\n\tat java.base/sun.nio.ch.UnixFileDispatcherImpl.write(UnixFileDispatcherImpl.java:65)\n\tat java.base/sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)\n\tat java.base/sun.nio.ch.IOUtil.write(IOUtil.java:102)\n\tat java.base/sun.nio.ch.IOUtil.write(IOUtil.java:72)\n\tat java.base/sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:300)\n\tat java.base/sun.nio.ch.ChannelOutputStream.writeFully(ChannelOutputStream.java:68)\n\tat java.base/sun.nio.ch.ChannelOutputStream.write(ChannelOutputStream.java:105)\n\tat java.base/sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:309)\n\tat java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:381)\n\tat java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:357)\n\tat java.base/sun.nio.cs.StreamEncoder.lockedWrite(StreamEncoder.java:158)\n\tat java.base/sun.nio.cs.StreamEncoder.write(StreamEncoder.java:139)\n\tat java.base/java.io.OutputStreamWriter.write(OutputStreamWriter.java:219)\n\tat java.base/java.io.BufferedWriter.implFlushBuffer(BufferedWriter.java:178)\n\tat java.base/java.io.BufferedWriter.flushBuffer(BufferedWriter.java:163)\n\tat java.base/java.io.BufferedWriter.implWrite(BufferedWriter.java:334)\n\tat java.base/java.io.BufferedWriter.write(BufferedWriter.java:313)\n\tat java.base/java.io.Writer.write(Writer.java:278)\n\tat io.airbyte.workers.internal.VersionedAirbyteMessageBufferedWriter.write(VersionedAirbyteMessageBufferedWriter.java:39)\n\tat io.airbyte.workers.internal.LocalContainerAirbyteDestination.acceptWithNoTimeoutMonitor(LocalContainerAirbyteDestination.kt:137)\n\tat io.airbyte.workers.internal.LocalContainerAirbyteDestination.accept(LocalContainerAirbyteDestination.kt:96)\n\tat io.airbyte.workers.general.BufferedReplicationWorker.writeToDestination(BufferedReplicationWorker.java:439)\n\t... 5 more\n",
  "timestamp" : 1775521664087
}, {
  "failureOrigin" : "replication",
  "internalMessage" : "No exit code found.",
  "externalMessage" : "Something went wrong during replication",
  "metadata" : {
    "attemptNumber" : 0,
    "jobId" : 139039
  },
  "stacktrace" : "java.lang.IllegalStateException: No exit code found.\n\tat io.airbyte.workers.internal.ContainerIOHandle.getExitCode(ContainerIOHandle.kt:101)\n\tat io.airbyte.workers.internal.LocalContainerAirbyteDestination.getExitValue(LocalContainerAirbyteDestination.kt:118)\n\tat io.airbyte.workers.general.BufferedReplicationWorker.readFromDestination(BufferedReplicationWorker.java:496)\n\tat io.airbyte.workers.general.BufferedReplicationWorker.lambda$runAsync$2(BufferedReplicationWorker.java:216)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\n",
  "timestamp" : 1775521664086
}, {
  "failureOrigin" : "source",
  "internalMessage" : "Source process read attempt failed",
  "externalMessage" : "Something went wrong within the source connector",
  "metadata" : {
    "attemptNumber" : 0,
    "jobId" : 139039,
    "connector_command" : "read"
  },
  "stacktrace" : "io.airbyte.workers.internal.exception.SourceException: Source process read attempt failed\n\tat io.airbyte.workers.general.BufferedReplicationWorker.readFromSource(BufferedReplicationWorker.java:376)\n\tat io.airbyte.workers.general.BufferedReplicationWorker.lambda$runAsyncWithHeartbeatCheck$3(BufferedReplicationWorker.java:223)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\nCaused by: java.lang.IllegalStateException: No exit code found.\n\tat io.airbyte.workers.internal.ContainerIOHandle.getExitCode(ContainerIOHandle.kt:101)\n\tat io.airbyte.workers.internal.LocalContainerAirbyteSource.getExitValue(LocalContainerAirbyteSource.kt:89)\n\tat io.airbyte.workers.general.BufferedReplicationWorker.readFromSource(BufferedReplicationWorker.java:356)\n\t... 5 more\n",
  "timestamp" : 1775521664688
}, {
  "failureOrigin" : "replication",
  "internalMessage" : "io.airbyte.workers.exception.WorkerException: Destination has not terminated.  This warning is normal if the job was cancelled.",
  "externalMessage" : "Something went wrong during replication",
  "metadata" : {
    "attemptNumber" : 0,
    "jobId" : 139039
  },
  "stacktrace" : "java.lang.RuntimeException: io.airbyte.workers.exception.WorkerException: Destination has not terminated.  This warning is normal if the job was cancelled.\n\tat io.airbyte.workers.general.BufferedReplicationWorker$CloseableWithTimeout.lambda$close$0(BufferedReplicationWorker.java:548)\n\tat io.airbyte.workers.general.BufferedReplicationWorker.lambda$runAsyncWithTimeout$5(BufferedReplicationWorker.java:244)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\nCaused by: io.airbyte.workers.exception.WorkerException: Destination has not terminated.  This warning is normal if the job was cancelled.\n\tat io.airbyte.workers.internal.LocalContainerAirbyteDestination.close(LocalContainerAirbyteDestination.kt:64)\n\tat io.airbyte.workers.general.BufferedReplicationWorker$CloseableWithTimeout.lambda$close$0(BufferedReplicationWorker.java:546)\n\t... 5 more\n",
  "timestamp" : 1775521724695
} ]
2026-04-07 10:29:44 replication-orchestrator INFO 
2026-04-07 10:29:44 replication-orchestrator INFO ----- END REPLICATION -----
2026-04-07 10:29:44 replication-orchestrator INFO 
2026-04-07 10:29:44 replication-orchestrator INFO Returning output...
2026-04-07 10:29:44 platform INFO Closing Segment analytics client...
2026-04-07 10:29:44 platform INFO Waiting for Segment analytic client to flush enqueued messages...
2026-04-07 10:29:44 platform INFO Segment analytic client flush complete.
2026-04-07 10:29:44 platform INFO Segment analytics client closed.  No new events will be accepted.
2026-04-07 10:29:45 platform INFO 
----- START POST REPLICATION OPERATIONS -----

2026-04-07 10:29:45 platform INFO No post-replication operation(s) to perform.
2026-04-07 10:29:45 platform INFO 
----- END POST REPLICATION OPERATIONS -----

2026-04-07 10:29:46 platform INFO Retry State: RetryManager(completeFailureBackoffPolicy=BackoffPolicy(minInterval=PT10S, maxInterval=PT30M, base=3), partialFailureBackoffPolicy=null, successiveCompleteFailureLimit=5, successivePartialFailureLimit=1000, totalCompleteFailureLimit=10, totalPartialFailureLimit=20, successiveCompleteFailures=0, successivePartialFailures=1, totalCompleteFailures=0, totalPartialFailures=1)
 Backoff before next attempt: 0 seconds

Contribute

• Yes, I want to contribute

---

Internal Tracking: https://github.com/airbytehq/oncall/issues/11899

[octavia-bot]

AI Triage Starting...

Thank you for opening this issue! I'm an AI assistant that will do an initial review and may:

• Ask clarifying questions if needed
• Suggest relevant documentation or workarounds
• Flag this for internal visibility

Note: Community issues are reviewed on a best-effort basis and do not have a guaranteed response time. For additional help:

• Join the Airbyte Community Slack to connect with other users and community members
• If you're an Airbyte Cloud customer, you can open a support ticket or contact your account representative, referencing this issue URL

View playbook

• 🔗 Session URL: https://app.devin.ai/sessions/09870dfc04ef4d54902707bec161a115

✅ Devin AI session created successfully!

[devin-ai-integration]

Hi plovegro, thank you for reporting this issue!

It looks like the destination-mssql connector is crashing during large syncs, which causes the replication orchestrator to fail when it cannot find the exit code files (/dest/exitCode.txt and /source/exitCode.txt). The root cause appears to be the destination process dying with a Broken pipe error (java.io.IOException: Broken pipe), which then cascades into the "No exit code found" failures you are seeing.

From your logs, only 30,528 of 982,068 emitted records were committed before the destination process crashed. The retry manager then kicks in but likely hits the same issue on subsequent attempts, causing the loop you described.

A few clarifying questions:

1. Airbyte version: Are you running Airbyte OSS self-hosted? If so, which version?
2. Resource limits: What are the memory/CPU resources allocated to your destination container? Large syncs with destination-mssql can be memory-intensive, and the Broken pipe error may indicate the destination process was killed due to an OOM (Out of Memory) condition.
3. MSSQL Server version: Which version of SQL Server are you connecting to?
4. Reproducibility: Does this happen consistently with large syncs, or is it intermittent? Does it succeed with smaller data volumes?

Troubleshooting Suggestions

• If you are self-hosted, try increasing the memory allocation for the destination container. OOM kills are a common cause of "Broken pipe" + "No exit code found" errors.
• Check your MSSQL server logs around the time of the failure for any connection drops, deadlocks, or resource exhaustion errors.
• If possible, try syncing a single smaller stream first to confirm the connector works for lower volumes.

I have escalated this to our internal team for further investigation.

---

Need more help? Join Airbyte Community Slack for peer support, or if you're a Cloud customer, open a support ticket referencing this URL.

[plovegro]

Airbyte version: OSS - 1.6.2
Resource limits: Out of box values
MSSQL Server version: Azure SQL Server
Reproducibility: seems random