2022-07-15 03:18:11 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:18:11 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49582/0/logs.log 2022-07-15 03:18:11 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:18:11 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-check-49582-0-iyxln for airbyte/source-postgres:0.4.18 2022-07-15 03:19:33 INFO i.a.w.p.KubeProcessFactory(create):103 - source-postgres-check-49582-0-iyxln stdoutLocalPort = 9015 2022-07-15 03:20:40 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:20:22 INFO i.a.w.p.KubeProcessFactory(create):106 - source-postgres-check-49582-0-iyxln stderrLocalPort = 9018 2022-07-15 03:20:22 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:20:22 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:20:22 INFO i.a.w.p.KubePodProcess():515 - Creating pod source-postgres-check-49582-0-iyxln... 2022-07-15 03:20:23 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:20:23 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:20:23 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:20:23 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:20:23 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-07-15 03:20:23 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/4fb54eca-67a7-4ab2-b6ed-2f34ce24ce4e/source_config.json datalake/source-postgres-check-49582-0-iyxln:/config/source_config.json -c init 2022-07-15 03:20:23 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:24 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:24 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:20:24 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/33086b6a-d73b-4c06-9d1c-bd6cad5ead00/FINISHED_UPLOADING datalake/source-postgres-check-49582-0-iyxln:/config/FINISHED_UPLOADING -c init 2022-07-15 03:20:24 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:24 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:24 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:20:25 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:20:25 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:20:26 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:20:26 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.7.68 2022-07-15 03:20:26 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:20:26 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:20:26 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:26 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:26 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:26 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:20:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:25 INFO i.a.i.s.p.PostgresSource(main):409 - starting source: class io.airbyte.integrations.source.postgres.PostgresSource 2022-07-15 03:20:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:25 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-15 03:20:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:25 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-07-15 03:20:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:25 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-07-15 03:20:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:25 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:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 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:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 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:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 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:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 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:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-07-15 03:20:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-07-15 03:20:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-07-15 03:20:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 INFO i.a.i.s.p.PostgresSource(isCdc):258 - using CDC: false 2022-07-15 03:20:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 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:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-07-15 03:20:26 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:26 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-07-15 03:20:27 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / source-postgres-check-49582-0-iyxln) - Closed all resources for pod 2022-07-15 03:20:27 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:20:27 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49582/0/logs.log 2022-07-15 03:20:27 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:20:27 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-check-49582-0-ffebw for airbyte/destination-snowflake:0.4.30 2022-07-15 03:20:28 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-check-49582-0-ffebw stdoutLocalPort = 9008 2022-07-15 03:20:28 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-check-49582-0-ffebw stderrLocalPort = 9014 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess():515 - Creating pod destination-snowflake-check-49582-0-ffebw... 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:20:28 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/8d4efab1-18b2-4109-89a7-a65753424c01/source_config.json datalake/destination-snowflake-check-49582-0-ffebw:/config/source_config.json -c init 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/e545df32-d825-40e8-89b2-6fa878c038f6/FINISHED_UPLOADING datalake/destination-snowflake-check-49582-0-ffebw:/config/FINISHED_UPLOADING -c init 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:30 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:20:31 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:20:31 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.7.34 2022-07-15 03:20:32 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:20:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-15 03:20:32 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:20:32 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:32 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:32 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:32 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:32 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:20:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 INFO i.a.i.b.IntegrationRunner(createSentryTransaction):351 - Sentry transaction event: a6be8338064c4f169f1784128e828ce6 2022-07-15 03:20:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-07-15 03:20:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-07-15 03:20:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 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:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 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:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 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:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 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:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 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:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING 2022-07-15 03:20:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 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:32 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:32 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-07-15 03:20:33 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:33 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@3f362135 2022-07-15 03:20:33 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:33 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-07-15 03:20:33 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:33 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection 2022-07-15 03:20:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:34 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-07-15 03:20:34 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:20:34 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-07-15 03:20:36 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / destination-snowflake-check-49582-0-ffebw) - Closed all resources for pod 2022-07-15 03:20:36 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:20:36 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49582/0/logs.log 2022-07-15 03:20:36 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:20:36 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 49582 attempt id: 0 2022-07-15 03:20:36 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {public.import_row_issue=incremental - append} 2022-07-15 03:20:36 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-07-15 03:20:36 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-write-49582-0-aclry for airbyte/destination-snowflake:0.4.30 2022-07-15 03:20:36 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-write-49582-0-aclry stdoutLocalPort = 9008 2022-07-15 03:20:36 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-write-49582-0-aclry stderrLocalPort = 9014 2022-07-15 03:20:36 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:20:36 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:20:36 INFO i.a.w.p.KubePodProcess():515 - Creating pod destination-snowflake-write-49582-0-aclry... 2022-07-15 03:20:36 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:20:36 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/91ebee70-20d5-4ecd-ae94-3fb19ed89903/destination_config.json datalake/destination-snowflake-write-49582-0-aclry:/config/destination_config.json -c init 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/ef24b91a-ebfa-4440-bff7-7de8cb3554f6/destination_catalog.json datalake/destination-snowflake-write-49582-0-aclry:/config/destination_catalog.json -c init 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/4b64043e-0541-4ccb-8984-904806a31ae2/FINISHED_UPLOADING datalake/destination-snowflake-write-49582-0-aclry:/config/FINISHED_UPLOADING -c init 2022-07-15 03:20:38 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:20:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:20:39 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:20:39 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:20:39 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.10.149 2022-07-15 03:20:40 INFO i.a.w.p.KubePodProcess():570 - Creating stdin socket... 2022-07-15 03:20:40 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-read-49582-0-opwik for airbyte/source-postgres:0.4.18 2022-07-15 03:21:09 INFO i.a.w.p.KubeProcessFactory(create):103 - source-postgres-read-49582-0-opwik stdoutLocalPort = 9013 2022-07-15 03:20:40 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:40 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:40 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:40 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-07-15 03:20:40 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 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/IMPORT_ROW_ISSUE_AB1.sql from import_row_issue 2022-07-15 03:31:36 normalization > Generating airbyte_ctes/PROD/IMPORT_ROW_ISSUE_AB2.sql from import_row_issue 2022-07-15 03:31:36 normalization > Generating airbyte_ctes/PROD/IMPORT_ROW_ISSUE_AB3.sql from import_row_issue 2022-07-15 03:31:36 normalization > Generating airbyte_incremental/PROD/IMPORT_ROW_ISSUE.sql from import_row_issue 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:14 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / destination-snowflake-write-49582-0-aclry) - Closed all resources for pod 2022-07-15 03:31:14 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:14 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6fb1d826[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657855236851,endTime=1657855874061,totalStats=io.airbyte.config.SyncStats@2f8185c2[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]] 2022-07-15 03:31:14 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages 2022-07-15 03:31:14 WARN i.a.w.g.DefaultReplicationWorker(run):276 - State capture: No new state, falling back on input state: io.airbyte.config.State@358df2e3[state={"cdc":false,"streams":[{"cursor":"391875653","stream_name":"import_row_issue","cursor_field":["id"],"stream_namespace":"public"}]}] 2022-07-15 03:31:14 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:31:14 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@680ec87c[standardSyncSummary=io.airbyte.config.StandardSyncSummary@488a1cd1[status=failed,recordsSynced=0,bytesSynced=0,startTime=1657855236851,endTime=1657855874061,totalStats=io.airbyte.config.SyncStats@2f8185c2[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=,state=io.airbyte.config.State@358df2e3[state={"cdc":false,"streams":[{"cursor":"391875653","stream_name":"import_row_issue","cursor_field":["id"],"stream_namespace":"public"}]}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@48c7a0a6[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@264935b0[stream=io.airbyte.protocol.models.AirbyteStream@381a442d[name=import_row_issue,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"code":{"type":"string"},"level":{"type":"string"},"message":{"type":"string"},"import_row_id":{"type":"number"},"import_mapping_id":{"type":"number"},"import_session_id":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[id],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-07-15 03:31:14 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-07-15 03:31:14 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49582/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-49582-0-dvtgu for airbyte/normalization-snowflake:0.2.1 2022-07-15 03:31:23 INFO i.a.w.p.KubeProcessFactory(create):103 - normalization-snowflake-normalize-49582-0-dvtgu stdoutLocalPort = 9028 2022-07-15 03:31:32 INFO i.a.w.p.KubeProcessFactory(create):106 - normalization-snowflake-normalize-49582-0-dvtgu stderrLocalPort = 9012 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(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:31:32 INFO i.a.w.p.KubePodProcess():515 - Creating pod normalization-snowflake-normalize-49582-0-dvtgu... 2022-07-15 03:31:32 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/09b6dacc-6127-483b-9836-9d197535d759/destination_config.json datalake/normalization-snowflake-normalize-49582-0-dvtgu:/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/3971ea80-7a5b-47a7-b24a-b176c8784272/destination_catalog.json datalake/normalization-snowflake-normalize-49582-0-dvtgu:/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/5f2ba537-806e-4dc3-9aa4-c1145b2253a8/FINISHED_UPLOADING datalake/normalization-snowflake-normalize-49582-0-dvtgu:/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.11.177 2022-07-15 03:31:36 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:31:51 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / normalization-snowflake-normalize-49582-0-dvtgu) - Closed all resources for pod 2022-07-15 03:31:51 INFO i.a.w.g.DefaultNormalizationWorker(run):73 - Normalization executed in 37 seconds. 2022-07-15 03:31:51 INFO i.a.w.g.DefaultNormalizationWorker(run):79 - Normalization summary: io.airbyte.config.NormalizationSummary@305ac671[startTime=1657855874197,endTime=1657855911512] 2022-07-15 03:31:51 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:31:51 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 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 2 unused configuration paths: 2022-07-15 03:31:41 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-07-15 03:31:41 normalization > - models.airbyte_utils.generated.airbyte_views 2022-07-15 03:31:41 normalization > 2022-07-15 03:31:41 normalization > 03:31:41 Found 4 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:42 normalization > 03:31:42 Concurrency: 5 threads (target='prod') 2022-07-15 03:31:42 normalization > 03:31:42 2022-07-15 03:31:44 normalization > 03:31:44 1 of 1 START incremental model PROD.IMPORT_ROW_ISSUE.................................................................... [RUN] 2022-07-15 03:31:50 normalization > 03:31:50 1 of 1 OK created incremental model PROD.IMPORT_ROW_ISSUE............................................................... [SUCCESS 1 in 6.57s] 2022-07-15 03:31:50 normalization > 03:31:50 2022-07-15 03:31:50 normalization > 03:31:50 Finished running 1 incremental model in 9.49s. 2022-07-15 03:31:50 normalization > 03:31:50 2022-07-15 03:31:50 normalization > 03:31:50 Completed successfully 2022-07-15 03:31:50 normalization > 03:31:50 2022-07-15 03:31:50 normalization > 03:31:50 Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1 2022-07-15 03:31:52 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:31:52 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49582/1/logs.log 2022-07-15 03:31:52 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:31:52 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-check-49582-1-rgbkc for airbyte/source-postgres:0.4.18 2022-07-15 03:32:20 INFO i.a.w.p.KubeProcessFactory(create):103 - source-postgres-check-49582-1-rgbkc stdoutLocalPort = 9012 2022-07-15 03:32:41 INFO i.a.w.p.KubeProcessFactory(create):106 - source-postgres-check-49582-1-rgbkc stderrLocalPort = 9015 2022-07-15 03:32:41 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server... 2022-07-15 03:32:41 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server... 2022-07-15 03:32:41 INFO i.a.w.p.KubePodProcess():515 - Creating pod source-postgres-check-49582-1-rgbkc... 2022-07-15 03:32:41 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-07-15 03:32:41 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present.. 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready.. 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/a6aa8423-901f-4d01-b859-756ff9b4015e/source_config.json datalake/source-postgres-check-49582-1-rgbkc:/config/source_config.json -c init 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/65fad94e-2614-45a0-83dc-e72bcab37600/FINISHED_UPLOADING datalake/source-postgres-check-49582-1-rgbkc:/config/FINISHED_UPLOADING -c init 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-07-15 03:32:43 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-07-15 03:32:44 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout... 2022-07-15 03:32:44 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr... 2022-07-15 03:32:45 INFO i.a.w.p.KubePodProcess():565 - Reading pod IP... 2022-07-15 03:32:45 INFO i.a.w.p.KubePodProcess():567 - Pod IP: 172.17.10.51 2022-07-15 03:32:45 INFO i.a.w.p.KubePodProcess():574 - Using null stdin output stream... 2022-07-15 03:32:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 INFO i.a.i.s.p.PostgresSource(main):409 - starting source: class io.airbyte.integrations.source.postgres.PostgresSource 2022-07-15 03:32:45 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-07-15 03:32:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-07-15 03:32:45 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:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-07-15 03:32:45 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:32:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-07-15 03:32:45 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:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 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:45 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-07-15 03:32:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 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:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 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:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 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:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 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:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-07-15 03:32:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-07-15 03:32:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-07-15 03:32:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 INFO i.a.i.s.p.PostgresSource(isCdc):258 - using CDC: false 2022-07-15 03:32:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 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:32:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-07-15 03:32:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-15 03:32:45 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-07-15 03:32:46 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / source-postgres-check-49582-1-rgbkc) - Closed all resources for pod 2022-07-15 03:32:46 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:32:46 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/49582/1/logs.log 2022-07-15 03:32:46 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-07-15 03:32:46 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-check-49582-1-gfhyf for airbyte/destination-snowflake:0.4.30 2022-07-15 03:32:53 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-check-49582-1-gfhyf stdoutLocalPort = 9028 2022-07-15 03:37:56 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):194 - Running sync worker cancellation... 2022-07-15 03:37:56 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Interrupting worker thread... 2022-07-15 03:37:56 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):201 - Cancelling completable future... 2022-07-15 03:37:56 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-07-15 03:37:56 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-07-15 03:37:56 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=b707bb98-f3ef-374d-886a-f8f38f499612, 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:37:56 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:105) ~[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