2022-07-01 16:15:27 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.method: does not have a value in the enumeration [Standard] 2022-07-01 16:15:27 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/41966/0/logs.log 2022-07-01 16:15:27 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-01 16:15:27 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-check-41966-0-jvdys for airbyte/source-postgres:0.4.18 2022-07-01 16:15:27 INFO i.a.w.p.KubeProcessFactory(create):103 - source-postgres-check-41966-0-jvdys stdoutLocalPort = 9008 2022-07-01 16:15:27 INFO i.a.w.p.KubeProcessFactory(create):106 - source-postgres-check-41966-0-jvdys stderrLocalPort = 9009 2022-07-01 16:15:27 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-01 16:15:27 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-01 16:15:27 INFO i.a.w.p.KubePodProcess():515 - Creating pod source-postgres-check-41966-0-jvdys... 2022-07-01 16:15:27 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-01 16:15:27 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/4c6c1d17-3350-4cfb-964c-c71ebfa10cfe/source_config.json datalake/source-postgres-check-41966-0-jvdys:/config/source_config.json -c init 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/a7456160-874d-456b-acba-41f29311d4cd/FINISHED_UPLOADING datalake/source-postgres-check-41966-0-jvdys:/config/FINISHED_UPLOADING -c init 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-01 16:15:28 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-01 16:15:29 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-01 16:15:29 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-01 16:15:30 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-01 16:15:30 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.9.217 2022-07-01 16:15:30 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 INFO i.a.i.s.p.PostgresSource(main):409 - starting source: class io.airbyte.integrations.source.postgres.PostgresSource 2022-07-01 16:15:30 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-01 16:15:30 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-07-01 16:15:30 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-07-01 16:15:30 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-07-01 16:15:30 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-07-01 16:15:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:30 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-07-01 16:15:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:31 INFO i.a.i.s.p.PostgresSource(isCdc):258 - using CDC: false 2022-07-01 16:15:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$getCheckOperations$1):93 - Attempting to get metadata from the database to see if we can connect. 2022-07-01 16:15:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:31 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-07-01 16:15:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-01 16:15:31 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-07-01 16:15:31 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / source-postgres-check-41966-0-jvdys) - Closed all resources for pod 2022-07-01 16:15:31 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-01 16:15:31 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/41966/0/logs.log 2022-07-01 16:15:31 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-01 16:15:31 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-check-41966-0-bphsi for airbyte/destination-snowflake:0.4.30 2022-07-01 16:15:31 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-check-41966-0-bphsi stdoutLocalPort = 9032 2022-07-01 16:15:31 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-check-41966-0-bphsi stderrLocalPort = 9033 2022-07-01 16:15:31 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-01 16:15:31 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-01 16:15:31 INFO i.a.w.p.KubePodProcess():515 - Creating pod destination-snowflake-check-41966-0-bphsi... 2022-07-01 16:15:31 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-01 16:20:31 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):161 - Completing future exceptionally... io.airbyte.workers.exception.WorkerException: Error while getting checking connection. at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:86) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:29) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.exception.WorkerException: Timed out waiting for [300000] milliseconds for [Pod] with name:[destination-snowflake-check-41966-0-bphsi] in namespace [datalake]. at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:138) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:80) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:55) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 3 more Caused by: io.fabric8.kubernetes.client.KubernetesClientTimeoutException: Timed out waiting for [300000] milliseconds for [Pod] with name:[destination-snowflake-check-41966-0-bphsi] in namespace [datalake]. at io.fabric8.kubernetes.client.dsl.base.BaseOperation.waitUntilCondition(BaseOperation.java:860) ~[kubernetes-client-5.12.2.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.waitUntilCondition(BaseOperation.java:83) ~[kubernetes-client-5.12.2.jar:?] at io.airbyte.workers.process.KubePodProcess.waitForInitPodToRun(KubePodProcess.java:308) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.process.KubePodProcess.(KubePodProcess.java:544) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:134) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:80) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:55) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 3 more 2022-07-01 16:20:31 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-01 16:20:31 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=ec922b0d-7c04-3761-a29c-eccda901a823, activityType=Run, attempt=1 java.util.concurrent.ExecutionException: io.airbyte.workers.exception.WorkerException: Error while getting checking connection. at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:132) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.check.connection.CheckConnectionActivityImpl.run(CheckConnectionActivityImpl.java:76) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at jdk.internal.reflect.GeneratedMethodAccessor607.invoke(Unknown Source) ~[?:?] at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.exception.WorkerException: Error while getting checking connection. at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:86) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:29) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 1 more Caused by: io.airbyte.workers.exception.WorkerException: Timed out waiting for [300000] milliseconds for [Pod] with name:[destination-snowflake-check-41966-0-bphsi] in namespace [datalake]. at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:138) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:80) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:55) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:29) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 1 more Caused by: io.fabric8.kubernetes.client.KubernetesClientTimeoutException: Timed out waiting for [300000] milliseconds for [Pod] with name:[destination-snowflake-check-41966-0-bphsi] in namespace [datalake]. at io.fabric8.kubernetes.client.dsl.base.BaseOperation.waitUntilCondition(BaseOperation.java:860) ~[kubernetes-client-5.12.2.jar:?] at io.fabric8.kubernetes.client.dsl.base.BaseOperation.waitUntilCondition(BaseOperation.java:83) ~[kubernetes-client-5.12.2.jar:?] at io.airbyte.workers.process.KubePodProcess.waitForInitPodToRun(KubePodProcess.java:308) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.process.KubePodProcess.(KubePodProcess.java:544) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:134) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.process.AirbyteIntegrationLauncher.check(AirbyteIntegrationLauncher.java:80) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:55) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:29) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 1 more