2022-07-15 03:19:20 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:19:20 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49584/0/logs.log 2022-07-15 03:19:20 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:19:20 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-check-49584-0-femuz for airbyte/source-postgres:0.4.18 2022-07-15 03:19:55 INFO i.a.w.p.KubeProcessFactory(create):103 - source-postgres-check-49584-0-femuz stdoutLocalPort = 9019 2022-07-15 03:20:42 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:20:27 INFO i.a.w.p.KubeProcessFactory(create):106 - source-postgres-check-49584-0-femuz stderrLocalPort = 9015 2022-07-15 03:20:27 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:20:27 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:20:27 INFO i.a.w.p.KubePodProcess():515 - Creating pod source-postgres-check-49584-0-femuz... 2022-07-15 03:20:27 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:20:27 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/85c48e22-4d02-449a-8b6b-ed5aabfc83f1/source_config.json datalake/source-postgres-check-49584-0-femuz:/config/source_config.json -c init 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/dc776d6e-b689-48f0-a6a6-6c68b605eb1c/FINISHED_UPLOADING datalake/source-postgres-check-49584-0-femuz:/config/FINISHED_UPLOADING -c init 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:20:29 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:20:29 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.5.35 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:30 INFO i.a.i.s.p.PostgresSource(main):409 - starting source: class io.airbyte.integrations.source.postgres.PostgresSource 2022-07-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:30 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-15 03:20:30 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:30 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-07-15 03:20: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-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:30 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-07-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:30 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:20: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-15 03:20:30 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:20:30 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20: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-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20: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-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20: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-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20: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-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:30 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-07-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:30 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-07-15 03:20:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:30 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-07-15 03:20:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:31 INFO i.a.i.s.p.PostgresSource(isCdc):258 - using CDC: false 2022-07-15 03:20:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20: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-15 03:20:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:31 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-07-15 03:20:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:31 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-07-15 03:20:31 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / source-postgres-check-49584-0-femuz) - Closed all resources for pod 2022-07-15 03:20:31 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:20:31 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49584/0/logs.log 2022-07-15 03:20:31 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:20:31 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-check-49584-0-clyke for airbyte/destination-snowflake:0.4.30 2022-07-15 03:20:31 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-check-49584-0-clyke stdoutLocalPort = 9019 2022-07-15 03:20:31 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-check-49584-0-clyke stderrLocalPort = 9015 2022-07-15 03:20:31 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:20:31 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:20:31 INFO i.a.w.p.KubePodProcess():515 - Creating pod destination-snowflake-check-49584-0-clyke... 2022-07-15 03:20:31 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:20:31 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/02a76de3-9620-4c4e-8551-4cd90a65b9ac/source_config.json datalake/destination-snowflake-check-49584-0-clyke:/config/source_config.json -c init 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/43065016-3a94-476b-9525-8655f2cde2bc/FINISHED_UPLOADING datalake/destination-snowflake-check-49584-0-clyke:/config/FINISHED_UPLOADING -c init 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:33 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:20:33 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:20:34 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:20:34 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:20:34 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.6.158 2022-07-15 03:20:34 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:20:34 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:20:34 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:20:34 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:20:34 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:20:34 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:20:34 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:20:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:34 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-15 03:20:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:34 INFO i.a.i.b.IntegrationRunner(createSentryTransaction):351 - Sentry transaction event: 52300319c6524b1c89049d3a7a92e41b 2022-07-15 03:20:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:34 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-07-15 03:20:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:34 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-07-15 03:20:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:34 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:20:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:35 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:20:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:35 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:20:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:35 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:20:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:35 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:20:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:35 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2022-07-15 03:20:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:35 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:20:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:35 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-07-15 03:20:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:36 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@3f362135 2022-07-15 03:20:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:36 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-07-15 03:20:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:36 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2022-07-15 03:20:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:36 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-07-15 03:20:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:36 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / destination-snowflake-check-49584-0-clyke) - Closed all resources for pod 2022-07-15 03:20:38 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:20:39 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49584/0/logs.log 2022-07-15 03:20:39 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:20:39 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 49584 attempt id: 0 2022-07-15 03:20:39 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {public.product=incremental - append_dedup} 2022-07-15 03:20:39 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-07-15 03:20:39 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-write-49584-0-qenor for airbyte/destination-snowflake:0.4.30 2022-07-15 03:20:39 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-write-49584-0-qenor stdoutLocalPort = 9019 2022-07-15 03:20:39 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-write-49584-0-qenor stderrLocalPort = 9015 2022-07-15 03:20:39 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:20:39 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:20:39 INFO i.a.w.p.KubePodProcess():515 - Creating pod destination-snowflake-write-49584-0-qenor... 2022-07-15 03:20:39 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:20:39 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/f4c45c83-da36-4b52-9ed2-78b617edab89/destination_config.json datalake/destination-snowflake-write-49584-0-qenor:/config/destination_config.json -c init 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/426a85ff-2c2b-43b5-9a25-ed28e819de73/destination_catalog.json datalake/destination-snowflake-write-49584-0-qenor:/config/destination_catalog.json -c init 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/825968bc-ada9-4bea-8039-8047b1281c43/FINISHED_UPLOADING datalake/destination-snowflake-write-49584-0-qenor:/config/FINISHED_UPLOADING -c init 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:41 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:41 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:20:41 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:20:41 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:20:42 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:20:42 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.4.217 2022-07-15 03:20:42 INFO i.a.w.p.KubePodProcess():570 - Creating stdin socket... 2022-07-15 03:20:42 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-read-49584-0-qmsje for airbyte/source-postgres:0.4.18 2022-07-15 03:21:09 INFO i.a.w.p.KubeProcessFactory(create):103 - source-postgres-read-49584-0-qmsje stdoutLocalPort = 9009 2022-07-15 03:20:42 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:20:42 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-15 03:20:42 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-15 03:20:42 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-07-15 03:20:42 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:31:13 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / destination-snowflake-write-49584-0-qenor) - Closed all resources for pod 2022-07-15 03:31:13 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:105) ~[io.airbyte-airbyte-workers-0.39.17-alpha.jar:?] ... 6 more 2022-07-15 03:31:13 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6e795570[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657855239119,endTime=1657855873962,totalStats=io.airbyte.config.SyncStats@391fc89c[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]] 2022-07-15 03:31:13 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages 2022-07-15 03:31:13 WARN i.a.w.g.DefaultReplicationWorker(run):276 - State capture: No new state, falling back on input state: io.airbyte.config.State@44bafe34[state={"cdc":false,"streams":[{"cursor":"2022-07-15T02:20:05.316333Z","stream_name":"product","cursor_field":["updated_at"],"stream_namespace":"public"}]}] 2022-07-15 03:31:13 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:31:13 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@30bb9df7[standardSyncSummary=io.airbyte.config.StandardSyncSummary@7871575a[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657855239119,endTime=1657855873962,totalStats=io.airbyte.config.SyncStats@391fc89c[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=,state=io.airbyte.config.State@44bafe34[state={"cdc":false,"streams":[{"cursor":"2022-07-15T02:20:05.316333Z","stream_name":"product","cursor_field":["updated_at"],"stream_namespace":"public"}]}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@10e1f2ef[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@1e512161[stream=io.airbyte.protocol.models.AirbyteStream@72694379[name=product,jsonSchema={"type":"object","properties":{"mpn":{"type":"string"},"sku":{"type":"string"},"ihs_id":{"type":"number"},"hidden_at":{"type":"string"},"created_at":{"type":"string"},"indexed_at":{"type":"string"},"updated_at":{"type":"string"},"ihs_category":{"type":"string"},"last_ihs_update":{"type":"string"},"ihs_category_type":{"type":"string"},"manufacturer_name":{"type":"string"},"indexed_updated_at":{"type":"string"},"last_index_checksum":{"type":"string"},"last_ihs_update_check":{"type":"string"},"last_ihs_parameters_update":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[sku]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[updated_at],destinationSyncMode=append_dedup,primaryKey=[[sku]],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-07-15 03:31:13 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-07-15 03:31:14 INFO i.a.c.p.ConfigRepository(updateConnectionState):775 - Updating connection eeea4753-643a-42d1-abcf-e59deeaac56e state: io.airbyte.config.State@34774520[state={"cdc":false,"streams":[{"cursor":"2022-07-15T02:20:05.316333Z","stream_name":"product","cursor_field":["updated_at"],"stream_namespace":"public"}]}] 2022-07-15 03:31:14 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49584/0/logs.log 2022-07-15 03:31:14 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:31:14 INFO i.a.w.g.DefaultNormalizationWorker(run):49 - Running normalization. 2022-07-15 03:31:14 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.2.1 2022-07-15 03:31:14 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = normalization-snowflake-normalize-49584-0-hqalt for airbyte/normalization-snowflake:0.2.1 2022-07-15 03:31:14 INFO i.a.c.p.ConfigRepository(updateConnectionState):775 - Updating connection 61d0b50f-9c40-48da-b72b-995453f68898 state: io.airbyte.config.State@1e0e3629[state={"cdc":false,"streams":[{"cursor":"391875653","stream_name":"import_row_issue","cursor_field":["id"],"stream_namespace":"public"}]}] 2022-07-15 03:31:19 INFO i.a.w.p.KubeProcessFactory(create):103 - normalization-snowflake-normalize-49584-0-hqalt stdoutLocalPort = 9019 2022-07-15 03:31:36 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /config 2022-07-15 03:31:36 normalization > Namespace(config='destination_config.json', integration_type=, out='/config') 2022-07-15 03:31:36 normalization > transform_snowflake 2022-07-15 03:31:36 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /config --catalog destination_catalog.json --out /config/models/generated/ --json-column _airbyte_data 2022-07-15 03:31:36 normalization > Processing destination_catalog.json... 2022-07-15 03:31:36 normalization > Generating airbyte_ctes/PROD/PRODUCT_AB1.sql from product 2022-07-15 03:31:36 normalization > Generating airbyte_ctes/PROD/PRODUCT_AB2.sql from product 2022-07-15 03:31:36 normalization > Generating airbyte_views/PROD/PRODUCT_STG.sql from product 2022-07-15 03:31:36 normalization > Generating airbyte_incremental/scd/PROD/PRODUCT_SCD.sql from product 2022-07-15 03:31:36 normalization > Generating airbyte_incremental/PROD/PRODUCT.sql from product 2022-07-15 03:31:36 normalization > detected no config file for ssh, assuming ssh is off. 2022-07-15 03:31:38 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-07-15 03:31:38 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-07-15 03:31:38 normalization > 2022-07-15 03:31:38 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-07-15 03:31:38 normalization > 2022-07-15 03:31:40 normalization > 03:31:40 Running with dbt=1.0.0 2022-07-15 03:31:40 normalization > 03:31:40 Partial parse save file not found. Starting full parse. 2022-07-15 03:31:41 normalization > 03:31:41 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-07-15 03:31:41 normalization > There are 1 unused configuration paths: 2022-07-15 03:31:41 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-07-15 03:31:41 normalization > 2022-07-15 03:31:41 normalization > 03:31:41 Found 5 models, 0 tests, 0 snapshots, 0 analyses, 535 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics 2022-07-15 03:31:41 normalization > 03:31:41 2022-07-15 03:31:32 INFO i.a.w.p.KubeProcessFactory(create):106 - normalization-snowflake-normalize-49584-0-hqalt stderrLocalPort = 9026 2022-07-15 03:31:32 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:31:32 INFO i.a.w.p.KubePodProcess():515 - Creating pod normalization-snowflake-normalize-49584-0-hqalt... 2022-07-15 03:31:32 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:31:33 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:31:33 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:31:34 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:31:34 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:31:34 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-07-15 03:31:34 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/07101027-3c28-43ed-9554-3362d2520bba/destination_config.json datalake/normalization-snowflake-normalize-49584-0-hqalt:/config/destination_config.json -c init 2022-07-15 03:31:34 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:31:34 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:31:34 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-07-15 03:31:34 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/9534b4bf-6aec-46e4-a524-fde6a7172e8d/destination_catalog.json datalake/normalization-snowflake-normalize-49584-0-hqalt:/config/destination_catalog.json -c init 2022-07-15 03:31:34 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:31:35 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:31:35 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:31:35 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/76353f8e-b0ed-467d-803c-f007ba1e8476/FINISHED_UPLOADING datalake/normalization-snowflake-normalize-49584-0-hqalt:/config/FINISHED_UPLOADING -c init 2022-07-15 03:31:35 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:31:35 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:31:35 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:31:35 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:31:35 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:31:36 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:31:36 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.6.210 2022-07-15 03:31:36 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:31:43 normalization > 03:31:43 Concurrency: 5 threads (target='prod') 2022-07-15 03:31:43 normalization > 03:31:43 2022-07-15 03:31:43 normalization > 03:31:43 1 of 3 START view model _AIRBYTE_PROD.PRODUCT_STG....................................................................... [RUN] 2022-07-15 03:31:44 normalization > 03:31:44 1 of 3 OK created view model _AIRBYTE_PROD.PRODUCT_STG.................................................................. [SUCCESS 1 in 1.01s] 2022-07-15 03:31:44 normalization > 03:31:44 2 of 3 START incremental model PROD.PRODUCT_SCD......................................................................... [RUN] 2022-07-15 03:32:21 normalization > 03:32:21 2 of 3 OK created incremental model PROD.PRODUCT_SCD.................................................................... [SUCCESS 1 in 37.17s] 2022-07-15 03:32:21 normalization > 03:32:21 3 of 3 START incremental model PROD.PRODUCT............................................................................. [RUN] 2022-07-15 03:33:11 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / normalization-snowflake-normalize-49584-0-hqalt) - Closed all resources for pod 2022-07-15 03:33:11 INFO i.a.w.g.DefaultNormalizationWorker(run):73 - Normalization executed in 1 minute 57 seconds. 2022-07-15 03:33:11 INFO i.a.w.g.DefaultNormalizationWorker(run):79 - Normalization summary: io.airbyte.config.NormalizationSummary@5294c317[startTime=1657855874113,endTime=1657855991769] 2022-07-15 03:33:11 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:33:11 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-07-15 03:33:10 normalization > 03:33:10 3 of 3 OK created incremental model PROD.PRODUCT........................................................................ [SUCCESS 1 in 49.54s] 2022-07-15 03:33:10 normalization > 03:33:10 2022-07-15 03:33:10 normalization > 03:33:10 Finished running 1 view model, 2 incremental models in 89.51s. 2022-07-15 03:33:10 normalization > 03:33:10 2022-07-15 03:33:10 normalization > 03:33:10 Completed successfully 2022-07-15 03:33:10 normalization > 03:33:10 2022-07-15 03:33:10 normalization > 03:33:10 Done. PASS=3 WARN=0 ERROR=0 SKIP=0 TOTAL=3 2022-07-15 03:33:12 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:33:12 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49584/1/logs.log 2022-07-15 03:33:12 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:33:12 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-check-49584-1-ouamb for airbyte/source-postgres:0.4.18 2022-07-15 03:38:22 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):194 - Running sync worker cancellation... 2022-07-15 03:38:22 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Interrupting worker thread... 2022-07-15 03:38:22 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):201 - Cancelling completable future... 2022-07-15 03:38:22 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-07-15 03:38:22 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:38:22 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=7da2e4f3-9686-3813-a630-6f9463837201, 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:38:22 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