2022-05-25 12:53:17 INFO i.a.s.a.SchedulerApp(main):227 - temporalHost = airbyte-temporal:7233 2022-05-25 12:53:17 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:20 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:23 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:26 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:29 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:31 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:34 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:36 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:38 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:40 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:42 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:44 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:46 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:48 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:50 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:52 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:54 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:56 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:58 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:00 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:02 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:04 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:06 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:08 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:10 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:12 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:14 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:16 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:53:40 INFO i.a.w.WorkerApp(main):314 - temporalHost = airbyte-temporal:7233 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_CPU_REQUEST: 'null' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_CPU_LIMIT: 'null' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_MEMORY_REQUEST: 'null' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_MEMORY_LIMIT: 'null' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_TOLERATIONS: '' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_NODE_SELECTORS: '' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_SECRET: '' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY: 'IfNotPresent' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_SOCAT_IMAGE: 'alpine/socat:1.7.4.1-r1' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_BUSYBOX_IMAGE: 'busybox:1.28' 2022-05-25 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_CURL_IMAGE: 'curlimages/curl:7.77.0' 2022-05-25 12:53:40 INFO i.a.w.WorkerApp(getJobProcessFactory):264 - Using Kubernetes namespace: apps 2022-05-25 12:53:41 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252) ~[grpc-services-1.42.1.jar:1.42.1] at io.temporal.serviceclient.WorkflowServiceStubsImpl.lambda$checkHealth$2(WorkflowServiceStubsImpl.java:282) ~[temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.checkHealth(WorkflowServiceStubsImpl.java:275) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.(WorkflowServiceStubsImpl.java:182) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:41) [temporal-serviceclient-1.6.0.jar:?] at io.airbyte.workers.temporal.TemporalUtils.createTemporalService(TemporalUtils.java:50) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] at io.airbyte.workers.WorkerApp.main(WorkerApp.java:324) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: airbyte-temporal/172.20.151.83:7233 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.grpc.netty.shaded.io.netty.channel.unix.Errors.newConnectException0(Errors.java:155) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Errors.handleConnectErrno(Errors.java:128) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:278) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:710) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:687) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:567) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:470) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at java.lang.Thread.run(Thread.java:833) ~[?:?] 2022-05-25 12:53:41 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252) ~[grpc-services-1.42.1.jar:1.42.1] at io.temporal.serviceclient.WorkflowServiceStubsImpl.lambda$checkHealth$2(WorkflowServiceStubsImpl.java:282) ~[temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.checkHealth(WorkflowServiceStubsImpl.java:275) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.(WorkflowServiceStubsImpl.java:182) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:41) [temporal-serviceclient-1.6.0.jar:?] at io.airbyte.workers.temporal.TemporalUtils.createTemporalService(TemporalUtils.java:50) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] at io.airbyte.workers.WorkerApp.main(WorkerApp.java:324) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: airbyte-temporal/172.20.151.83:7233 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.grpc.netty.shaded.io.netty.channel.unix.Errors.newConnectException0(Errors.java:155) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Errors.handleConnectErrno(Errors.java:128) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:278) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:710) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:687) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:567) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:470) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at java.lang.Thread.run(Thread.java:833) ~[?:?] 2022-05-25 12:53:41 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252) ~[grpc-services-1.42.1.jar:1.42.1] at io.temporal.serviceclient.WorkflowServiceStubsImpl.lambda$checkHealth$2(WorkflowServiceStubsImpl.java:282) ~[temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.checkHealth(WorkflowServiceStubsImpl.java:275) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.(WorkflowServiceStubsImpl.java:182) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:41) [temporal-serviceclient-1.6.0.jar:?] at io.airbyte.workers.temporal.TemporalUtils.createTemporalService(TemporalUtils.java:50) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] at io.airbyte.workers.WorkerApp.main(WorkerApp.java:324) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: airbyte-temporal/172.20.151.83:7233 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.grpc.netty.shaded.io.netty.channel.unix.Errors.newConnectException0(Errors.java:155) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Errors.handleConnectErrno(Errors.java:128) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:278) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:710) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:687) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:567) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:470) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at java.lang.Thread.run(Thread.java:833) ~[?:?] 2022-05-25 12:53:42 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252) ~[grpc-services-1.42.1.jar:1.42.1] at io.temporal.serviceclient.WorkflowServiceStubsImpl.lambda$checkHealth$2(WorkflowServiceStubsImpl.java:282) ~[temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.checkHealth(WorkflowServiceStubsImpl.java:275) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.(WorkflowServiceStubsImpl.java:182) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:41) [temporal-serviceclient-1.6.0.jar:?] at io.airbyte.workers.temporal.TemporalUtils.createTemporalService(TemporalUtils.java:50) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] at io.airbyte.workers.WorkerApp.main(WorkerApp.java:324) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: airbyte-temporal/172.20.151.83:7233 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.grpc.netty.shaded.io.netty.channel.unix.Errors.newConnectException0(Errors.java:155) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Errors.handleConnectErrno(Errors.java:128) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:278) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:710) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:687) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:567) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:470) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at java.lang.Thread.run(Thread.java:833) ~[?:?] 2022-05-25 12:53:42 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252) ~[grpc-services-1.42.1.jar:1.42.1] at io.temporal.serviceclient.WorkflowServiceStubsImpl.lambda$checkHealth$2(WorkflowServiceStubsImpl.java:282) ~[temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.checkHealth(WorkflowServiceStubsImpl.java:275) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.(WorkflowServiceStubsImpl.java:182) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:41) [temporal-serviceclient-1.6.0.jar:?] at io.airbyte.workers.temporal.TemporalUtils.createTemporalService(TemporalUtils.java:50) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] at io.airbyte.workers.WorkerApp.main(WorkerApp.java:324) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: airbyte-temporal/172.20.151.83:7233 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.grpc.netty.shaded.io.netty.channel.unix.Errors.newConnectException0(Errors.java:155) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Errors.handleConnectErrno(Errors.java:128) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:278) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:710) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:687) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:567) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:470) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at java.lang.Thread.run(Thread.java:833) ~[?:?] 2022-05-25 12:53:43 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252) ~[grpc-services-1.42.1.jar:1.42.1] at io.temporal.serviceclient.WorkflowServiceStubsImpl.lambda$checkHealth$2(WorkflowServiceStubsImpl.java:282) ~[temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.checkHealth(WorkflowServiceStubsImpl.java:275) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.(WorkflowServiceStubsImpl.java:182) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:41) [temporal-serviceclient-1.6.0.jar:?] at io.airbyte.workers.temporal.TemporalUtils.createTemporalService(TemporalUtils.java:50) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] at io.airbyte.workers.WorkerApp.main(WorkerApp.java:324) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: airbyte-temporal/172.20.151.83:7233 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.grpc.netty.shaded.io.netty.channel.unix.Errors.newConnectException0(Errors.java:155) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Errors.handleConnectErrno(Errors.java:128) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:278) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:710) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:687) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:567) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:470) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at java.lang.Thread.run(Thread.java:833) ~[?:?] 2022-05-25 12:53:45 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.42.1.jar:1.42.1] at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252) ~[grpc-services-1.42.1.jar:1.42.1] at io.temporal.serviceclient.WorkflowServiceStubsImpl.lambda$checkHealth$2(WorkflowServiceStubsImpl.java:282) ~[temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.checkHealth(WorkflowServiceStubsImpl.java:275) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubsImpl.(WorkflowServiceStubsImpl.java:182) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:51) [temporal-serviceclient-1.6.0.jar:?] at io.temporal.serviceclient.WorkflowServiceStubs.newInstance(WorkflowServiceStubs.java:41) [temporal-serviceclient-1.6.0.jar:?] at io.airbyte.workers.temporal.TemporalUtils.createTemporalService(TemporalUtils.java:50) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] at io.airbyte.workers.WorkerApp.main(WorkerApp.java:324) [io.airbyte-airbyte-workers-0.35.12-alpha.jar:?] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: airbyte-temporal/172.20.151.83:7233 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.grpc.netty.shaded.io.netty.channel.unix.Errors.newConnectException0(Errors.java:155) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Errors.handleConnectErrno(Errors.java:128) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:278) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:710) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:687) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:567) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:470) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[grpc-netty-shaded-1.42.1.jar:1.42.1] at java.lang.Thread.run(Thread.java:833) ~[?:?] 2022-05-25 12:53:48 INFO i.t.s.WorkflowServiceStubsImpl():184 - Created GRPC client for channel: ManagedChannelOrphanWrapper{delegate=ManagedChannelImpl{logId=1, target=airbyte-temporal:7233}} 2022-05-25 12:53:48 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):125 - Waiting for temporal server... 2022-05-25 12:53:48 WARN i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):130 - Waiting for default namespace to be initialized in temporal... 2022-05-25 12:53:55 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):144 - Found temporal default namespace! 2022-05-25 12:53:55 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_USER: 'airbyte' 2022-05-25 12:53:55 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_PASSWORD: '*****' 2022-05-25 12:53:55 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_URL: 'jdbc:postgresql://airbyte-postgresql:5432/db-airbyte' 2022-05-25 12:53:55 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available... 2022-05-25 12:53:55 INFO i.a.d.i.c.ConfigsDatabaseInstance(lambda$static$3):27 - Testing if airbyte_configs has been created and seeded... 2022-05-25 12:53:57 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available! 2022-05-25 12:53:57 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available! 2022-05-25 12:53:57 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-25 12:53:57 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-25 12:53:57 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available... 2022-05-25 12:53:57 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready... 2022-05-25 12:53:57 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available! 2022-05-25 12:53:57 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available! 2022-05-25 12:53:57 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable DEPLOYMENT_MODE: 'OSS' 2022-05-25 12:53:57 INFO i.t.s.WorkflowServiceStubsImpl():184 - Created GRPC client for channel: ManagedChannelOrphanWrapper{delegate=ManagedChannelImpl{logId=8, target=airbyte-temporal:7233}} 2022-05-25 12:53:57 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):125 - Waiting for temporal server... 2022-05-25 12:53:57 WARN i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):130 - Waiting for default namespace to be initialized in temporal... 2022-05-25 12:54:04 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):144 - Found temporal default namespace! 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_CPU_REQUEST: 'null' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_CPU_LIMIT: 'null' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_MEMORY_REQUEST: 'null' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_MEMORY_LIMIT: 'null' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_TOLERATIONS: '' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_NODE_SELECTORS: '' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_SECRET: '' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY: 'IfNotPresent' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_SOCAT_IMAGE: 'alpine/socat:1.7.4.1-r1' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_BUSYBOX_IMAGE: 'busybox:1.28' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_CURL_IMAGE: 'curlimages/curl:7.77.0' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONTAINER_ORCHESTRATOR_ENABLED: 'false' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAX_SPEC_WORKERS: '5' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAX_CHECK_WORKERS: '5' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAX_DISCOVER_WORKERS: '5' 2022-05-25 12:54:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAX_SYNC_WORKERS: '5' 2022-05-25 12:54:04 INFO o.e.j.u.l.Log(initialized):169 - Logging initialized @28154ms to org.eclipse.jetty.util.log.Slf4jLog 2022-05-25 12:54:04 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=2, pollThreadNamePrefix='Workflow Poller taskQueue="DISCOVER_SCHEMA", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=1, pollThreadNamePrefix='Local Activity Poller taskQueue="DISCOVER_SCHEMA", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Activity Poller taskQueue="DISCOVER_SCHEMA", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=2, pollThreadNamePrefix='Workflow Poller taskQueue="CONNECTION_UPDATER", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=1, pollThreadNamePrefix='Local Activity Poller taskQueue="CONNECTION_UPDATER", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Activity Poller taskQueue="CONNECTION_UPDATER", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=2, pollThreadNamePrefix='Workflow Poller taskQueue="CHECK_CONNECTION", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=1, pollThreadNamePrefix='Local Activity Poller taskQueue="CHECK_CONNECTION", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Activity Poller taskQueue="CHECK_CONNECTION", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=2, pollThreadNamePrefix='Workflow Poller taskQueue="SYNC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=1, pollThreadNamePrefix='Local Activity Poller taskQueue="SYNC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Activity Poller taskQueue="SYNC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO o.e.j.s.Server(doStart):360 - jetty-9.4.31.v20200723; built: 2020-07-23T17:57:36.812Z; git: 450ba27947e13e66baa8cd1ce7e85a4461cacc1d; jvm 17.0.1+12-39 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=2, pollThreadNamePrefix='Workflow Poller taskQueue="GET_SPEC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=1, pollThreadNamePrefix='Local Activity Poller taskQueue="GET_SPEC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Activity Poller taskQueue="GET_SPEC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-jsf5d} 2022-05-25 12:54:05 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Host Local Workflow Poller'}, identity=ffcc0cb8-845b-432e-8e99-7810df8d89ad} 2022-05-25 12:54:05 INFO o.e.j.s.h.ContextHandler(doStart):860 - Started o.e.j.s.ServletContextHandler@72790726{/,null,AVAILABLE} 2022-05-25 12:54:05 INFO o.e.j.s.AbstractConnector(doStart):331 - Started ServerConnector@47a157e5{HTTP/1.1, (http/1.1)}{0.0.0.0:9000} 2022-05-25 12:54:05 INFO o.e.j.s.Server(doStart):400 - Started @28648ms 2022-05-25 12:54:18 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:20 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:22 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:24 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:26 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:28 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:30 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:32 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:34 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:36 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:38 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:40 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:42 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:44 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:46 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:48 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:50 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:52 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:54 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:56 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:54:58 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:55:00 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:55:02 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:55:04 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:55:06 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:55:08 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:55:10 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:55:12 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:55:14 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-25 12:55:16 INFO i.a.s.a.SchedulerApp(main):232 - Creating Job DB connection pool... 2022-05-25 12:55:16 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available... 2022-05-25 12:55:16 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready... 2022-05-25 12:55:17 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available! 2022-05-25 12:55:17 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available! 2022-05-25 12:55:17 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_USER: 'airbyte' 2022-05-25 12:55:17 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_PASSWORD: '*****' 2022-05-25 12:55:17 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_URL: 'jdbc:postgresql://airbyte-postgresql:5432/db-airbyte' 2022-05-25 12:55:17 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available... 2022-05-25 12:55:17 INFO i.a.d.i.c.ConfigsDatabaseInstance(lambda$static$3):27 - Testing if airbyte_configs has been created and seeded... 2022-05-25 12:55:17 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available! 2022-05-25 12:55:17 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available! 2022-05-25 12:55:17 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-25 12:55:17 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-25 12:55:17 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-25 12:55:17 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MINIMUM_WORKSPACE_RETENTION_DAYS: '1' 2022-05-25 12:55:17 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAXIMUM_WORKSPACE_RETENTION_DAYS: '60' 2022-05-25 12:55:17 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAXIMUM_WORKSPACE_SIZE_MB: '5000' 2022-05-25 12:55:18 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable DEPLOYMENT_MODE: 'OSS' 2022-05-25 12:55:18 INFO i.t.s.WorkflowServiceStubsImpl():184 - Created GRPC client for channel: ManagedChannelOrphanWrapper{delegate=ManagedChannelImpl{logId=1, target=airbyte-temporal:7233}} 2022-05-25 12:55:18 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):125 - Waiting for temporal server... 2022-05-25 12:55:18 WARN i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):130 - Waiting for default namespace to be initialized in temporal... 2022-05-25 12:55:25 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):144 - Found temporal default namespace! 2022-05-25 12:55:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable PUBLISH_METRICS: 'false' 2022-05-25 12:55:25 INFO i.a.s.a.SchedulerApp(main):275 - Launching scheduler... 2022-05-25 12:55:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SYNC_JOB_MAX_ATTEMPTS: '3' 2022-05-25 12:55:25 INFO i.a.s.a.SchedulerApp(start):143 - Start running the old scheduler 2022-05-26 12:53:57 INFO i.a.s.a.SchedulerApp(main):227 - temporalHost = airbyte-temporal:7233 2022-05-26 12:53:57 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:00 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:03 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:07 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:09 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:11 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:13 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:15 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:17 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:19 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:21 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:24 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:26 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:28 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:30 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:32 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:34 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:36 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:38 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:40 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:42 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:44 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:46 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:48 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:50 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:52 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:54 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:56 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_CPU_REQUEST: 'null' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_CPU_LIMIT: 'null' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_MEMORY_REQUEST: 'null' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_MEMORY_LIMIT: 'null' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_TOLERATIONS: '' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_NODE_SELECTORS: '' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_SECRET: '' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY: 'IfNotPresent' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_SOCAT_IMAGE: 'alpine/socat:1.7.4.1-r1' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_BUSYBOX_IMAGE: 'busybox:1.28' 2022-05-26 12:54:25 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_CURL_IMAGE: 'curlimages/curl:7.77.0' 2022-05-26 12:54:29 INFO i.a.w.WorkerApp(getJobProcessFactory):264 - Using Kubernetes namespace: apps 2022-05-26 12:54:32 INFO i.t.s.WorkflowServiceStubsImpl():184 - Created GRPC client for channel: ManagedChannelOrphanWrapper{delegate=ManagedChannelImpl{logId=1, target=airbyte-temporal:7233}} 2022-05-26 12:54:32 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):125 - Waiting for temporal server... 2022-05-26 12:54:32 WARN i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):130 - Waiting for default namespace to be initialized in temporal... 2022-05-26 12:54:39 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):144 - Found temporal default namespace! 2022-05-26 12:54:39 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_USER: 'airbyte' 2022-05-26 12:54:39 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_PASSWORD: '*****' 2022-05-26 12:54:39 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_URL: 'jdbc:postgresql://airbyte-postgresql:5432/db-airbyte' 2022-05-26 12:54:39 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available... 2022-05-26 12:54:39 INFO i.a.d.i.c.ConfigsDatabaseInstance(lambda$static$3):27 - Testing if airbyte_configs has been created and seeded... 2022-05-26 12:54:41 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available! 2022-05-26 12:54:41 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available! 2022-05-26 12:54:41 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-26 12:54:41 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-26 12:54:41 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available... 2022-05-26 12:54:41 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready... 2022-05-26 12:54:41 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available! 2022-05-26 12:54:41 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available! 2022-05-26 12:54:41 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable DEPLOYMENT_MODE: 'OSS' 2022-05-26 12:54:42 INFO i.t.s.WorkflowServiceStubsImpl():184 - Created GRPC client for channel: ManagedChannelOrphanWrapper{delegate=ManagedChannelImpl{logId=5, target=airbyte-temporal:7233}} 2022-05-26 12:54:42 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):125 - Waiting for temporal server... 2022-05-26 12:54:42 WARN i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):130 - Waiting for default namespace to be initialized in temporal... 2022-05-26 12:54:49 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):144 - Found temporal default namespace! 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_CPU_REQUEST: 'null' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_CPU_LIMIT: 'null' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_MEMORY_REQUEST: 'null' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_MAIN_CONTAINER_MEMORY_LIMIT: 'null' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_TOLERATIONS: '' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_NODE_SELECTORS: '' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_SECRET: '' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY: 'IfNotPresent' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_SOCAT_IMAGE: 'alpine/socat:1.7.4.1-r1' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_BUSYBOX_IMAGE: 'busybox:1.28' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable JOB_KUBE_CURL_IMAGE: 'curlimages/curl:7.77.0' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONTAINER_ORCHESTRATOR_ENABLED: 'false' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAX_SPEC_WORKERS: '5' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAX_CHECK_WORKERS: '5' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAX_DISCOVER_WORKERS: '5' 2022-05-26 12:54:49 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAX_SYNC_WORKERS: '5' 2022-05-26 12:54:49 INFO o.e.j.u.l.Log(initialized):169 - Logging initialized @27592ms to org.eclipse.jetty.util.log.Slf4jLog 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=2, pollThreadNamePrefix='Workflow Poller taskQueue="DISCOVER_SCHEMA", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=1, pollThreadNamePrefix='Local Activity Poller taskQueue="DISCOVER_SCHEMA", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Activity Poller taskQueue="DISCOVER_SCHEMA", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=2, pollThreadNamePrefix='Workflow Poller taskQueue="CONNECTION_UPDATER", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO o.e.j.s.Server(doStart):360 - jetty-9.4.31.v20200723; built: 2020-07-23T17:57:36.812Z; git: 450ba27947e13e66baa8cd1ce7e85a4461cacc1d; jvm 17.0.1+12-39 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=1, pollThreadNamePrefix='Local Activity Poller taskQueue="CONNECTION_UPDATER", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Activity Poller taskQueue="CONNECTION_UPDATER", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=2, pollThreadNamePrefix='Workflow Poller taskQueue="CHECK_CONNECTION", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=1, pollThreadNamePrefix='Local Activity Poller taskQueue="CHECK_CONNECTION", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Activity Poller taskQueue="CHECK_CONNECTION", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=2, pollThreadNamePrefix='Workflow Poller taskQueue="SYNC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=1, pollThreadNamePrefix='Local Activity Poller taskQueue="SYNC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Activity Poller taskQueue="SYNC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=2, pollThreadNamePrefix='Workflow Poller taskQueue="GET_SPEC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=1, pollThreadNamePrefix='Local Activity Poller taskQueue="GET_SPEC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Activity Poller taskQueue="GET_SPEC", namespace="default"'}, identity=1@airbyte-worker-76dd6c68f4-h6p7l} 2022-05-26 12:54:49 INFO o.e.j.s.h.ContextHandler(doStart):860 - Started o.e.j.s.ServletContextHandler@52b858c9{/,null,AVAILABLE} 2022-05-26 12:54:49 INFO i.t.i.w.Poller(start):95 - start(): Poller{options=PollerOptions{maximumPollRateIntervalMilliseconds=1000, maximumPollRatePerSecond=0.0, pollBackoffCoefficient=2.0, pollBackoffInitialInterval=PT0.1S, pollBackoffMaximumInterval=PT1M, pollThreadCount=5, pollThreadNamePrefix='Host Local Workflow Poller'}, identity=97516124-b015-4101-aba1-29b743753111} 2022-05-26 12:54:49 INFO o.e.j.s.AbstractConnector(doStart):331 - Started ServerConnector@6526d856{HTTP/1.1, (http/1.1)}{0.0.0.0:9000} 2022-05-26 12:54:49 INFO o.e.j.s.Server(doStart):400 - Started @27912ms 2022-05-26 12:54:58 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:00 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:02 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:04 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:06 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:08 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:10 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:12 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:14 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:16 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:18 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:20 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:22 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:24 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:26 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:28 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:30 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:32 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:34 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:36 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:38 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:40 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:42 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:44 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:46 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:48 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:50 INFO i.a.s.a.SchedulerApp(waitForServer):210 - Waiting for server to become available... 2022-05-26 12:55:52 INFO i.a.s.a.SchedulerApp(main):232 - Creating Job DB connection pool... 2022-05-26 12:55:53 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available... 2022-05-26 12:55:53 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready... 2022-05-26 12:55:54 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available! 2022-05-26 12:55:54 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available! 2022-05-26 12:55:54 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_USER: 'airbyte' 2022-05-26 12:55:54 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_PASSWORD: '*****' 2022-05-26 12:55:54 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable CONFIG_DATABASE_URL: 'jdbc:postgresql://airbyte-postgresql:5432/db-airbyte' 2022-05-26 12:55:54 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available... 2022-05-26 12:55:54 INFO i.a.d.i.c.ConfigsDatabaseInstance(lambda$static$3):27 - Testing if airbyte_configs has been created and seeded... 2022-05-26 12:55:54 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available! 2022-05-26 12:55:54 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available! 2022-05-26 12:55:54 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-26 12:55:54 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-26 12:55:54 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SECRET_PERSISTENCE: 'NONE' 2022-05-26 12:55:54 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MINIMUM_WORKSPACE_RETENTION_DAYS: '1' 2022-05-26 12:55:54 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAXIMUM_WORKSPACE_RETENTION_DAYS: '60' 2022-05-26 12:55:54 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable MAXIMUM_WORKSPACE_SIZE_MB: '5000' 2022-05-26 12:55:54 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable DEPLOYMENT_MODE: 'OSS' 2022-05-26 12:55:56 INFO i.t.s.WorkflowServiceStubsImpl():184 - Created GRPC client for channel: ManagedChannelOrphanWrapper{delegate=ManagedChannelImpl{logId=1, target=airbyte-temporal:7233}} 2022-05-26 12:55:56 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):125 - Waiting for temporal server... 2022-05-26 12:55:56 WARN i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):130 - Waiting for default namespace to be initialized in temporal... 2022-05-26 12:56:03 INFO i.a.w.t.TemporalUtils(waitForTemporalServerAndLog):144 - Found temporal default namespace! 2022-05-26 12:56:03 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable PUBLISH_METRICS: 'false' 2022-05-26 12:56:03 INFO i.a.s.a.SchedulerApp(main):275 - Launching scheduler... 2022-05-26 12:56:03 INFO i.a.c.EnvConfigs(getEnvOrDefault):596 - Using default value for environment variable SYNC_JOB_MAX_ATTEMPTS: '3' 2022-05-26 12:56:03 INFO i.a.s.a.SchedulerApp(start):143 - Start running the old scheduler