2021-07-09 05:45:45 INFO Executing worker wrapper. Airbyte version: 0.27.0-alpha 2021-07-09 05:45:46 INFO Executing worker wrapper. Airbyte version: 0.27.0-alpha 2021-07-09 05:45:46 INFO start sync worker. job id: 15 attempt id: 0 2021-07-09 05:45:46 INFO configured sync modes: {helpdeskv2.export_conversations=incremental - append} 2021-07-09 05:45:46 INFO Running destination... 2021-07-09 05:45:46 INFO stdoutLocalPort = 9016 2021-07-09 05:45:46 INFO stderrLocalPort = 9017 2021-07-09 05:45:46 INFO Creating stdout socket server... 2021-07-09 05:45:46 INFO Creating stderr socket server... 2021-07-09 05:45:46 INFO Creating pod... 2021-07-09 05:45:46 INFO Waiting until command fetcher pod completes... 2021-07-09 05:45:47 INFO Found entrypoint: /airbyte/base.sh 2021-07-09 05:45:47 INFO Creating pod... 2021-07-09 05:45:47 INFO Waiting for init container to be ready before copying files... 2021-07-09 05:45:47 INFO Init container present.. 2021-07-09 05:45:52 INFO Init container ready.. 2021-07-09 05:45:52 INFO Copying files... 2021-07-09 05:45:52 INFO Uploading file: destination_config.json 2021-07-09 05:45:52 INFO Uploading file: destination_catalog.json 2021-07-09 05:45:52 INFO Uploading file: FINISHED_UPLOADING 2021-07-09 05:45:52 INFO Waiting until pod is ready... 2021-07-09 05:46:09 INFO Setting stdout... 2021-07-09 05:46:13 INFO Setting stderr... 2021-07-09 05:46:15 INFO Reading pod IP... 2021-07-09 05:46:15 INFO Pod IP: 172.31.17.98 2021-07-09 05:46:15 INFO Creating stdin socket... 2021-07-09 09:15:36 INFO Running sync worker cancellation... 2021-07-09 09:15:36 INFO Cancelling replication worker... 2021-07-09 09:15:46 INFO Cancelling destination... 2021-07-09 09:15:46 INFO Attempting to cancel destination process... 2021-07-09 09:15:46 INFO Destination process exists, cancelling... 2021-07-09 09:15:46 INFO Destroying Kube process: airbyte-worker-15-0-xqvmd 2021-07-09 09:15:46 INFO stdoutLocalPort = 9016 2021-07-09 09:15:46 INFO Port consumer releasing: 9016 2021-07-09 09:15:46 WARN airbyte-destination gobbler IOException: Socket closed. Typically happens when cancelling a job. 2021-07-09 09:15:46 INFO Port consumer releasing: 9017 2021-07-09 09:15:46 INFO Destroyed Kube process: airbyte-worker-15-0-xqvmd 2021-07-09 09:15:56 INFO Port consumer releasing: 9016 2021-07-09 09:15:56 INFO Port consumer releasing: 9017 2021-07-09 09:15:56 INFO Destroying Kube process: airbyte-worker-15-0-xqvmd 2021-07-09 09:15:56 INFO Port consumer releasing: 9016 2021-07-09 09:15:56 INFO Port consumer releasing: 9017 2021-07-09 09:15:56 INFO stderrLocalPort = 9017 2021-07-09 09:15:56 INFO Destroyed Kube process: airbyte-worker-15-0-xqvmd 2021-07-09 09:15:56 INFO Cancelled destination process! 2021-07-09 09:15:56 INFO Cancelling source... 2021-07-09 09:15:56 INFO Attempting to cancel source process... 2021-07-09 09:15:56 INFO Source process no longer exists, cancellation is a no-op. 2021-07-09 09:15:56 INFO Interrupting worker thread... 2021-07-09 09:15:56 INFO Cancelling completable future... 2021-07-09 09:15:56 INFO Creating stdout socket server... 2021-07-09 09:15:56 INFO Stopping cancellation check scheduling... 2021-07-09 09:15:56 WARN Job either timeout-ed or was cancelled. 2021-07-09 09:15:56 INFO Creating pod... 2021-07-09 09:15:56 INFO Creating stderr socket server... 2021-07-09 09:15:56 INFO Port consumer releasing: 9016 2021-07-09 09:15:56 INFO Port consumer releasing: 9017 2021-07-09 09:15:56 ERROR Exception while while waiting for process to finish java.lang.InterruptedException: sleep interrupted at java.lang.Thread.sleep(Native Method) ~[?:?] at java.lang.Process.waitFor(Process.java:217) ~[?:?] at io.airbyte.workers.process.KubePodProcess.waitFor(KubePodProcess.java:507) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?] at io.airbyte.workers.WorkerUtils.gentleClose(WorkerUtils.java:56) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:123) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:121) ~[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) [?:?] 2021-07-09 09:15:56 WARN Activity failure. ActivityId=a259311f-6a0c-36b5-9669-9cae97c07c64, 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:15:56 WARN Process is taking too long to finish. Killing it 2021-07-09 09:15:56 INFO Destroying Kube process: airbyte-worker-15-0-xqvmd 2021-07-09 09:15:56 INFO Port consumer releasing: 9016 2021-07-09 09:15:56 INFO Port consumer releasing: 9017 2021-07-09 09:15:56 INFO Destroyed Kube process: airbyte-worker-15-0-xqvmd 2021-07-09 09:16:16 INFO Unable to find pod airbyte-worker-15-0-xqvmd to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2021-07-09 09:16:16 INFO Port consumer releasing: 9016 2021-07-09 09:16:16 INFO Port consumer releasing: 9017 2021-07-09 09:16:16 INFO Unable to find pod airbyte-worker-15-0-xqvmd to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2021-07-09 09:16:16 INFO Unable to find pod airbyte-worker-15-0-xqvmd to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2021-07-09 09:16:16 INFO Unable to find pod airbyte-worker-15-0-xqvmd to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2021-07-09 09:16:16 INFO Unable to find pod airbyte-worker-15-0-xqvmd to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2021-07-09 09:16:16 INFO Unable to find pod airbyte-worker-15-0-xqvmd to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2021-07-09 09:16:16 WARN Destination process might not have shut down correctly. destination process alive: false, destination process exit value: 143. This warning is normal if the job was cancelled. 2021-07-09 09:16:16 ERROR Sync worker failed. io.airbyte.workers.WorkerException: Operation: [create] for kind: [Pod] with name: [airbyte-command-fetcher-jbysm] in namespace: [airbyte] failed. at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:116) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?] at io.airbyte.workers.process.ProcessFactory.create(ProcessFactory.java:71) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?] at io.airbyte.workers.process.AirbyteIntegrationLauncher.read(AirbyteIntegrationLauncher.java:140) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.start(DefaultAirbyteSource.java:81) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:123) ~[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: io.fabric8.kubernetes.client.KubernetesClientException: Operation: [create] for kind: [Pod] with name: [airbyte-command-fetcher-jbysm] in namespace: [airbyte] failed. at io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:64) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:72) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.create(BaseOperation.java:373) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.utils.CreateOrReplaceHelper.createOrReplace(CreateOrReplaceHelper.java:53) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.createOrReplace(BaseOperation.java:411) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.createOrReplace(BaseOperation.java:86) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.createOrReplace(BaseOperation.java:394) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.createOrReplace(BaseOperation.java:86) ~[kubernetes-client-5.3.1.jar:?] at io.airbyte.workers.process.KubePodProcess.getCommandFromImage(KubePodProcess.java:165) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?] at io.airbyte.workers.process.KubePodProcess.(KubePodProcess.java:309) ~[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:?] ... 7 more Caused by: java.io.InterruptedIOException: interrupted at okio.Timeout.throwIfReached(Timeout.java:146) ~[okio-1.17.2.jar:?] at okio.Okio$1.write(Okio.java:76) ~[okio-1.17.2.jar:?] at okio.AsyncTimeout$1.write(AsyncTimeout.java:180) ~[okio-1.17.2.jar:?] at okio.RealBufferedSink.flush(RealBufferedSink.java:224) ~[okio-1.17.2.jar:?] at okhttp3.internal.http2.Http2Writer.flush(Http2Writer.java:121) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http2.Http2Connection.flush(Http2Connection.java:439) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http2.Http2Stream$FramingSink.close(Http2Stream.java:631) ~[okhttp-3.14.9.jar:?] at okio.ForwardingSink.close(ForwardingSink.java:47) ~[okio-1.17.2.jar:?] at okhttp3.internal.connection.Exchange$RequestBodySink.close(Exchange.java:253) ~[okhttp-3.14.9.jar:?] at okio.RealBufferedSink.close(RealBufferedSink.java:248) ~[okio-1.17.2.jar:?] at okhttp3.internal.http.CallServerInterceptor.intercept(CallServerInterceptor.java:70) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:43) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:94) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:88) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[okhttp-3.14.9.jar:?] at io.fabric8.kubernetes.client.utils.BackwardsCompatibilityInterceptor.intercept(BackwardsCompatibilityInterceptor.java:133) ~[kubernetes-client-5.3.1.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[okhttp-3.14.9.jar:?] at io.fabric8.kubernetes.client.utils.TokenRefreshInterceptor.intercept(TokenRefreshInterceptor.java:42) ~[kubernetes-client-5.3.1.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[okhttp-3.14.9.jar:?] at io.fabric8.kubernetes.client.utils.ImpersonatorInterceptor.intercept(ImpersonatorInterceptor.java:68) ~[kubernetes-client-5.3.1.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[okhttp-3.14.9.jar:?] at io.fabric8.kubernetes.client.utils.HttpClientUtils.lambda$createApplicableInterceptors$6(HttpClientUtils.java:284) ~[kubernetes-client-5.3.1.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:142) ~[okhttp-3.14.9.jar:?] at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:117) ~[okhttp-3.14.9.jar:?] at okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:229) ~[okhttp-3.14.9.jar:?] at okhttp3.RealCall.execute(RealCall.java:81) ~[okhttp-3.14.9.jar:?] at io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:485) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:448) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleCreate(OperationSupport.java:263) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.handleCreate(BaseOperation.java:870) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.create(BaseOperation.java:365) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.utils.CreateOrReplaceHelper.createOrReplace(CreateOrReplaceHelper.java:53) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.createOrReplace(BaseOperation.java:411) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.createOrReplace(BaseOperation.java:86) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.createOrReplace(BaseOperation.java:394) ~[kubernetes-client-5.3.1.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.createOrReplace(BaseOperation.java:86) ~[kubernetes-client-5.3.1.jar:?] at io.airbyte.workers.process.KubePodProcess.getCommandFromImage(KubePodProcess.java:165) ~[io.airbyte-airbyte-workers-0.27.0-alpha.jar:?] at io.airbyte.workers.process.KubePodProcess.(KubePodProcess.java:309) ~[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:?] ... 7 more 2021-07-09 09:16:16 INFO sync summary: io.airbyte.config.ReplicationAttemptSummary@454e0932[status=cancelled,recordsSynced=0,bytesSynced=0,startTime=1625809546021,endTime=1625822176271] 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@85fdb55[state={"cdc":false,"streams":[{"cursor":"2021-07-06T09:49:26Z","stream_name":"export_conversations","cursor_field":["updatedAt"],"stream_namespace":"helpdeskv2"}]}]