2022-04-13 19:50:51 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha 2022-04-13 19:50:51 INFO i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/1073/2/logs.log 2022-04-13 19:51:09 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-13 19:50:51 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha 2022-04-13 19:50:51 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 1073 attempt id: 2 2022-04-13 19:50:51 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.group_members=full_refresh - append, null.merge_request_commits=full_refresh - append, null.merge_requests=incremental - append, null.commits=incremental - append, null.groups=full_refresh - append, null.projects=full_refresh - append, null.jobs=full_refresh - append, null.pipelines=incremental - append, null.project_members=full_refresh - append, null.branches=full_refresh - append, null.pipelines_extended=full_refresh - append} 2022-04-13 19:50:51 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-04-13 19:50:51 INFO i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = destination-snowflake-sync-1073-2-kalka for airbyte/destination-snowflake:0.4.24 2022-04-13 19:50:51 INFO i.a.w.p.KubeProcessFactory(create):116 - destination-snowflake-sync-1073-2-kalka stdoutLocalPort = 9040 2022-04-13 19:50:51 INFO i.a.w.p.KubeProcessFactory(create):119 - destination-snowflake-sync-1073-2-kalka stderrLocalPort = 9001 2022-04-13 19:50:51 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):565 - Creating stdout socket server... 2022-04-13 19:50:51 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):583 - Creating stderr socket server... 2022-04-13 19:50:51 INFO i.a.w.p.KubePodProcess():503 - Creating pod... 2022-04-13 19:50:51 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-04-13 19:50:51 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):318 - Init container present.. 2022-04-13 19:50:54 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):321 - Init container ready.. 2022-04-13 19:50:54 INFO i.a.w.p.KubePodProcess():528 - Copying files... 2022-04-13 19:50:54 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-04-13 19:50:54 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/4ea7d1e7-e544-413f-b245-145999d9e507/destination_config.json product-analytics/destination-snowflake-sync-1073-2-kalka:/config/destination_config.json -c init 2022-04-13 19:50:54 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-13 19:50:57 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-13 19:50:57 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-04-13 19:50:57 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/667857d8-8b1d-44af-85a2-3846a0dfbf70/destination_catalog.json product-analytics/destination-snowflake-sync-1073-2-kalka:/config/destination_catalog.json -c init 2022-04-13 19:50:57 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-13 19:50:59 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-13 19:50:59 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-04-13 19:50:59 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/9a97ea92-f8fa-4882-bbfb-aa5e9654b449/FINISHED_UPLOADING product-analytics/destination-snowflake-sync-1073-2-kalka:/config/FINISHED_UPLOADING -c init 2022-04-13 19:50:59 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-13 19:51:01 INFO i.a.w.p.KubePodProcess(waitForInitPodToTerminate):332 - Waiting for init container to terminate before checking exit value... 2022-04-13 19:51:02 INFO i.a.w.p.KubePodProcess(waitForInitPodToTerminate):337 - Init container terminated with exit value 0. 2022-04-13 19:51:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Init was successful; ignoring non-zero kubectl cp exit code for success indicator file. 2022-04-13 19:51:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-13 19:51:02 INFO i.a.w.p.KubePodProcess():531 - Waiting until pod is ready... 2022-04-13 19:51:05 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):574 - Setting stdout... 2022-04-13 19:51:06 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):586 - Setting stderr... 2022-04-13 19:51:09 INFO i.a.w.p.KubePodProcess():546 - Reading pod IP... 2022-04-13 19:51:09 INFO i.a.w.p.KubePodProcess():548 - Pod IP: 10.56.91.21 2022-04-13 19:51:09 INFO i.a.w.p.KubePodProcess():551 - Creating stdin socket... 2022-04-13 19:51:09 INFO i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = source-gitlab-sync-1073-2-xyhrp for airbyte/source-gitlab:0.1.4 2022-04-13 19:51:09 INFO i.a.w.p.KubeProcessFactory(create):116 - source-gitlab-sync-1073-2-xyhrp stdoutLocalPort = 9002 2022-04-13 19:51:09 INFO i.a.w.p.KubeProcessFactory(create):119 - source-gitlab-sync-1073-2-xyhrp stderrLocalPort = 9003 2022-04-13 19:51:09 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):565 - Creating stdout socket server... 2022-04-13 19:51:09 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):583 - Creating stderr socket server... 2022-04-13 19:51:09 INFO i.a.w.p.KubePodProcess():503 - Creating pod... 2022-04-13 19:51:09 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-04-13 19:51:09 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):318 - Init container present.. 2022-04-13 19:51:12 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):321 - Init container ready.. 2022-04-13 19:51:12 INFO i.a.w.p.KubePodProcess():528 - Copying files... 2022-04-13 19:51:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: input_state.json 2022-04-13 19:51:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/924fbec6-df01-47a1-ab4a-2d3428e87755/input_state.json product-analytics/source-gitlab-sync-1073-2-xyhrp:/config/input_state.json -c init 2022-04-13 19:51:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-13 19:51:14 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-13 19:51:14 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-04-13 19:51:14 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/c486da85-7215-4774-90cb-4ef6708d777c/source_config.json product-analytics/source-gitlab-sync-1073-2-xyhrp:/config/source_config.json -c init 2022-04-13 19:51:14 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-13 19:51:16 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-13 19:51:16 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_catalog.json 2022-04-13 19:51:16 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/2246e6e6-9fa4-4fce-bcbe-df84034a2404/source_catalog.json product-analytics/source-gitlab-sync-1073-2-xyhrp:/config/source_catalog.json -c init 2022-04-13 19:51:16 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-13 19:51:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-13 19:51:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-04-13 19:51:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/26530a1c-1faa-4c64-8252-b2fbcae4bd65/FINISHED_UPLOADING product-analytics/source-gitlab-sync-1073-2-xyhrp:/config/FINISHED_UPLOADING -c init 2022-04-13 19:51:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-13 19:51:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-13 19:51:21 INFO i.a.w.p.KubePodProcess():531 - Waiting until pod is ready... 2022-04-13 19:51:23 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):574 - Setting stdout... 2022-04-13 19:51:24 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):586 - Setting stderr... 2022-04-13 19:51:26 INFO i.a.w.p.KubePodProcess():546 - Reading pod IP... 2022-04-13 19:51:26 INFO i.a.w.p.KubePodProcess():548 - Pod IP: 10.56.102.209 2022-04-13 19:51:26 INFO i.a.w.p.KubePodProcess():555 - Using null stdin output stream... 2022-04-13 19:51:26 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-04-13 19:51:26 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-04-13 19:51:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-04-13 19:51:09 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-13 19:51:09 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-13 19:51:09 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-13 19:51:09 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.b.IntegrationRunner(createSentryTransaction):339 - Sentry transaction event: f3376740f6654ea0be928f2ceb0a7bf5 2022-04-13 19:51:26 source > Starting syncing SourceGitlab 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-04-13 19:51:26 source > Syncing stream: branches 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 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-04-13 19:51:26 destination > 2022-04-13 19:51:07 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-04-13 19:51:26 destination > 2022-04-13 19:51:07 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-04-13 19:51:26 destination > 2022-04-13 19:51:07 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-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_branches, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_zyf_gitlab_wex_branches, outputTableName=_airbyte_raw_gitlab_wex_branches, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_commits, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_yyb_gitlab_wex_commits, outputTableName=_airbyte_raw_gitlab_wex_commits, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_group_members, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_gnq_gitlab_wex_group_members, outputTableName=_airbyte_raw_gitlab_wex_group_members, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_groups, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_qxl_gitlab_wex_groups, outputTableName=_airbyte_raw_gitlab_wex_groups, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_jobs, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_hcc_gitlab_wex_jobs, outputTableName=_airbyte_raw_gitlab_wex_jobs, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_merge_request_commits, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_gns_gitlab_wex_merge_request_commits, outputTableName=_airbyte_raw_gitlab_wex_merge_request_commits, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_merge_requests, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_rgn_gitlab_wex_merge_requests, outputTableName=_airbyte_raw_gitlab_wex_merge_requests, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_pipelines, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_vbh_gitlab_wex_pipelines, outputTableName=_airbyte_raw_gitlab_wex_pipelines, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_pipelines_extended, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_yid_gitlab_wex_pipelines_extended, outputTableName=_airbyte_raw_gitlab_wex_pipelines_extended, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_project_members, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_ybw_gitlab_wex_project_members, outputTableName=_airbyte_raw_gitlab_wex_project_members, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gitlab_wex_projects, namespace=null, outputSchemaName=AIRBYTE, tmpTableName=_airbyte_tmp_bym_gitlab_wex_projects, outputTableName=_airbyte_raw_gitlab_wex_projects, syncMode=append} 2022-04-13 19:51:26 destination > 2022-04-13 19:51:08 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-04-13 19:51:26 destination > 2022-04-13 19:51:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):114 - Preparing tmp tables in destination started for 11 streams 2022-04-13 19:51:26 destination > 2022-04-13 19:51:08 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_branches: tmp table: _airbyte_tmp_zyf_gitlab_wex_branches, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:08 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-04-13 19:51:26 destination > 2022-04-13 19:51:09 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@3e4e8fdf 2022-04-13 19:51:26 destination > 2022-04-13 19:51:09 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-04-13 19:51:26 destination > 2022-04-13 19:51:09 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_branches 2022-04-13 19:51:26 destination > 2022-04-13 19:51:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_commits: tmp table: _airbyte_tmp_yyb_gitlab_wex_commits, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:09 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_commits 2022-04-13 19:51:26 destination > 2022-04-13 19:51:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_group_members: tmp table: _airbyte_tmp_gnq_gitlab_wex_group_members, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:11 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_group_members 2022-04-13 19:51:26 destination > 2022-04-13 19:51:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_groups: tmp table: _airbyte_tmp_qxl_gitlab_wex_groups, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:12 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_groups 2022-04-13 19:51:26 destination > 2022-04-13 19:51:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_jobs: tmp table: _airbyte_tmp_hcc_gitlab_wex_jobs, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:12 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_jobs 2022-04-13 19:51:26 destination > 2022-04-13 19:51:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_merge_request_commits: tmp table: _airbyte_tmp_gns_gitlab_wex_merge_request_commits, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:13 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_merge_request_commits 2022-04-13 19:51:26 destination > 2022-04-13 19:51:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_merge_requests: tmp table: _airbyte_tmp_rgn_gitlab_wex_merge_requests, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:13 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_merge_requests 2022-04-13 19:51:26 destination > 2022-04-13 19:51:13 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_pipelines: tmp table: _airbyte_tmp_vbh_gitlab_wex_pipelines, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:14 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:14 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_pipelines 2022-04-13 19:51:26 destination > 2022-04-13 19:51:14 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_pipelines_extended: tmp table: _airbyte_tmp_yid_gitlab_wex_pipelines_extended, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:14 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:14 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_pipelines_extended 2022-04-13 19:51:26 destination > 2022-04-13 19:51:14 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_project_members: tmp table: _airbyte_tmp_ybw_gitlab_wex_project_members, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:15 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:15 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_project_members 2022-04-13 19:51:26 destination > 2022-04-13 19:51:15 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema AIRBYTE stream gitlab_wex_projects: tmp table: _airbyte_tmp_bym_gitlab_wex_projects, stage: 2022/04/13/19/0981B9CF-FECC-4BB3-BF9F-8D21E24437CE/ 2022-04-13 19:51:26 destination > 2022-04-13 19:51:15 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 19:51:26 destination > 2022-04-13 19:51:15 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema AIRBYTE stream gitlab_wex_projects 2022-04-13 19:51:26 destination > 2022-04-13 19:51:15 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing tmp tables in destination completed. 2022-04-13 19:51:32 destination > 2022-04-13 19:51:32 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_branches (current state: 0 bytes in 0 buffers) 2022-04-13 19:52:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (351 KB) 2022-04-13 19:53:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 2000 (701 KB) 2022-04-13 19:53:49 source > Read 2290 records from branches stream 2022-04-13 19:53:49 source > Finished syncing branches 2022-04-13 19:53:49 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 2022-04-13 19:53:49 source > Syncing stream: commits 2022-04-13 19:53:52 destination > 2022-04-13 19:53:52 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_commits (current state: 160 KB in 1 buffers) 2022-04-13 19:55:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 3000 (1 MB) 2022-04-13 19:55:47 source > Read 520 records from commits stream 2022-04-13 19:55:47 source > Finished syncing commits 2022-04-13 19:55:47 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 Syncing stream commits 0:01:58.347393 2022-04-13 19:55:47 source > Syncing stream: group_members 2022-04-13 19:55:52 source > Read 12 records from group_members stream 2022-04-13 19:55:52 source > Finished syncing group_members 2022-04-13 19:55:52 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 Syncing stream commits 0:01:58.347393 Syncing stream group_members 0:00:04.739665 2022-04-13 19:55:52 source > Syncing stream: groups 2022-04-13 19:55:52 source > Read 10 records from groups stream 2022-04-13 19:55:52 source > Finished syncing groups 2022-04-13 19:55:52 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 Syncing stream commits 0:01:58.347393 Syncing stream group_members 0:00:04.739665 Syncing stream groups 0:00:00.610403 2022-04-13 19:55:52 source > Syncing stream: jobs 2022-04-13 19:55:52 destination > 2022-04-13 19:55:52 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_group_members (current state: 219 KB in 2 buffers) 2022-04-13 19:55:56 destination > 2022-04-13 19:55:56 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_groups (current state: 219 KB in 3 buffers) 2022-04-13 19:55:57 destination > 2022-04-13 19:55:57 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_jobs (current state: 219 KB in 4 buffers) 2022-04-13 19:57:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 4000 (1 MB) 2022-04-13 19:58:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 5000 (2 MB) 2022-04-13 19:59:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 6000 (3 MB) 2022-04-13 20:01:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 7000 (3 MB) 2022-04-13 20:02:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 8000 (4 MB) 2022-04-13 20:04:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 9000 (5 MB) 2022-04-13 20:06:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 10000 (5 MB) 2022-04-13 20:06:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 11000 (6 MB) 2022-04-13 20:09:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 12000 (7 MB) 2022-04-13 20:10:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 13000 (7 MB) 2022-04-13 20:12:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 14000 (8 MB) 2022-04-13 20:13:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 15000 (9 MB) 2022-04-13 20:15:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 16000 (9 MB) 2022-04-13 20:17:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 17000 (10 MB) 2022-04-13 20:19:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 18000 (11 MB) 2022-04-13 20:20:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 19000 (11 MB) 2022-04-13 20:22:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 20000 (12 MB) 2022-04-13 20:23:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 21000 (13 MB) 2022-04-13 20:25:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 22000 (13 MB) 2022-04-13 20:27:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 23000 (14 MB) 2022-04-13 20:28:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 24000 (15 MB) 2022-04-13 20:29:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 25000 (15 MB) 2022-04-13 20:31:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 26000 (16 MB) 2022-04-13 20:33:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 27000 (17 MB) 2022-04-13 20:35:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 28000 (17 MB) 2022-04-13 20:36:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 29000 (18 MB) 2022-04-13 20:38:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 30000 (19 MB) 2022-04-13 20:40:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 31000 (19 MB) 2022-04-13 20:41:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 32000 (20 MB) 2022-04-13 20:43:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 33000 (21 MB) 2022-04-13 20:45:02 source > Read 31061 records from jobs stream 2022-04-13 20:44:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 34000 (21 MB) 2022-04-13 20:45:02 source > Finished syncing jobs 2022-04-13 20:45:02 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 Syncing stream commits 0:01:58.347393 Syncing stream group_members 0:00:04.739665 Syncing stream groups 0:00:00.610403 Syncing stream jobs 0:49:10.039867 2022-04-13 20:45:02 source > Syncing stream: merge_request_commits 2022-04-13 20:45:10 destination > 2022-04-13 20:45:10 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_merge_request_commits (current state: 2 MB in 5 buffers) 2022-04-13 20:54:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 35000 (25 MB) 2022-04-13 20:57:16 source > Backing off _send(...) for 5.0s (requests.exceptions.ConnectionError: ('Connection aborted.', ConnectionResetError(104, 'Connection reset by peer'))) 2022-04-13 20:57:25 source > Caught retryable error '('Connection aborted.', ConnectionResetError(104, 'Connection reset by peer'))' after 1 tries. Waiting 5 seconds then retrying... 2022-04-13 21:02:01 source > Read 1615 records from merge_request_commits stream 2022-04-13 21:02:01 source > Finished syncing merge_request_commits 2022-04-13 21:02:01 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 Syncing stream commits 0:01:58.347393 Syncing stream group_members 0:00:04.739665 Syncing stream groups 0:00:00.610403 Syncing stream jobs 0:49:10.039867 Syncing stream merge_request_commits 0:16:58.735854 2022-04-13 21:02:01 source > Syncing stream: merge_requests 2022-04-13 21:02:02 destination > 2022-04-13 21:02:02 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_merge_requests (current state: 3 MB in 6 buffers) 2022-04-13 21:02:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 36000 (28 MB) 2022-04-13 21:03:53 source > Read 392 records from merge_requests stream 2022-04-13 21:03:53 source > Finished syncing merge_requests 2022-04-13 21:03:53 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 Syncing stream commits 0:01:58.347393 Syncing stream group_members 0:00:04.739665 Syncing stream groups 0:00:00.610403 Syncing stream jobs 0:49:10.039867 Syncing stream merge_request_commits 0:16:58.735854 Syncing stream merge_requests 0:01:52.314999 2022-04-13 21:03:53 source > Syncing stream: pipelines 2022-04-13 21:03:58 destination > 2022-04-13 21:03:58 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_pipelines (current state: 3 MB in 7 buffers) 2022-04-13 21:04:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 37000 (29 MB) 2022-04-13 21:05:47 source > Read 872 records from pipelines stream 2022-04-13 21:05:47 source > Finished syncing pipelines 2022-04-13 21:05:47 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 Syncing stream commits 0:01:58.347393 Syncing stream group_members 0:00:04.739665 Syncing stream groups 0:00:00.610403 Syncing stream jobs 0:49:10.039867 Syncing stream merge_request_commits 0:16:58.735854 Syncing stream merge_requests 0:01:52.314999 Syncing stream pipelines 0:01:53.721111 2022-04-13 21:05:47 source > Syncing stream: pipelines_extended 2022-04-13 21:05:54 destination > 2022-04-13 21:05:54 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_pipelines_extended (current state: 3 MB in 8 buffers) 2022-04-13 21:10:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 38000 (30 MB) 2022-04-13 21:18:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 39000 (31 MB) 2022-04-13 21:29:39 source > Backing off _send(...) for 5.0s (airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException) 2022-04-13 21:29:48 source > Caught retryable error '' after 1 tries. Waiting 5 seconds then retrying... 2022-04-13 21:32:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 40000 (32 MB) 2022-04-13 21:42:17 source > Backing off _send(...) for 5.0s (airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException) 2022-04-13 21:42:25 source > Caught retryable error '' after 1 tries. Waiting 5 seconds then retrying... 2022-04-13 21:46:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 41000 (33 MB) 2022-04-13 21:54:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 42000 (34 MB) 2022-04-13 21:55:18 source > Read 4648 records from pipelines_extended stream 2022-04-13 21:55:18 source > Finished syncing pipelines_extended 2022-04-13 21:55:18 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 Syncing stream commits 0:01:58.347393 Syncing stream group_members 0:00:04.739665 Syncing stream groups 0:00:00.610403 Syncing stream jobs 0:49:10.039867 Syncing stream merge_request_commits 0:16:58.735854 Syncing stream merge_requests 0:01:52.314999 Syncing stream pipelines 0:01:53.721111 Syncing stream pipelines_extended 0:49:30.568274 2022-04-13 21:55:18 source > Syncing stream: project_members 2022-04-13 21:55:28 destination > 2022-04-13 21:55:28 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_project_members (current state: 3 MB in 9 buffers) 2022-04-13 21:55:28 destination > 2022-04-13 21:55:28 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 10 current buffers (3 MB in total) 2022-04-13 21:55:28 destination > 2022-04-13 21:55:28 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream gitlab_wex_pipelines_extended (593 KB) 2022-04-13 21:55:28 destination > 2022-04-13 21:55:28 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream gitlab_wex_pipelines_extended (593 KB) to staging 2022-04-13 21:55:28 destination > 2022-04-13 21:55:28 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 33e309ad-f008-4c0c-8eca-f727e9f7572b11903580149916451699.csv.gz (602 KB) 2022-04-13 21:55:29 destination > 2022-04-13 21:55:29 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 21:55:29 destination > 2022-04-13 21:55:29 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 33e309ad-f008-4c0c-8eca-f727e9f7572b11903580149916451699.csv.gz 2022-04-13 21:55:29 destination > 2022-04-13 21:55:29 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream gitlab_wex_merge_request_commits (602 KB) 2022-04-13 21:55:29 destination > 2022-04-13 21:55:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream gitlab_wex_merge_request_commits (602 KB) to staging 2022-04-13 21:55:29 destination > 2022-04-13 21:55:29 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 1d1c2a11-9090-4fcf-b9da-ff15877debda16678208280876968121.csv.gz (610 KB) 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 1d1c2a11-9090-4fcf-b9da-ff15877debda16678208280876968121.csv.gz 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream gitlab_wex_pipelines (56 KB) 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream gitlab_wex_pipelines (56 KB) to staging 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to a90d4031-12f0-414b-a86c-2c9f876f85f62768942546084796639.csv.gz (75 KB) 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data a90d4031-12f0-414b-a86c-2c9f876f85f62768942546084796639.csv.gz 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream gitlab_wex_commits (59 KB) 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream gitlab_wex_commits (59 KB) to staging 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 5b0859a6-9443-4cbe-a150-23e36e70c2e910664611408075991365.csv.gz (63 KB) 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 5b0859a6-9443-4cbe-a150-23e36e70c2e910664611408075991365.csv.gz 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream gitlab_wex_jobs (2 MB) 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream gitlab_wex_jobs (2 MB) to staging 2022-04-13 21:55:30 destination > 2022-04-13 21:55:30 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 2d4ae38f-3b96-42de-92a0-31de0d7c271f8005607244897198249.csv.gz (2 MB) 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 2d4ae38f-3b96-42de-92a0-31de0d7c271f8005607244897198249.csv.gz 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream gitlab_wex_merge_requests (77 KB) 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream gitlab_wex_merge_requests (77 KB) to staging 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 7954a582-06df-4e7a-b3cd-b2c992caac1c7179970124984353227.csv.gz (91 KB) 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 7954a582-06df-4e7a-b3cd-b2c992caac1c7179970124984353227.csv.gz 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream gitlab_wex_groups (10 bytes) 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream gitlab_wex_groups (10 bytes) to staging 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 4bd6c897-245c-4b44-bb38-6d47bbd4ca4315790080469460088444.csv.gz (2 KB) 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 4bd6c897-245c-4b44-bb38-6d47bbd4ca4315790080469460088444.csv.gz 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream gitlab_wex_group_members (10 bytes) 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream gitlab_wex_group_members (10 bytes) to staging 2022-04-13 21:55:31 destination > 2022-04-13 21:55:31 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 7473d166-4128-48e6-8d71-9a510d83fee911541128847439816323.csv.gz (1 KB) 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 7473d166-4128-48e6-8d71-9a510d83fee911541128847439816323.csv.gz 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream gitlab_wex_branches (160 KB) 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream gitlab_wex_branches (160 KB) to staging 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 4fab3f36-6d4b-4bc9-9431-8d1bfbdf00a610006116785877863881.csv.gz (167 KB) 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 4fab3f36-6d4b-4bc9-9431-8d1bfbdf00a610006116785877863881.csv.gz 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$flushAll$2):95 - Flushing buffer of stream gitlab_wex_project_members (10 bytes) 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream gitlab_wex_project_members (10 bytes) to staging 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 1552c9f3-e28c-4c31-8769-3c4dd32e7cb510678915333411368014.csv.gz (379 bytes) 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 1552c9f3-e28c-4c31-8769-3c4dd32e7cb510678915333411368014.csv.gz 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream gitlab_wex_pipelines_extended 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream gitlab_wex_merge_request_commits 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream gitlab_wex_pipelines 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream gitlab_wex_commits 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream gitlab_wex_jobs 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream gitlab_wex_merge_requests 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream gitlab_wex_groups 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream gitlab_wex_group_members 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream gitlab_wex_branches 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(close):119 - Closing buffer for stream gitlab_wex_project_members 2022-04-13 21:55:32 destination > 2022-04-13 21:55:32 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_project_members (current state: 0 bytes in 0 buffers) 2022-04-13 21:57:10 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required 2022-04-13 21:56:55 source > Read 232 records from project_members stream 2022-04-13 21:56:55 source > Finished syncing project_members 2022-04-13 21:56:55 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 Syncing stream commits 0:01:58.347393 Syncing stream group_members 0:00:04.739665 Syncing stream groups 0:00:00.610403 Syncing stream jobs 0:49:10.039867 Syncing stream merge_request_commits 0:16:58.735854 Syncing stream merge_requests 0:01:52.314999 Syncing stream pipelines 0:01:53.721111 Syncing stream pipelines_extended 0:49:30.568274 Syncing stream project_members 0:01:37.354809 2022-04-13 21:56:55 source > Syncing stream: projects 2022-04-13 21:56:56 destination > 2022-04-13 21:56:56 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream gitlab_wex_projects (current state: 0 bytes in 1 buffers) 2022-04-13 21:57:10 source > Read 215 records from projects stream 2022-04-13 21:57:10 source > Finished syncing projects 2022-04-13 21:57:10 source > SourceGitlab runtimes: Syncing stream branches 0:02:24.030040 Syncing stream commits 0:01:58.347393 Syncing stream group_members 0:00:04.739665 Syncing stream groups 0:00:00.610403 Syncing stream jobs 0:49:10.039867 Syncing stream merge_request_commits 0:16:58.735854 Syncing stream merge_requests 0:01:52.314999 Syncing stream pipelines 0:01:53.721111 Syncing stream pipelines_extended 0:49:30.568274 Syncing stream project_members 0:01:37.354809 Syncing stream projects 0:00:14.504486 2022-04-13 21:57:10 source > Finished syncing SourceGitlab 2022-04-13 21:57:10 INFO i.a.w.p.KubePodProcess(close):695 - (pod: product-analytics / source-gitlab-sync-1073-2-xyhrp) - Closed all resources for pod 2022-04-13 21:57:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 42512 (36 MB) 2022-04-13 21:57:10 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Socket closed. Typically happens when cancelling a job. 2022-04-13 21:57:10 INFO i.a.w.p.KubePodProcess(close):695 - (pod: product-analytics / destination-snowflake-sync-1073-2-kalka) - Closed all resources for pod 2022-04-13 21:57:10 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 143 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 143. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.WorkerException: Destination process exit with code 143. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 143 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] ... 1 more 2022-04-13 21:57:10 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@aef326f[status=failed,recordsSynced=41867,bytesSynced=37867027,startTime=1649879451439,endTime=1649887030143,totalStats=io.airbyte.config.SyncStats@59d3b4e5[recordsEmitted=41867,bytesEmitted=37867027,stateMessagesEmitted=645,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@5c1adbef[streamName=gitlab_wex_groups,stats=io.airbyte.config.SyncStats@608cd87a[recordsEmitted=10,bytesEmitted=14774,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@1383f24e[streamName=gitlab_wex_jobs,stats=io.airbyte.config.SyncStats@57330847[recordsEmitted=31061,bytesEmitted=21807710,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@5dfc64ed[streamName=gitlab_wex_pipelines,stats=io.airbyte.config.SyncStats@5b352820[recordsEmitted=872,bytesEmitted=323932,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@57a8a08a[streamName=gitlab_wex_branches,stats=io.airbyte.config.SyncStats@1816eb08[recordsEmitted=2290,bytesEmitted=823531,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@26732feb[streamName=gitlab_wex_project_members,stats=io.airbyte.config.SyncStats@5475772d[recordsEmitted=232,bytesEmitted=132638,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@46cb21d9[streamName=gitlab_wex_commits,stats=io.airbyte.config.SyncStats@69aacca3[recordsEmitted=520,bytesEmitted=456431,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@5619ba0a[streamName=gitlab_wex_merge_request_commits,stats=io.airbyte.config.SyncStats@292a73fb[recordsEmitted=1615,bytesEmitted=6896753,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@36f05aee[streamName=gitlab_wex_projects,stats=io.airbyte.config.SyncStats@9004747[recordsEmitted=215,bytesEmitted=1019712,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@12d26587[streamName=gitlab_wex_pipelines_extended,stats=io.airbyte.config.SyncStats@681d798d[recordsEmitted=4648,bytesEmitted=5641660,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@5c8e794a[streamName=gitlab_wex_group_members,stats=io.airbyte.config.SyncStats@57bf27e3[recordsEmitted=12,bytesEmitted=4459,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@56c09ece[streamName=gitlab_wex_merge_requests,stats=io.airbyte.config.SyncStats@5592548a[recordsEmitted=392,bytesEmitted=745427,stateMessagesEmitted=,recordsCommitted=]]]] 2022-04-13 21:57:10 INFO i.a.w.DefaultReplicationWorker(run):248 - Source output at least one state message 2022-04-13 21:57:10 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@7212e3b2[state={}] 2022-04-13 21:57:10 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-13 21:57:10 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@4f5194d7[standardSyncSummary=io.airbyte.config.StandardSyncSummary@301139dc[status=failed,recordsSynced=41867,bytesSynced=37867027,startTime=1649879451439,endTime=1649887030143,totalStats=io.airbyte.config.SyncStats@59d3b4e5[recordsEmitted=41867,bytesEmitted=37867027,stateMessagesEmitted=645,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@5c1adbef[streamName=gitlab_wex_groups,stats=io.airbyte.config.SyncStats@608cd87a[recordsEmitted=10,bytesEmitted=14774,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@1383f24e[streamName=gitlab_wex_jobs,stats=io.airbyte.config.SyncStats@57330847[recordsEmitted=31061,bytesEmitted=21807710,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@5dfc64ed[streamName=gitlab_wex_pipelines,stats=io.airbyte.config.SyncStats@5b352820[recordsEmitted=872,bytesEmitted=323932,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@57a8a08a[streamName=gitlab_wex_branches,stats=io.airbyte.config.SyncStats@1816eb08[recordsEmitted=2290,bytesEmitted=823531,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@26732feb[streamName=gitlab_wex_project_members,stats=io.airbyte.config.SyncStats@5475772d[recordsEmitted=232,bytesEmitted=132638,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@46cb21d9[streamName=gitlab_wex_commits,stats=io.airbyte.config.SyncStats@69aacca3[recordsEmitted=520,bytesEmitted=456431,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@5619ba0a[streamName=gitlab_wex_merge_request_commits,stats=io.airbyte.config.SyncStats@292a73fb[recordsEmitted=1615,bytesEmitted=6896753,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@36f05aee[streamName=gitlab_wex_projects,stats=io.airbyte.config.SyncStats@9004747[recordsEmitted=215,bytesEmitted=1019712,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@12d26587[streamName=gitlab_wex_pipelines_extended,stats=io.airbyte.config.SyncStats@681d798d[recordsEmitted=4648,bytesEmitted=5641660,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@5c8e794a[streamName=gitlab_wex_group_members,stats=io.airbyte.config.SyncStats@57bf27e3[recordsEmitted=12,bytesEmitted=4459,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@56c09ece[streamName=gitlab_wex_merge_requests,stats=io.airbyte.config.SyncStats@5592548a[recordsEmitted=392,bytesEmitted=745427,stateMessagesEmitted=,recordsCommitted=]]]],state=io.airbyte.config.State@7212e3b2[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@72954674[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@458f38c3[stream=io.airbyte.protocol.models.AirbyteStream@63bfb89[name=gitlab_wex_branches,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"name":{"type":["null","string"]},"merged":{"type":["null","boolean"]},"default":{"type":["null","boolean"]},"web_url":{"type":["null","string"]},"can_push":{"type":["null","boolean"]},"commit_id":{"type":["null","string"]},"protected":{"type":["null","boolean"]},"project_id":{"type":["null","integer"]},"developers_can_push":{"type":["null","boolean"]},"developers_can_merge":{"type":["null","boolean"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[name]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[name]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3fdded4b[stream=io.airbyte.protocol.models.AirbyteStream@6723ba22[name=gitlab_wex_commits,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","string"]},"stats":{"type":["null","object"],"properties":{"total":{"type":["null","integer"]},"additions":{"type":["null","integer"]},"deletions":{"type":["null","integer"]}}},"title":{"type":["null","string"]},"message":{"type":["null","string"]},"web_url":{"type":["null","string"]},"short_id":{"type":["null","string"]},"trailers":{"type":["null","object"]},"created_at":{"type":["null","string"],"format":"date-time"},"parent_ids":{"type":["null","array"],"items":{"type":["null","string"]}},"project_id":{"type":["null","integer"]},"author_name":{"type":["null","string"]},"author_email":{"type":["null","string"]},"authored_date":{"type":["null","string"],"format":"date-time"},"committed_date":{"type":["null","string"],"format":"date-time"},"committer_name":{"type":["null","string"]},"committer_email":{"type":["null","string"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[created_at],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[created_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5bd6cf25[stream=io.airbyte.protocol.models.AirbyteStream@2689065[name=gitlab_wex_group_members,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"state":{"type":["null","string"]},"web_url":{"type":["null","string"]},"group_id":{"type":["null","integer"]},"username":{"type":["null","string"]},"avatar_url":{"type":["null","string"]},"created_at":{"type":["null","string"],"format":"date-time"},"expires_at":{"type":["null","string"],"format":"date-time"},"access_level":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@528f92d6[stream=io.airbyte.protocol.models.AirbyteStream@2887c00f[name=gitlab_wex_groups,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"path":{"type":["null","string"]},"ldap_cn":{"type":["null","string"]},"web_url":{"type":["null","string"]},"projects":{"type":["null","array"],"items":{"type":"object","properties":{"id":{"type":["null","integer"]},"path_with_namespace":{"type":["null","string"]}}}},"full_name":{"type":["null","string"]},"full_path":{"type":["null","string"]},"parent_id":{"type":["null","integer"]},"avatar_url":{"type":["null","string"]},"created_at":{"type":["null","string"],"format":"date-time"},"visibility":{"type":["null","string","integer","boolean"]},"description":{"type":["null","string"]},"ldap_access":{"type":["null","string","integer","boolean"]},"lfs_enabled":{"type":["null","boolean"]},"runners_token":{"type":["null","string"]},"emails_disabled":{"type":["null","boolean"]},"shared_projects":{"type":["null","array"]},"mentions_disabled":{"type":["null","boolean"]},"shared_with_groups":{"type":["null","array"]},"auto_devops_enabled":{"type":["null","boolean"]},"share_with_group_lock":{"type":["null","boolean"]},"project_creation_level":{"type":["null","string"]},"request_access_enabled":{"type":["null","boolean"]},"subgroup_creation_level":{"type":["null","string"]},"two_factor_grace_period":{"type":["null","integer"]},"default_branch_protection":{"type":["null","integer"]},"shared_runners_minutes_limit":{"type":["null","integer"]},"prevent_forking_outside_group":{"type":["null","boolean"]},"require_two_factor_authentication":{"type":["null","boolean"]},"extra_shared_runners_minutes_limit":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@45c59ddd[stream=io.airbyte.protocol.models.AirbyteStream@368c6b8[name=gitlab_wex_jobs,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"ref":{"type":["null","string"]},"tag":{"type":["null","boolean"]},"name":{"type":["null","string"]},"stage":{"type":["null","string"]},"status":{"type":["null","string"]},"user_id":{"type":["null","integer"]},"web_url":{"type":["null","string"]},"coverage":{"type":["null","number","string"]},"duration":{"type":["null","number"]},"tag_list":{"type":["null","array"]},"artifacts":{"type":["null","array"]},"commit_id":{"type":["null","string"]},"runner_id":{"type":["null","integer"]},"created_at":{"type":["null","string"],"format":"date-time"},"project_id":{"type":["null","integer"]},"started_at":{"type":["null","string"],"format":"date-time"},"finished_at":{"type":["null","string"],"format":"date-time"},"pipeline_id":{"type":["null","integer"]},"allow_failure":{"type":["null","boolean"]},"queued_duration":{"type":["null","number"]},"artifacts_expire_at":{"type":["null","string"],"format":"date-time"}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2d5ffd21[stream=io.airbyte.protocol.models.AirbyteStream@3b4ec73d[name=gitlab_wex_merge_request_commits,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"iid":{"type":["null","integer"]},"sha":{"type":["null","string"]},"user":{"type":["null","object"]},"state":{"type":["null","string"]},"title":{"type":["null","string"]},"author":{"type":["null","object"]},"labels":{"type":["null","array"],"items":{"type":"string"}},"squash":{"type":["null","boolean"]},"upvotes":{"type":["null","integer"]},"web_url":{"type":["null","string"]},"assignee":{"type":["null","object"]},"pipeline":{"type":["null","object"]},"assignees":{"type":["null","array"],"items":{"type":"object"}},"closed_at":{"type":["null","string"],"format":"date-time"},"closed_by":{"type":["null","object"]},"diff_refs":{"type":["null","object"],"properties":{"base_sha":{"type":["null","string"]},"head_sha":{"type":["null","string"]},"start_sha":{"type":["null","string"]}}},"downvotes":{"type":["null","integer"]},"merged_at":{"type":["null","string"],"format":"date-time"},"merged_by":{"type":["null","object"]},"milestone":{"type":["null","object"]},"reference":{"type":["null","string"]},"reviewers":{"type":["null","array"],"items":{"type":"object"}},"created_at":{"type":["null","string"],"format":"date-time"},"project_id":{"type":["null","integer"]},"references":{"type":["null","object"]},"subscribed":{"type":["null","boolean"]},"time_stats":{"type":["null","object"]},"updated_at":{"type":["null","string"],"format":"date-time"},"description":{"type":["null","string"]},"merge_error":{"type":["null","boolean","string"]},"merge_status":{"type":["null","string"]},"changes_count":{"type":["null","integer","string"]},"has_conflicts":{"type":["null","boolean"]},"head_pipeline":{"type":["null","object","string","boolean","integer"]},"source_branch":{"type":["null","string"]},"target_branch":{"type":["null","string"]},"merge_commit_sha":{"type":["null","string"]},"user_notes_count":{"type":["null","integer"]},"work_in_progress":{"type":["null","boolean"]},"discussion_locked":{"type":["null","boolean"]},"merge_request_iid":{"type":["null","integer"]},"source_project_id":{"type":["null","integer"]},"squash_commit_sha":{"type":["null","string"]},"target_project_id":{"type":["null","integer"]},"first_contribution":{"type":["null","boolean"]},"approvals_before_merge":{"type":["null","boolean","string","object"]},"task_completion_status":{"type":["null","object"]},"latest_build_started_at":{"type":["null","string"],"format":"date-time"},"latest_build_finished_at":{"type":["null","string"],"format":"date-time"},"force_remove_source_branch":{"type":["null","boolean"]},"should_remove_source_branch":{"type":["null","boolean"]},"merge_when_pipeline_succeeds":{"type":["null","boolean"]},"blocking_discussions_resolved":{"type":["null","boolean"]},"first_deployed_to_production_at":{"type":["null","string"],"format":"date-time"}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@520c8efc[stream=io.airbyte.protocol.models.AirbyteStream@1714cf03[name=gitlab_wex_merge_requests,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"iid":{"type":["null","integer"]},"sha":{"type":["null","string"]},"state":{"type":["null","string"]},"title":{"type":["null","string"]},"labels":{"type":["null","array"],"items":{"type":["null","string"]}},"squash":{"type":["null","boolean"]},"upvotes":{"type":["null","integer"]},"web_url":{"type":["null","string"]},"assignees":{"type":["null","array"],"items":{"type":["null","integer"]}},"author_id":{"type":["null","integer"]},"closed_at":{"type":["null","string"],"format":"date-time"},"downvotes":{"type":["null","integer"]},"merged_at":{"type":["null","string"],"format":"date-time"},"reference":{"type":["null","string"]},"reviewers":{"type":["null","array"]},"created_at":{"type":["null","string"],"format":"date-time"},"project_id":{"type":["null","integer"]},"references":{"type":["null","object"]},"time_stats":{"type":["null","object"]},"updated_at":{"type":["null","string"],"format":"date-time"},"assignee_id":{"type":["null","integer"]},"description":{"type":["null","string"]},"closed_by_id":{"type":["null","integer"]},"merge_status":{"type":["null","string"]},"merged_by_id":{"type":["null","integer"]},"milestone_id":{"type":["null","integer"]},"has_conflicts":{"type":["null","boolean"]},"source_branch":{"type":["null","string"]},"target_branch":{"type":["null","string"]},"merge_commit_sha":{"type":["null","string"]},"user_notes_count":{"type":["null","integer"]},"work_in_progress":{"type":["null","boolean"]},"discussion_locked":{"type":["null","boolean"]},"source_project_id":{"type":["null","integer"]},"squash_commit_sha":{"type":["null","string"]},"target_project_id":{"type":["null","integer"]},"approvals_before_merge":{"type":["null","boolean","string","object"]},"task_completion_status":{"type":["null","object"]},"force_remove_source_branch":{"type":["null","boolean"]},"should_remove_source_branch":{"type":["null","boolean"]},"merge_when_pipeline_succeeds":{"type":["null","boolean"]},"blocking_discussions_resolved":{"type":["null","boolean"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updated_at],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[updated_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@45709e35[stream=io.airbyte.protocol.models.AirbyteStream@8cace89[name=gitlab_wex_pipelines,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"ref":{"type":["null","string"]},"sha":{"type":["null","string"]},"status":{"type":["null","string"]},"web_url":{"type":["null","string"]},"created_at":{"type":["null","string"],"format":"date-time"},"project_id":{"type":["null","integer"]},"updated_at":{"type":["null","string"],"format":"date-time"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updated_at],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[updated_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3e07ca02[stream=io.airbyte.protocol.models.AirbyteStream@f5a7616[name=gitlab_wex_pipelines_extended,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"ref":{"type":["null","string"]},"sha":{"type":["null","string"]},"tag":{"type":["null","boolean"]},"user":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"state":{"type":["null","string"]},"web_url":{"type":["null","string"]},"username":{"type":["null","string"]},"avatar_url":{"type":["null","string"]}}},"status":{"type":["null","string"]},"web_url":{"type":["null","string"]},"coverage":{"type":["null","number","string"]},"duration":{"type":["null","integer"]},"before_sha":{"type":["null","string"]},"created_at":{"type":["null","string"],"format":"date-time"},"project_id":{"type":["null","integer"]},"started_at":{"type":["null","string"],"format":"date-time"},"updated_at":{"type":["null","string"],"format":"date-time"},"finished_at":{"type":["null","string"],"format":"date-time"},"yaml_errors":{"type":["null","string"]},"committed_at":{"type":["null","string"],"format":"date-time"},"detailed_status":{"type":["null","object"]},"queued_duration":{"type":["null","number","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4e1ac0fe[stream=io.airbyte.protocol.models.AirbyteStream@107ae132[name=gitlab_wex_project_members,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"state":{"type":["null","string"]},"web_url":{"type":["null","string"]},"username":{"type":["null","string"]},"avatar_url":{"type":["null","string"]},"created_at":{"type":["null","string"],"format":"date-time"},"expires_at":{"type":["null","string"],"format":"date-time"},"project_id":{"type":["null","integer"]},"access_level":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@102d6ee5[stream=io.airbyte.protocol.models.AirbyteStream@4c1b4030[name=gitlab_wex_projects,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"path":{"type":["null","string"]},"_links":{"type":"object","properties":{"self":{"type":["null","string"]},"events":{"type":["null","string"]},"issues":{"type":["null","string"]},"labels":{"type":["null","string"]},"members":{"type":["null","string"]},"repo_branches":{"type":["null","string"]},"merge_requests":{"type":["null","string"]}}},"topics":{"type":["null","array"]},"web_url":{"type":["null","string"]},"archived":{"type":["null","boolean"]},"tag_list":{"type":["null","array"],"items":{"type":["null","string"]}},"namespace":{"type":"object","properties":{"id":{"type":["null","integer"]},"kind":{"type":["null","string"]},"name":{"type":["null","string"]},"path":{"type":["null","string"]},"web_url":{"type":["null","string"]},"full_path":{"type":["null","string"]},"parent_id":{"type":["null","integer"]},"avatar_url":{"type":["null","string"]}}},"avatar_url":{"type":["null","string"]},"created_at":{"type":["null","string"],"format":"date-time"},"creator_id":{"type":["null","integer"]},"empty_repo":{"type":["null","boolean"]},"readme_url":{"type":["null","string"]},"star_count":{"type":["null","integer"]},"statistics":{"type":"object","properties":{"wiki_size":{"type":["null","integer"]},"commit_count":{"type":["null","integer"]},"storage_size":{"type":["null","integer"]},"packages_size":{"type":["null","integer"]},"snippets_size":{"type":["null","integer"]},"repository_size":{"type":["null","integer"]},"lfs_objects_size":{"type":["null","integer"]},"job_artifacts_size":{"type":["null","integer"]}}},"visibility":{"type":["null","string"]},"description":{"type":["null","string"]},"forks_count":{"type":["null","integer"]},"lfs_enabled":{"type":["null","boolean"]},"permissions":{"type":"object","properties":{"group_access":{"type":["null","object"],"properties":{"access_level":{"type":["null","integer"]},"notification_level":{"type":["null","integer"]}}},"project_access":{"type":["null","object"],"properties":{"access_level":{"type":["null","integer"]},"notification_level":{"type":["null","integer"]}}}}},"public_jobs":{"type":["null","boolean"]},"import_error":{"type":["null","string","boolean"]},"jobs_enabled":{"type":["null","boolean"]},"merge_method":{"type":["null","string"]},"wiki_enabled":{"type":["null","boolean"]},"build_timeout":{"type":["null","integer"]},"import_status":{"type":["null","string"]},"runners_token":{"type":["null","string"]},"ci_config_path":{"type":["null","string"]},"default_branch":{"type":["null","string"]},"issues_enabled":{"type":["null","boolean"]},"emails_disabled":{"type":["null","boolean"]},"ssh_url_to_repo":{"type":["null","string"]},"http_url_to_repo":{"type":["null","string"]},"last_activity_at":{"type":["null","string"],"format":"date-time"},"packages_enabled":{"type":["null","boolean"]},"snippets_enabled":{"type":["null","boolean"]},"open_issues_count":{"type":["null","integer"]},"wiki_access_level":{"type":["null","string"]},"build_git_strategy":{"type":["null","string"]},"pages_access_level":{"type":["null","string"]},"shared_with_groups":{"type":["null","array"]},"auto_devops_enabled":{"type":["null","boolean"]},"builds_access_level":{"type":["null","string"]},"issues_access_level":{"type":["null","string"]},"name_with_namespace":{"type":["null","string"]},"path_with_namespace":{"type":["null","string"]},"build_coverage_regex":{"type":["null","string"]},"ci_default_git_depth":{"type":["null","integer"]},"forking_access_level":{"type":["null","string"]},"requirements_enabled":{"type":["null","boolean"]},"service_desk_address":{"type":["null","string"]},"service_desk_enabled":{"type":["null","boolean"]},"compliance_frameworks":{"type":["null","array"]},"snippets_access_level":{"type":["null","string"]},"analytics_access_level":{"type":["null","string"]},"merge_requests_enabled":{"type":["null","boolean"]},"request_access_enabled":{"type":["null","boolean"]},"shared_runners_enabled":{"type":["null","boolean"]},"operations_access_level":{"type":["null","string"]},"repository_access_level":{"type":["null","string"]},"suggestion_commit_message":{"type":["null","string"]},"container_registry_enabled":{"type":["null","boolean"]},"auto_devops_deploy_strategy":{"type":["null","string"]},"autoclose_referenced_issues":{"type":["null","boolean"]},"can_create_merge_request_in":{"type":["null","boolean"]},"container_expiration_policy":{"type":"object","properties":{"keep_n":{"type":["null","integer"]},"cadence":{"type":["null","string"]},"enabled":{"type":["null","boolean"]},"name_regex":{"type":["null","string"]},"older_than":{"type":["null","string"]},"next_run_at":{"type":["null","string"],"format":"date-time"},"name_regex_keep":{"type":["null","string"]}}},"merge_requests_access_level":{"type":["null","string"]},"auto_cancel_pending_pipelines":{"type":["null","string"]},"ci_forward_deployment_enabled":{"type":["null","boolean"]},"allow_merge_on_skipped_pipeline":{"type":["null","boolean"]},"container_registry_image_prefix":{"type":["null","string"]},"restrict_user_defined_variables":{"type":["null","boolean"]},"security_and_compliance_enabled":{"type":["null","boolean"]},"remove_source_branch_after_merge":{"type":["null","boolean"]},"resolve_outdated_diff_discussions":{"type":["null","boolean"]},"printing_merge_request_link_enabled":{"type":["null","boolean"]},"only_allow_merge_if_pipeline_succeeds":{"type":["null","boolean"]},"external_authorization_classification_label":{"type":["null","string"]},"only_allow_merge_if_all_discussions_are_resolved":{"type":["null","boolean"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@541e747d[failureOrigin=source,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 143,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@13aa6cbd[additionalProperties={attemptNumber=2, jobId=1073}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 143 at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 143 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1649887030141], io.airbyte.config.FailureReason@688b726b[failureOrigin=replication,failureType=,internalMessage=java.lang.RuntimeException: java.io.UncheckedIOException: java.net.SocketException: Socket closed,externalMessage=Something went wrong during replication,metadata=io.airbyte.config.Metadata@7e87a58a[additionalProperties={attemptNumber=2, jobId=1073}],stacktrace=java.util.concurrent.CompletionException: java.lang.RuntimeException: java.io.UncheckedIOException: java.net.SocketException: Socket closed at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: java.lang.RuntimeException: java.io.UncheckedIOException: java.net.SocketException: Socket closed at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:367) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more Caused by: java.io.UncheckedIOException: java.net.SocketException: Socket closed at java.base/java.io.BufferedReader$1.hasNext(BufferedReader.java:574) at java.base/java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1855) at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:292) at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206) at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:161) at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:298) at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.isFinished(DefaultAirbyteDestination.java:141) at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:341) ... 4 more Caused by: java.net.SocketException: Socket closed at java.base/sun.nio.ch.NioSocketImpl.endRead(NioSocketImpl.java:248) at java.base/sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:327) at java.base/sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:350) at java.base/sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:803) at java.base/java.net.Socket$SocketInputStream.read(Socket.java:966) at java.base/sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:270) at java.base/sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:313) at java.base/sun.nio.cs.StreamDecoder.read(StreamDecoder.java:188) at java.base/java.io.InputStreamReader.read(InputStreamReader.java:177) at java.base/java.io.BufferedReader.fill(BufferedReader.java:162) at java.base/java.io.BufferedReader.readLine(BufferedReader.java:329) at java.base/java.io.BufferedReader.readLine(BufferedReader.java:396) at java.base/java.io.BufferedReader$1.hasNext(BufferedReader.java:571) ... 12 more ,retryable=,timestamp=1649887030142]]] 2022-04-13 21:57:10 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-13 21:57:10 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.method: does not have a value in the enumeration [Standard] 2022-04-13 21:57:10 INFO i.a.a.LoggingTrackingClient(track):43 - track. version: 0.35.65-alpha, userId: d34023de-55ec-4c7e-a758-937681bc1a92, action: Connector Jobs, metadata: {job_type=sync, volume_rows=41867, namespace_definition=destination, config.destination.loading_method.method=set, config.source.groups=set, config.destination.credentials.password=set, frequency=360 min, sync_start_time=1649879451439, duration=7579, connector_source_definition_id=5e6175e5-68e1-4c17-bff9-56103bbb0d80, workspace_id=c810ba10-3e93-4c4c-976f-8605746e4520, config.destination.database=set, attempt_stage=ENDED, config.destination.warehouse=set, attempt_id=2, connector_destination=Snowflake, catalog.sync_mode.incremental=set, connector_destination_docker_repository=airbyte/destination-snowflake, config.destination.role=set, table_prefix=true, workspace_name=c810ba10-3e93-4c4c-976f-8605746e4520, config.source.start_date=set, connector_source=Gitlab, config.destination.host=set, connector_source_docker_repository=airbyte/source-gitlab, config.source.private_token=set, config.destination.schema=set, attempt_completion_status=FAILED, config.destination.username=set, catalog.sync_mode.full_refresh=set, connection_id=0c792eae-1d29-4deb-8372-a19f37c8dcce, job_id=1073, connector_source_version=0.1.4, catalog.destination_sync_mode.append=set, connector_destination_version=0.4.24, operation_count=0, config.source.api_url=set, volume_mb=37867027, connector_destination_definition_id=424892c4-daac-4491-b35d-c6688ba547ba}