2022-07-15 03:29:29 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:29:29 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49591/0/logs.log 2022-07-15 03:29:29 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:29:29 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-check-49591-0-jiwtd for airbyte/source-postgres:0.4.18 2022-07-15 03:31:19 INFO i.a.w.p.KubeProcessFactory(create):103 - source-postgres-check-49591-0-jiwtd stdoutLocalPort = 9026 2022-07-15 03:31:28 INFO i.a.w.p.KubeProcessFactory(create):106 - source-postgres-check-49591-0-jiwtd stderrLocalPort = 9012 2022-07-15 03:31:28 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:31:28 INFO i.a.w.p.KubePodProcess():515 - Creating pod source-postgres-check-49591-0-jiwtd... 2022-07-15 03:31:28 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:31:28 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:31:28 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:31:29 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:31:29 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:31:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-07-15 03:31:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/ed52b2b2-f72a-4fff-b305-4f29d37a42f9/source_config.json datalake/source-postgres-check-49591-0-jiwtd:/config/source_config.json -c init 2022-07-15 03:31:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:31:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:31:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:31:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/b00476cc-bed9-4dff-bba4-266af946ae5f/FINISHED_UPLOADING datalake/source-postgres-check-49591-0-jiwtd:/config/FINISHED_UPLOADING -c init 2022-07-15 03:31:29 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:31:30 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:31:30 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:31:30 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:31:30 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:31:31 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:31:31 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.7.68 2022-07-15 03:31:31 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:31:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 INFO i.a.i.s.p.PostgresSource(main):409 - starting source: class io.airbyte.integrations.source.postgres.PostgresSource 2022-07-15 03:31:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:31:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-15 03:31:31 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:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-07-15 03:31:31 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:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-07-15 03:31:31 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:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 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:31 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:31:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 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:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 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:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 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:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 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:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-07-15 03:31:31 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:31 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-07-15 03:31:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:32 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-07-15 03:31:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:32 INFO i.a.i.s.p.PostgresSource(isCdc):258 - using CDC: false 2022-07-15 03:31:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:32 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:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:32 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-07-15 03:31:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:31:32 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-07-15 03:31:32 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / source-postgres-check-49591-0-jiwtd) - Closed all resources for pod 2022-07-15 03:31:32 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:31:32 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49591/0/logs.log 2022-07-15 03:31:32 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:31:32 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-check-49591-0-leryq for airbyte/destination-snowflake:0.4.30 2022-07-15 03:32:28 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-check-49591-0-leryq stdoutLocalPort = 9028 2022-07-15 03:32:46 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-check-49591-0-leryq stderrLocalPort = 9015 2022-07-15 03:32:46 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:32:46 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:32:46 INFO i.a.w.p.KubePodProcess():515 - Creating pod destination-snowflake-check-49591-0-leryq... 2022-07-15 03:32:46 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:32:46 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/474f3770-71b7-456a-8843-8645ca1056a4/source_config.json datalake/destination-snowflake-check-49591-0-leryq:/config/source_config.json -c init 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/6e6aa15f-e97d-4e17-a735-d50264f877b1/FINISHED_UPLOADING datalake/destination-snowflake-check-49591-0-leryq:/config/FINISHED_UPLOADING -c init 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:32:47 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:32:48 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:32:48 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:32:49 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:32:49 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.11.40 2022-07-15 03:32:49 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:32:49 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:32:49 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:49 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:49 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:49 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:49 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:32:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:49 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-15 03:32:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 INFO i.a.i.b.IntegrationRunner(createSentryTransaction):351 - Sentry transaction event: a3cc6780059840aebabe409fe2db4890 2022-07-15 03:32:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-07-15 03:32:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-07-15 03:32:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 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:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 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:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 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:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 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:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 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:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2022-07-15 03:32:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 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:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:50 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-07-15 03:32:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:51 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@d08edc5 2022-07-15 03:32:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:51 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-07-15 03:32:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:51 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2022-07-15 03:32:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:52 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-07-15 03:32:52 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:52 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-07-15 03:32:53 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / destination-snowflake-check-49591-0-leryq) - Closed all resources for pod 2022-07-15 03:32:53 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:32:53 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49591/0/logs.log 2022-07-15 03:32:53 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:32:54 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 49591 attempt id: 0 2022-07-15 03:32:54 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {public.spy_cms_block_category_connector=full_refresh - overwrite, public.spy_cms_block=full_refresh - overwrite, public.spy_cms_block_store=full_refresh - overwrite, public.spy_cms_page=full_refresh - overwrite, public.spy_cms_block_glossary_key_mapping=full_refresh - overwrite, public.spy_category_template=full_refresh - overwrite, public.spy_cms_glossary_key_mapping=full_refresh - overwrite, public.spy_cms_block_category_position=full_refresh - overwrite, public.spy_cms_block_template=full_refresh - overwrite, public.spy_cms_page_localized_attributes=full_refresh - overwrite} 2022-07-15 03:32:54 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-07-15 03:32:54 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-write-49591-0-omgox for airbyte/destination-snowflake:0.4.30 2022-07-15 03:33:19 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-write-49591-0-omgox stdoutLocalPort = 9019 2022-07-15 03:43:04 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:43:00 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-write-49591-0-omgox stderrLocalPort = 9008 2022-07-15 03:43:00 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:43:00 INFO i.a.w.p.KubePodProcess():515 - Creating pod destination-snowflake-write-49591-0-omgox... 2022-07-15 03:43:00 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:43:01 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:43:01 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/79f70d01-d359-4cff-bebe-7a735cc0db28/destination_config.json datalake/destination-snowflake-write-49591-0-omgox:/config/destination_config.json -c init 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/f3169688-0de3-4bf5-a9e8-1df21ac28369/destination_catalog.json datalake/destination-snowflake-write-49591-0-omgox:/config/destination_catalog.json -c init 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/0ae7e251-b04a-4910-8e42-f1b58678baff/FINISHED_UPLOADING datalake/destination-snowflake-write-49591-0-omgox:/config/FINISHED_UPLOADING -c init 2022-07-15 03:43:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:43:03 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:43:03 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:43:03 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:43:03 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:43:04 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:43:04 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.7.180 2022-07-15 03:43:04 INFO i.a.w.p.KubePodProcess():570 - Creating stdin socket... 2022-07-15 03:43:04 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-read-49591-0-enhnn for airbyte/source-postgres:0.4.18 2022-07-15 03:43:04 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:43:04 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-15 03:43:04 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-07-15 03:43:04 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-07-15 03:43:04 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:53:20 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / destination-snowflake-write-49591-0-omgox) - Closed all resources for pod 2022-07-15 03:53:20 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:53:20 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@567d8649[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657855974009,endTime=1657857200398,totalStats=io.airbyte.config.SyncStats@75e7fd2d[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]] 2022-07-15 03:53:20 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages 2022-07-15 03:53:20 WARN i.a.w.g.DefaultReplicationWorker(run):279 - State capture: No state retained. 2022-07-15 03:53:20 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:53:20 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@60fae155[standardSyncSummary=io.airbyte.config.StandardSyncSummary@575b9283[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657855974009,endTime=1657857200398,totalStats=io.airbyte.config.SyncStats@75e7fd2d[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=,state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@5ae4c91b[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@591cc7cd[stream=io.airbyte.protocol.models.AirbyteStream@6edb65f2[name=spy_category_template,jsonSchema={"type":"object","properties":{"name":{"type":"string"},"template_path":{"type":"string"},"id_category_template":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id_category_template]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id_category_template]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@651f3d20[stream=io.airbyte.protocol.models.AirbyteStream@19cf9c89[name=spy_cms_block,jsonSchema={"type":"object","properties":{"name":{"type":"string"},"type":{"type":"string"},"value":{"type":"number"},"fk_page":{"type":"number"},"valid_to":{"type":"string"},"is_active":{"type":"boolean"},"valid_from":{"type":"string"},"fk_template":{"type":"number"},"id_cms_block":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id_cms_block]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id_cms_block]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@26d202d2[stream=io.airbyte.protocol.models.AirbyteStream@1313170f[name=spy_cms_block_category_connector,jsonSchema={"type":"object","properties":{"fk_category":{"type":"number"},"fk_cms_block":{"type":"number"},"fk_category_template":{"type":"number"},"fk_cms_block_category_position":{"type":"number"},"id_cms_block_category_connector":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id_cms_block_category_connector]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id_cms_block_category_connector]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@ff9ce70[stream=io.airbyte.protocol.models.AirbyteStream@6a3720d2[name=spy_cms_block_category_position,jsonSchema={"type":"object","properties":{"name":{"type":"string"},"id_cms_block_category_position":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id_cms_block_category_position]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id_cms_block_category_position]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5cc57bd4[stream=io.airbyte.protocol.models.AirbyteStream@5765b42c[name=spy_cms_block_glossary_key_mapping,jsonSchema={"type":"object","properties":{"placeholder":{"type":"string"},"fk_cms_block":{"type":"number"},"fk_glossary_key":{"type":"number"},"id_cms_block_glossary_key_mapping":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id_cms_block_glossary_key_mapping]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id_cms_block_glossary_key_mapping]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@16ae7afe[stream=io.airbyte.protocol.models.AirbyteStream@454cf949[name=spy_cms_block_store,jsonSchema={"type":"object","properties":{"fk_store":{"type":"number"},"fk_cms_block":{"type":"number"},"id_cms_block_store":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id_cms_block_store]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id_cms_block_store]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@322021ef[stream=io.airbyte.protocol.models.AirbyteStream@489e2753[name=spy_cms_block_template,jsonSchema={"type":"object","properties":{"template_name":{"type":"string"},"template_path":{"type":"string"},"id_cms_block_template":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id_cms_block_template]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id_cms_block_template]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2d82cd34[stream=io.airbyte.protocol.models.AirbyteStream@fa6ef7c[name=spy_cms_glossary_key_mapping,jsonSchema={"type":"object","properties":{"fk_page":{"type":"number"},"placeholder":{"type":"string"},"fk_glossary_key":{"type":"number"},"id_cms_glossary_key_mapping":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id_cms_glossary_key_mapping]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id_cms_glossary_key_mapping]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3c3a983e[stream=io.airbyte.protocol.models.AirbyteStream@5a79455[name=spy_cms_page,jsonSchema={"type":"object","properties":{"valid_to":{"type":"string"},"is_active":{"type":"boolean"},"valid_from":{"type":"string"},"fk_template":{"type":"number"},"id_cms_page":{"type":"number"},"is_searchable":{"type":"boolean"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id_cms_page]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id_cms_page]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3ef702b8[stream=io.airbyte.protocol.models.AirbyteStream@612d715[name=spy_cms_page_localized_attributes,jsonSchema={"type":"object","properties":{"name":{"type":"string"},"fk_locale":{"type":"number"},"created_at":{"type":"string"},"meta_title":{"type":"string"},"updated_at":{"type":"string"},"fk_cms_page":{"type":"number"},"meta_keywords":{"type":"string"},"meta_description":{"type":"string"},"id_cms_page_localized_attributes":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id_cms_page_localized_attributes]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id_cms_page_localized_attributes]],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-07-15 03:53:20 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-07-15 03:53:20 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49591/0/logs.log 2022-07-15 03:53:20 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:53:20 INFO i.a.w.g.DefaultNormalizationWorker(run):49 - Running normalization. 2022-07-15 03:53:20 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.2.1 2022-07-15 03:53:20 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = normalization-snowflake-normalize-49591-0-yzwpl for airbyte/normalization-snowflake:0.2.1 2022-07-15 04:03:20 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 04:03:20 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 04:03:20 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-07-15 04:03:20 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=9c8c2242-982c-36dd-9cfa-a48f3b6b9e48, 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 04:03:21 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49591/1/logs.log 2022-07-15 04:03:21 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 04:03:21 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-check-49591-1-ybqia for airbyte/source-postgres:0.4.18 2022-07-15 04:08:31 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):194 - Running sync worker cancellation... 2022-07-15 04:08:31 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Interrupting worker thread... 2022-07-15 04:08:31 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):201 - Cancelling completable future... 2022-07-15 04:08:31 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-07-15 04:08:31 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 04:08: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 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 2022-07-15 04:08:31 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=83b97197-3577-3fdf-a6da-1954b4ae5ac8, 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) [?:?]