2022-07-15 03:26:26 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-15 03:26:26 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49590/0/logs.log 2022-07-15 03:26:26 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:26:26 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-check-49590-0-clteb for airbyte/source-postgres:0.4.18 2022-07-15 03:31:14 INFO i.a.w.p.KubeProcessFactory(create):103 - source-postgres-check-49590-0-clteb stdoutLocalPort = 9008 2022-07-15 03:31:14 INFO i.a.w.p.KubeProcessFactory(create):106 - source-postgres-check-49590-0-clteb stderrLocalPort = 9014 2022-07-15 03:31:14 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:31:14 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:31:14 INFO i.a.w.p.KubePodProcess():515 - Creating pod source-postgres-check-49590-0-clteb... 2022-07-15 03:31:14 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:31:14 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/49ab4d7d-586e-4538-9119-8d571159c008/source_config.json datalake/source-postgres-check-49590-0-clteb:/config/source_config.json -c init 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/9e73ede5-42b1-4696-b2a8-b2d8b8b5fa7b/FINISHED_UPLOADING datalake/source-postgres-check-49590-0-clteb:/config/FINISHED_UPLOADING -c init 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:31:15 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:31:16 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:31:16 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:31:17 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:31:17 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.10.51 2022-07-15 03:31:17 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:31:17 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:31:17 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-15 03:31:17 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-15 03:31:17 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-07-15 03:31:17 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 INFO i.a.i.s.p.PostgresSource(main):409 - starting source: class io.airbyte.integrations.source.postgres.PostgresSource 2022-07-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-07-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-07-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-07-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 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-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 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-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 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-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 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-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-07-15 03:31:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:17 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-07-15 03:31:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:18 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-07-15 03:31:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:18 INFO i.a.i.s.p.PostgresSource(isCdc):258 - using CDC: false 2022-07-15 03:31:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:18 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-15 03:31:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:18 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-07-15 03:31:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:18 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-07-15 03:31:18 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / source-postgres-check-49590-0-clteb) - Closed all resources for pod 2022-07-15 03:31:18 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:31:18 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49590/0/logs.log 2022-07-15 03:31:18 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:31:18 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-check-49590-0-vipkk for airbyte/destination-snowflake:0.4.30 2022-07-15 03:31:28 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-check-49590-0-vipkk stdoutLocalPort = 9008 2022-07-15 03:32:20 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-check-49590-0-vipkk stderrLocalPort = 9028 2022-07-15 03:32:20 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:32:20 INFO i.a.w.p.KubePodProcess():515 - Creating pod destination-snowflake-check-49590-0-vipkk... 2022-07-15 03:32:20 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:32:20 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:32:20 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:32:21 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:32:21 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:32:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-07-15 03:32:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/aceeebf0-ee11-4bfc-a9ce-b720328e5f67/source_config.json datalake/destination-snowflake-check-49590-0-vipkk:/config/source_config.json -c init 2022-07-15 03:32:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:32:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:32:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:32:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/2c6d94f9-8e57-4f20-8b8d-2f9fa25c429e/FINISHED_UPLOADING datalake/destination-snowflake-check-49590-0-vipkk:/config/FINISHED_UPLOADING -c init 2022-07-15 03:32:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:32:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:32:22 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:32:23 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:32:23 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:32:23 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:32:23 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.7.161 2022-07-15 03:32:23 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:32:23 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:23 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-15 03:32:23 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:32:23 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-15 03:32:23 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-15 03:32:23 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-15 03:32:23 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-07-15 03:32:23 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 INFO i.a.i.b.IntegrationRunner(createSentryTransaction):351 - Sentry transaction event: 33627db384614972815a4cc326c6e61d 2022-07-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-07-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-07-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-07-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 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-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 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-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 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-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 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-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2022-07-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 WARN i.a.i.d.s.SnowflakeDatabase(createDataSource):96 - Obsolete User/password login mode is used. Please re-create a connection to use the latest connector's version 2022-07-15 03:32:24 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:24 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-07-15 03:32:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:25 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@3f362135 2022-07-15 03:32:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:25 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-07-15 03:32:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:25 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2022-07-15 03:32:25 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:25 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-07-15 03:32:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:26 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-07-15 03:32:56 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:32:28 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / destination-snowflake-check-49590-0-vipkk) - Closed all resources for pod 2022-07-15 03:32:28 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:32:28 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49590/0/logs.log 2022-07-15 03:32:28 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:32:28 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 49590 attempt id: 0 2022-07-15 03:32:28 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {public.offer_sourced=incremental - append_dedup} 2022-07-15 03:32:28 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-07-15 03:32:28 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-write-49590-0-mdcrt for airbyte/destination-snowflake:0.4.30 2022-07-15 03:32:51 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-write-49590-0-mdcrt stdoutLocalPort = 9008 2022-07-15 03:32:53 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-write-49590-0-mdcrt stderrLocalPort = 9015 2022-07-15 03:32:53 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:32:53 INFO i.a.w.p.KubePodProcess():515 - Creating pod destination-snowflake-write-49590-0-mdcrt... 2022-07-15 03:32:53 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:32:53 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:32:53 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:32:54 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:32:54 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:32:54 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-07-15 03:32:54 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/ddbefca2-7ebd-46b3-b61e-a3d00bfdf0c0/destination_config.json datalake/destination-snowflake-write-49590-0-mdcrt:/config/destination_config.json -c init 2022-07-15 03:32:54 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:32:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:32:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-07-15 03:32:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/a42934b0-8d73-44ac-a29b-1e9be15f8c30/destination_catalog.json datalake/destination-snowflake-write-49590-0-mdcrt:/config/destination_catalog.json -c init 2022-07-15 03:32:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:32:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:32:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:32:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/aaee0db7-3eab-48e2-9fb4-21963d02e453/FINISHED_UPLOADING datalake/destination-snowflake-write-49590-0-mdcrt:/config/FINISHED_UPLOADING -c init 2022-07-15 03:32:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:32:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:32:55 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:32:56 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:32:56 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:32:56 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:32:56 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.10.149 2022-07-15 03:32:56 INFO i.a.w.p.KubePodProcess():570 - Creating stdin socket... 2022-07-15 03:32:56 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-read-49590-0-hyhha for airbyte/source-postgres:0.4.18 2022-07-15 03:32:56 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-15 03:32:56 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-15 03:32:56 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-15 03:32:56 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-07-15 03:32:56 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:43:00 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / destination-snowflake-write-49590-0-mdcrt) - Closed all resources for pod 2022-07-15 03:43:00 ERROR i.a.w.g.DefaultReplicationWorker(run):180 - Sync worker failed. io.airbyte.workers.exception.WorkerException: Cannot invoke "java.lang.Integer.intValue()" because the return value of "io.airbyte.workers.process.KubePortManagerSingleton.take()" is null 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.read(AirbyteIntegrationLauncher.java:142) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.internal.DefaultAirbyteSource.start(DefaultAirbyteSource.java:72) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:139) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[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: java.lang.NullPointerException: Cannot invoke "java.lang.Integer.intValue()" because the return value of "io.airbyte.workers.process.KubePortManagerSingleton.take()" is null at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:102) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 6 more 2022-07-15 03:43:00 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@777f25c3[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657855948310,endTime=1657856580995,totalStats=io.airbyte.config.SyncStats@307578ae[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]] 2022-07-15 03:43:00 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages 2022-07-15 03:43:00 WARN i.a.w.g.DefaultReplicationWorker(run):276 - State capture: No new state, falling back on input state: io.airbyte.config.State@b8b4ce2[state={"cdc":false,"streams":[{"cursor":"11468686913","stream_name":"offer_sourced","cursor_field":["id"],"stream_namespace":"public"}]}] 2022-07-15 03:43:00 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:43:00 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@1b487f92[standardSyncSummary=io.airbyte.config.StandardSyncSummary@5d442fa1[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657855948310,endTime=1657856580995,totalStats=io.airbyte.config.SyncStats@307578ae[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=,state=io.airbyte.config.State@b8b4ce2[state={"cdc":false,"streams":[{"cursor":"11468686913","stream_name":"offer_sourced","cursor_field":["id"],"stream_namespace":"public"}]}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@fb54445[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@2a719505[stream=io.airbyte.protocol.models.AirbyteStream@729dcb36[name=offer_sourced,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"import_row_id":{"type":"number"},"price_multiplier":{"type":"number"},"account_platform_id":{"type":"string"},"referenced_offer_id":{"type":"number"},"needed_existing_data":{"type":"boolean"},"expiration_updated_at":{"type":"string"},"import_session_offer_id":{"type":"number"},"expiration_update_checked_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[id],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-07-15 03:43:00 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-07-15 03:43:01 INFO i.a.c.p.ConfigRepository(updateConnectionState):775 - Updating connection 3d077c97-b1a1-462b-8166-3ed9c96d3b83 state: io.airbyte.config.State@4ae9f7d[state={"cdc":false,"streams":[{"cursor":"11468686913","stream_name":"offer_sourced","cursor_field":["id"],"stream_namespace":"public"}]}] 2022-07-15 03:43:01 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49590/0/logs.log 2022-07-15 03:43:01 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:43:01 INFO i.a.w.g.DefaultNormalizationWorker(run):49 - Running normalization. 2022-07-15 03:43:01 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.2.1 2022-07-15 03:43:01 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = normalization-snowflake-normalize-49590-0-muwbg for airbyte/normalization-snowflake:0.2.1 2022-07-15 03:53:01 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):161 - Completing future exceptionally... io.airbyte.workers.exception.WorkerException: Normalization Failed. at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:63) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:21) ~[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: Cannot invoke "java.lang.Integer.intValue()" because the return value of "io.airbyte.workers.process.KubePortManagerSingleton.take()" is null at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:138) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.normalization.DefaultNormalizationRunner.runProcess(DefaultNormalizationRunner.java:123) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.normalization.DefaultNormalizationRunner.normalize(DefaultNormalizationRunner.java:108) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:58) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 3 more Caused by: java.lang.NullPointerException: Cannot invoke "java.lang.Integer.intValue()" because the return value of "io.airbyte.workers.process.KubePortManagerSingleton.take()" is null at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:102) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.normalization.DefaultNormalizationRunner.runProcess(DefaultNormalizationRunner.java:123) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.normalization.DefaultNormalizationRunner.normalize(DefaultNormalizationRunner.java:108) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:58) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 3 more 2022-07-15 03:53:01 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:53:01 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-07-15 03:53:01 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=ee9d703c-b925-33dd-94f4-b33b1036c111, activityType=Normalize, attempt=1 java.lang.RuntimeException: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.exception.WorkerException: Normalization Failed. at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:234) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:75) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at jdk.internal.reflect.GeneratedMethodAccessor687.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.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.exception.WorkerException: Normalization Failed. at io.temporal.serviceclient.CheckedExceptionWrapper.wrap(CheckedExceptionWrapper.java:56) ~[temporal-serviceclient-1.8.1.jar:?] at io.temporal.internal.sync.WorkflowInternal.wrap(WorkflowInternal.java:448) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.activity.Activity.wrap(Activity.java:51) ~[temporal-sdk-1.8.1.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:138) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$3(NormalizationActivityImpl.java:103) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:229) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 13 more Caused by: java.util.concurrent.ExecutionException: io.airbyte.workers.exception.WorkerException: Normalization Failed. 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.sync.NormalizationActivityImpl.lambda$normalize$3(NormalizationActivityImpl.java:103) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:229) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 13 more Caused by: io.airbyte.workers.exception.WorkerException: Normalization Failed. at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:63) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:21) ~[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: Cannot invoke "java.lang.Integer.intValue()" because the return value of "io.airbyte.workers.process.KubePortManagerSingleton.take()" is null at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:138) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.normalization.DefaultNormalizationRunner.runProcess(DefaultNormalizationRunner.java:123) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.normalization.DefaultNormalizationRunner.normalize(DefaultNormalizationRunner.java:108) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:58) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:21) ~[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: java.lang.NullPointerException: Cannot invoke "java.lang.Integer.intValue()" because the return value of "io.airbyte.workers.process.KubePortManagerSingleton.take()" is null at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:102) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.normalization.DefaultNormalizationRunner.runProcess(DefaultNormalizationRunner.java:123) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.normalization.DefaultNormalizationRunner.normalize(DefaultNormalizationRunner.java:108) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:58) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:21) ~[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 2022-07-15 03:53:01 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-15 03:53:01 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49590/1/logs.log 2022-07-15 03:53:01 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:53:01 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-check-49590-1-kjeta for airbyte/source-postgres:0.4.18 2022-07-15 03:58:11 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):194 - Running sync worker cancellation... 2022-07-15 03:58:11 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Interrupting worker thread... 2022-07-15 03:58:11 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):201 - Cancelling completable future... 2022-07-15 03:58:11 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-07-15 03:58:11 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:58:11 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=c0a6c46d-7a94-3d92-9a1a-1aaccdfa2dd4, activityType=Run, attempt=1 java.util.concurrent.CancellationException: null at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2478) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:207) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?] 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:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] 2022-07-15 03:58:11 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 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: java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1679) ~[?:?] at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:515) ~[?:?] at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:677) ~[?:?] at io.airbyte.workers.process.KubePortManagerSingleton.take(KubePortManagerSingleton.java:67) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:102) ~[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