2021-07-09 09:15:34 INFO  Executing worker wrapper. Airbyte version: 0.27.0-alpha
2021-07-09 09:15:34 INFO  Executing worker wrapper. Airbyte version: 0.27.0-alpha
2021-07-09 09:15:34 INFO  start sync worker. job id: 16 attempt id: 0
2021-07-09 09:15:34 INFO  configured sync modes: {helpdeskv2.export_conversations=incremental - append}
2021-07-09 09:15:34 INFO  Running destination...
2021-07-09 09:15:56 INFO  stdoutLocalPort = 9016
2021-07-09 09:15:56 INFO  stderrLocalPort = 9017
2021-07-09 09:15:56 ERROR Sync worker failed.
io.airbyte.workers.WorkerException: Address already in use
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:116) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.write(AirbyteIntegrationLauncher.java:163) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.start(DefaultAirbyteDestination.java:79) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:122) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:52) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
Caused by: java.net.BindException: Address already in use
	at sun.nio.ch.Net.bind0(Native Method) ~[?:?]
	at sun.nio.ch.Net.bind(Net.java:479) ~[?:?]
	at sun.nio.ch.Net.bind(Net.java:468) ~[?:?]
	at sun.nio.ch.NioSocketImpl.bind(NioSocketImpl.java:643) ~[?:?]
	at java.net.ServerSocket.bind(ServerSocket.java:396) ~[?:?]
	at java.net.ServerSocket.<init>(ServerSocket.java:282) ~[?:?]
	at java.net.ServerSocket.<init>(ServerSocket.java:173) ~[?:?]
	at io.airbyte.workers.process.KubePodProcess.<init>(KubePodProcess.java:304) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:100) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	... 6 more
2021-07-09 09:15:56 INFO  sync summary: io.airbyte.config.ReplicationAttemptSummary@220de598[status=failed,recordsSynced=0,bytesSynced=0,startTime=1625822134754,endTime=1625822156220]
2021-07-09 09:15:56 INFO  Source did not output any state messages
2021-07-09 09:15:56 WARN  State capture: No new state, falling back on input state: io.airbyte.config.State@9ac7bca[state={"cdc":false,"streams":[{"cursor":"2021-07-06T09:49:26Z","stream_name":"export_conversations","cursor_field":["updatedAt"],"stream_namespace":"helpdeskv2"}]}]
2021-07-09 09:15:56 INFO  Stopping cancellation check scheduling...
2021-07-09 09:15:56 INFO  Last output present: true. Should attempt again: true
2021-07-09 09:15:56 INFO  Starting attempt: 1 of 3
2021-07-09 09:15:56 INFO  Executing worker wrapper. Airbyte version: 0.27.0-alpha
2021-07-09 09:15:56 INFO  start sync worker. job id: 16 attempt id: 0
2021-07-09 09:15:56 INFO  configured sync modes: {helpdeskv2.export_conversations=incremental - append}
2021-07-09 09:15:56 INFO  Running destination...
2021-07-09 09:16:16 INFO  stdoutLocalPort = 9016
2021-07-09 09:16:16 INFO  stderrLocalPort = 9017
2021-07-09 09:16:16 ERROR Sync worker failed.
io.airbyte.workers.WorkerException: Address already in use
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:116) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.write(AirbyteIntegrationLauncher.java:163) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.start(DefaultAirbyteDestination.java:79) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:122) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:52) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
Caused by: java.net.BindException: Address already in use
	at sun.nio.ch.Net.bind0(Native Method) ~[?:?]
	at sun.nio.ch.Net.bind(Net.java:479) ~[?:?]
	at sun.nio.ch.Net.bind(Net.java:468) ~[?:?]
	at sun.nio.ch.NioSocketImpl.bind(NioSocketImpl.java:643) ~[?:?]
	at java.net.ServerSocket.bind(ServerSocket.java:396) ~[?:?]
	at java.net.ServerSocket.<init>(ServerSocket.java:282) ~[?:?]
	at java.net.ServerSocket.<init>(ServerSocket.java:173) ~[?:?]
	at io.airbyte.workers.process.KubePodProcess.<init>(KubePodProcess.java:304) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:100) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	... 6 more
2021-07-09 09:16:16 INFO  sync summary: io.airbyte.config.ReplicationAttemptSummary@1bc20270[status=failed,recordsSynced=0,bytesSynced=0,startTime=1625822156244,endTime=1625822176249]
2021-07-09 09:16:16 INFO  Source did not output any state messages
2021-07-09 09:16:16 WARN  State capture: No new state, falling back on input state: io.airbyte.config.State@9ac7bca[state={"cdc":false,"streams":[{"cursor":"2021-07-06T09:49:26Z","stream_name":"export_conversations","cursor_field":["updatedAt"],"stream_namespace":"helpdeskv2"}]}]
2021-07-09 09:16:16 INFO  Stopping cancellation check scheduling...
2021-07-09 09:16:16 INFO  Last output present: true. Should attempt again: true
2021-07-09 09:16:16 INFO  Starting attempt: 2 of 3
2021-07-09 09:16:16 INFO  Executing worker wrapper. Airbyte version: 0.27.0-alpha
2021-07-09 09:16:16 INFO  start sync worker. job id: 16 attempt id: 0
2021-07-09 09:16:16 INFO  configured sync modes: {helpdeskv2.export_conversations=incremental - append}
2021-07-09 09:16:16 INFO  Running destination...
2021-07-09 09:37:06 INFO  Running sync worker cancellation...
2021-07-09 09:37:06 INFO  Cancelling replication worker...
2021-07-09 09:37:16 INFO  Cancelling destination...
2021-07-09 09:37:16 INFO  Attempting to cancel destination process...
2021-07-09 09:37:16 INFO  Destination process no longer exists, cancellation is a no-op.
2021-07-09 09:37:16 INFO  Cancelling source...
2021-07-09 09:37:16 INFO  Attempting to cancel source process...
2021-07-09 09:37:16 INFO  Source process no longer exists, cancellation is a no-op.
2021-07-09 09:37:16 INFO  Interrupting worker thread...
2021-07-09 09:37:16 INFO  Cancelling completable future...
2021-07-09 09:37:16 WARN  Job either timeout-ed or was cancelled.
2021-07-09 09:37:16 ERROR Sync worker failed.
io.airbyte.workers.WorkerException: null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:116) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.write(AirbyteIntegrationLauncher.java:163) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.start(DefaultAirbyteDestination.java:79) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:122) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:52) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
Caused by: java.lang.InterruptedException
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1627) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:485) ~[?:?]
	at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:673) ~[?:?]
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:85) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	... 6 more
2021-07-09 09:37:16 INFO  sync summary: io.airbyte.config.ReplicationAttemptSummary@7f620b10[status=cancelled,recordsSynced=0,bytesSynced=0,startTime=1625822176273,endTime=1625823436287]
2021-07-09 09:37:16 INFO  Source did not output any state messages
2021-07-09 09:37:16 WARN  State capture: No new state, falling back on input state: io.airbyte.config.State@9ac7bca[state={"cdc":false,"streams":[{"cursor":"2021-07-06T09:49:26Z","stream_name":"export_conversations","cursor_field":["updatedAt"],"stream_namespace":"helpdeskv2"}]}]
2021-07-09 09:37:16 INFO  Stopping cancellation check scheduling...
2021-07-09 09:37:16 WARN  Activity failure. ActivityId=391a6c10-b9a4-36e5-99a7-b057cf8dea36, activityType=Replicate, attempt=1
java.util.concurrent.CancellationException: null
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2468) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:190) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:70) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:193) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:630) [?:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
2021-07-09 09:37:16 WARN  Job either timeout-ed or was cancelled.