Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Connection reset by peer] - pgloader fails #1648

Open
Sarcouy opened this issue Mar 3, 2025 · 1 comment
Open

[Connection reset by peer] - pgloader fails #1648

Sarcouy opened this issue Mar 3, 2025 · 1 comment

Comments

@Sarcouy
Copy link

Sarcouy commented Mar 3, 2025 •
edited
Loading

Please provide the following information:

pgloader --version
pgloader version "3.6.a94a0a3"
compiled with SBCL 1.4.0-1.el7

did you test a fresh compile from the source tree? ❌

Compiling pgloader from sources is documented in the README, it's easy to do, and if patches are to be made to fix your bug, you're going to have to build from sources to get the fix anyway…

did you search for other similar issues? => Couldn't find one ❌

how can I reproduce the bug?

  • I don't know, I only see that on my customers production plateformes from which i'm not allowed to export data
  • This bug appears from 1/3 to 2/3 of runs, otherwise it just works as expected

Incude a self-contained pgloader command file.

LOAD DATABASE
		FROM mysql://username:passwd@ip:3306/pmsipilot2
		INTO postgresql://username:passwd@localhost:5432/ods_instance0

with include drop, truncate, create tables, create indexes, batch rows = 10000, batch concurrency = 3,
  reset sequences,
  downcase identifiers
set
work_mem to '64MB',
maintenance_work_mem to '256MB',
search_path to 'pmsipilot, public'

SET MySQL PARAMETERS
net_read_timeout = '240',
net_write_timeout = '240'

cast type datetime to timestamptz drop default drop not null using zero-dates-to-null,
  type date drop not null drop not null drop default using zero-dates-to-null

INCLUDING ONLY TABLE NAMES MATCHING ~/^bda_|^compta_|^cdg_|^sa_|^uo_|^thesaurus/
EXCLUDING TABLE NAMES MATCHING ~/_[0-9]+$/

ALTER SCHEMA 'pmsipilot2' RENAME TO 'pmsipilot'

BEFORE LOAD DO
$$ SELECT pmsipilot.pgloader_drop_tables('qualifact_', true); $$,
$$ SELECT pmsipilot.pgloader_drop_tables('bda_', true); $$,
$$ SELECT pmsipilot.pgloader_drop_tables('compta_', true); $$,
$$ SELECT pmsipilot.pgloader_drop_tables('cdg_', true); $$,
$$ SELECT pmsipilot.pgloader_drop_tables('sa_', true); $$,
$$ SELECT pmsipilot.pgloader_drop_tables('uo_', true); $$,
$$ SELECT pmsipilot.pgloader_drop_tables('thesaurus', true); $$

AFTER LOAD DO
$$ SELECT pmsipilot.grant_select_tables(); $$,
$$ SELECT public.analyze_all_tables_regex('pmsipilot','^qualifact_|^bda_|^compta_|^cdg_|^sa_|^uo_|^thesaurus','_[0-9]+$'); $$,

PASTE HERE THE OUTPUT OF THE PGLOADER COMMAND

2025-03-02T18:10:33.619000+01:00 NOTICE COPY pmsipilot.rss with 1524481 rows estimated [1/4]
2025-03-02T18:10:33.619000+01:00 DEBUG Reader started for pmsipilot.rss
2025-03-02T18:10:33.620000+01:00 DEBUG start pmsipilot.rss   536629
2025-03-02T18:10:33.620000+01:00 DEBUG Finished processing READER for "pmsipilot.rum"    132.859000s
2025-03-02T18:10:33.620000+01:00 DEBUG CONNECTED TO #<MYSQL-CONNECTION mysql://[email protected]:3306/pmsipilot2 {1007D7DBB3}>
2025-03-02T18:10:33.620000+01:00 SQL MySQL: sending query: set net_read_timeout = 240;
2025-03-02T18:10:33.620000+01:00 SQL MySQL: sending query: set net_write_timeout = 240;
2025-03-02T18:10:33.621000+01:00 SQL MySQL: sending query: SELECT `id`, `id_tmp`, `NroRSS`, `etablissement_id`, `nro_rss_reel`, `annee`, `NroSej`, `nro_sej_orig`, `VerClass`, `version_cim10`, `GHM`, `GHM_lu`, `GHS`, `GHS_DialAvtSROS`, `DateEffetTarif`, `Tarif`, `DateNaiss`, `Sexe`, `id_patient`, `qualite_id_patient`, `DateEntree`, `ModeEntree`, `Provenance`, `DateSortie`, `ModeSortie`, `Destination`, `CodePostal`, `DP`, `DR`, `NbRUM`, `NbRUM2`, `NbSeances`, `NbSeances_lu`, `NbSeancesAvtSROS`, `NbSej`, `NbJour`, `NbJourPMSI`, `NbJourPMSIRSS`, `Periode`, `Dateur`, `TypeEXB`, `Val_GHS`, `Val_EXB`, `Val_ReadMemeGHM`, `Val_EXH`, `Val_Dialyses`, `Val_HD`, `Val_Ent1`, `Val_Ent2`, `Val_Ent3`, `Val_Tot_Dialyses`, `Val_Chypb`, `Val_Radioth`, `Val_687`, `Val_688`, `Val_689`, `Val_Prot`, `Val_Ict`, `Val_Rcmi`, `Val_9621`, `Val_9623`, `Val_9624`, `Val_9625`, `Val_9631`, `Val_9632`, `Val_9633`, `Val_Rap`, `Val_Apherese`, `Val_Sdc`, `Sup_Jour`, `Sup_01`, `Sup_02`, `Sup_02_REA`, `Sup_03`, `Sup_04`, `Sup_05`, `Sup_06`, `Sup_13`, `Sup_Organes`, `Sup_Organes_fg`, `Sup_02_max`, `Sup_03_max`, `Sup_Dialyses`, `Sup_Antepartum`, `Prestation_Inter_ETS`, `FactEPMSI`, `cancero`, `buhcd`, `type_po_fg`, `NumeroInnovation`, `NbIvgAnterieures`, `AnneeIvgPrecedente`, `NbNaissancesVivantesAnterieures`, `prise_en_compte_valo_po`, `GhsMinor`, `Val_GHS_Minor`, `GhsAvantInnov`, `Avastin`, `Alimta`, `finess_geo_id`, `SejAmbuMSAP`, `conversion_hc`, `pec_raac`, `forfaitDiabete`, `surveillance_part`, `admin_prod_rh`, `rescrit_tarifaire`, `nb_intervention`, `gradationHDJ`, `sejourHdjexterne`, `SejActeMSAP`, `CodeSupInnovation`, `Sup_Innovation`, `SejHDJ`, `non_programme`, `Val_Cartcell`, `Val_Prot_Ped`, `passage_urgence`, `finess` FROM `rss`
2025-03-02T18:10:33.660000+01:00 NOTICE copy pmsipilot.rum: 1738858 rows done, 988.6 MB,   7.4 MBps
2025-03-02T18:10:33.660000+01:00 DEBUG  stop pmsipilot.rum   | 403770 .. 536670 = 132.9d0
2025-03-02T18:10:33.660000+01:00 DEBUG Writer[2] for pmsipilot.rum is done in 74.118000s
2025-03-02T18:10:33.660000+01:00 DEBUG Finished processing WRITER for "pmsipilot.rum"    74.118000s
2025-03-02T18:10:33.660000+01:00 DEBUG writers-counts[pmsipilot.rum] = 0
2025-03-02T18:10:33.660000+01:00 NOTICE DONE copying pmsipilot.rum in 1m14.118s
2025-03-02T18:10:33.664000+01:00 INFO COPY ON ERROR STOP
2025-03-02T18:10:33.683000+01:00 DEBUG CONNECTED TO #<PGLOADER.PGSQL:PGSQL-CONNECTION pgsql://username@localhost:5432/ods_instance0 {10199DCE63}>
2025-03-02T18:10:33.683000+01:00 DEBUG SET client_encoding TO 'utf8'
2025-03-02T18:10:33.684000+01:00 DEBUG SET work_mem TO '64MB'
2025-03-02T18:10:33.684000+01:00 DEBUG SET maintenance_work_mem TO '256MB'
2025-03-02T18:10:33.684000+01:00 DEBUG SET search_path TO pmsipilot, public
2025-03-02T18:10:33.684000+01:00 DEBUG SET application_name TO 'pgloader'
2025-03-02T18:10:33.685000+01:00 SQL SET search_path TO pmsipilot;
2025-03-02T18:10:33.685000+01:00 INFO pgsql:copy-rows-from-queue[2]: pmsipilot.rum_supplements (id rum_id rss_id
                                                          nrorss nroseq
                                                          etablissement_id
                                                          qte_val_exh
                                                          qte_val_hd
                                                          qte_val_dialyses
                                                          qte_val_ent1
                                                          qte_val_ent2
                                                          qte_val_ent3
                                                          qte_val_tot_dialyses
                                                          qte_val_chypb
                                                          qte_val_radioth
                                                          qte_val_687
                                                          qte_val_688
                                                          qte_val_689
                                                          qte_val_prot
                                                          qte_val_ict
                                                          qte_val_rcmi
                                                          qte_val_9621
                                                          qte_val_9623
                                                          qte_val_9624
                                                          qte_val_9625
                                                          qte_val_9631
                                                          qte_val_9632
                                                          qte_val_9633
                                                          qte_val_rap
                                                          qte_val_apherese
                                                          qte_val_sdc
                                                          qte_sup_jour
                                                          qte_sup_01 qte_sup_02
                                                          qte_sup_03 qte_sup_04
                                                          qte_sup_05 qte_sup_06
                                                          qte_sup_13
                                                          qte_sup_02_rea
                                                          qte_sup_02_max
                                                          qte_sup_03_max
                                                          qte_sup_organes
                                                          qte_sup_organes_fg
                                                          qte_sup_dialyses
                                                          qte_sup_antepartum
                                                          qte_sup_innovation
                                                          qte_val_cartcell
                                                          qte_val_prot_ped)
2025-03-02T18:10:33.718000+01:00 ERROR A thread failed with error: couldn't read from #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}>:
                              Connection reset by peer
2025-03-02T18:10:33.732000+01:00 ERROR Date/time: 2025-03-02-18:10!
An unhandled error condition has been signalled:
   couldn't read from #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}>:
     Connection reset by peer


Backtrace for: #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}>
0: (TRIVIAL-BACKTRACE:PRINT-BACKTRACE-TO-STREAM #<SB-IMPL::STRING-OUTPUT-STREAM {101AEAFEA3}>)
1: (TRIVIAL-BACKTRACE:PRINT-BACKTRACE #<SB-INT:SIMPLE-STREAM-ERROR "~@<~?: ~2I~_~A~:>" {101AEAFBD3}> :OUTPUT NIL :IF-EXISTS :APPEND :VERBOSE NIL)
2: ((LAMBDA (CONDITION) :IN PGLOADER.LOAD:COPY-FROM) #<SB-INT:SIMPLE-STREAM-ERROR "~@<~?: ~2I~_~A~:>" {101AEAFBD3}>)
3: (LPARALLEL.KERNEL::CONDITION-HANDLER #<SB-INT:SIMPLE-STREAM-ERROR "~@<~?: ~2I~_~A~:>" {101AEAFBD3}>)
4: (SB-KERNEL::%SIGNAL #<SB-INT:SIMPLE-STREAM-ERROR "~@<~?: ~2I~_~A~:>" {101AEAFBD3}>)
5: (ERROR SB-INT:SIMPLE-STREAM-ERROR :STREAM #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}> :FORMAT-CONTROL "~@<~?: ~2I~_~A~:>" :FORMAT-ARGUMENTS ("couldn't read from ~S" (#<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}>) "Connection reset by peer"))
6: (SB-IMPL::REFILL-INPUT-BUFFER #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}>)
7: (SB-IMPL::FD-STREAM-READ-N-BYTES #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}> #(7 49 50 52 57 53 54 54 7 49 50 52 57 53 54 54 7 49 48 57 52 50 53 52 24 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 53 52 51 51 51 50 1 49 1 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0) 0 440 NIL)
8: (SB-IMPL::ANSI-STREAM-READ-SEQUENCE #(7 49 50 52 57 53 54 54 7 49 50 52 57 53 54 54 7 49 48 57 52 50 53 52 24 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 53 52 51 51 51 50 1 49 1 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0) #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}> 0 NIL)
9: (READ-SEQUENCE #(7 49 50 52 57 53 54 54 7 49 50 52 57 53 54 54 7 49 48 57 52 50 53 52 24 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 48 53 52 51 51 51 50 1 49 1 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 48 48 48 48 48 8 48 46 48 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0) #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}> :START 0 :END NIL)
10: (QMYND-IMPL::READ-WHOLE-CHUNK 440 #<QMYND-IMPL::MY-PACKET-STREAM 0/440 [111]>)
11: (QMYND-IMPL::PREPARE-NEXT-CHUNK #<QMYND-IMPL::MY-PACKET-STREAM 0/440 [111]>)
12: ((:METHOD QMYND-IMPL:MYSQL-CONNECTION-READ-PACKET (QMYND:MYSQL-BASE-CONNECTION)) #<QMYND-IMPL::MYSQL-INET-CONNECTION {101B932FC3}>) [fast-method]
13: (QMYND-IMPL::PARSE-RESULTSET-ROW-AS-TEXT-VECTOR 49 #(#S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "id" :ORG-NAME "id" :CS-COLL 63 :COLUMN-LENGTH 11 :TYPE 3 :FLAGS 16899 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "rum_id" :ORG-NAME "rum_id" :CS-COLL 63 :COLUMN-LENGTH 11 :TYPE 3 :FLAGS 20489 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "rss_id" :ORG-NAME "rss_id" :CS-COLL 63 :COLUMN-LENGTH 11 :TYPE 3 :FLAGS 20489 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "NroRSS" :ORG-NAME "NroRSS" :CS-COLL 33 :COLUMN-LENGTH 81 :TYPE 254 :FLAGS 16392 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "NroSeq" :ORG-NAME "NroSeq" :CS-COLL 63 :COLUMN-LENGTH 4 :TYPE 1 :FLAGS 16384 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "etablissement_id" :ORG-NAME "etablissement_id" :CS-COLL 63 :COLUMN-LENGTH 11 :TYPE 3 :FLAGS 16392 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_EXH" :ORG-NAME "qte_Val_EXH" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_HD" :ORG-NAME "qte_Val_HD" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Dialyses" :ORG-NAME "qte_Val_Dialyses" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Ent1" :ORG-NAME "qte_Val_Ent1" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Ent2" :ORG-NAME "qte_Val_Ent2" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Ent3" :ORG-NAME "qte_Val_Ent3" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Tot_Dialyses" :ORG-NAME "qte_Val_Tot_Dialyses" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Chypb" :ORG-NAME "qte_Val_Chypb" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Radioth" :ORG-NAME "qte_Val_Radioth" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_687" :ORG-NAME "qte_Val_687" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_688" :ORG-NAME "qte_Val_688" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_689" :ORG-NAME "qte_Val_689" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Prot" :ORG-NAME "qte_Val_Prot" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Ict" :ORG-NAME "qte_Val_Ict" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Rcmi" :ORG-NAME "qte_Val_Rcmi" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9621" :ORG-NAME "qte_Val_9621" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9623" :ORG-NAME "qte_Val_9623" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9624" :ORG-NAME "qte_Val_9624" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9625" :ORG-NAME "qte_Val_9625" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9631" :ORG-NAME "qte_Val_9631" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9632" :ORG-NAME "qte_Val_9632" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9633" :ORG-NAME "qte_Val_9633" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Rap" :ORG-NAME "qte_Val_Rap" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Apherese" :ORG-NAME "qte_Val_Apherese" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Sdc" :ORG-NAME "qte_Val_Sdc" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Jour" :ORG-NAME "qte_Sup_Jour" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_01" :ORG-NAME "qte_Sup_01" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_02" :ORG-NAME "qte_Sup_02" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_03" :ORG-NAME "qte_Sup_03" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_04" :ORG-NAME "qte_Sup_04" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_05" :ORG-NAME "qte_Sup_05" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_06" :ORG-NAME "qte_Sup_06" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_13" :ORG-NAME "qte_Sup_13" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_02_REA" :ORG-NAME "qte_Sup_02_REA" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_02_max" :ORG-NAME "qte_Sup_02_max" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_03_max" :ORG-NAME "qte_Sup_03_max" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Organes" :ORG-NAME "qte_Sup_Organes" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Organes_fg" :ORG-NAME "qte_Sup_Organes_fg" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Dialyses" :ORG-NAME "qte_Sup_Dialyses" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Antepartum" :ORG-NAME "qte_Sup_Antepartum" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Innovation" :ORG-NAME "qte_Sup_Innovation" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Cartcell" :ORG-NAME "qte_Val_Cartcell" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Prot_Ped" :ORG-NAME "qte_Val_Prot_Ped" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL)))
14: (QMYND-IMPL::MAP-RESULTSET-ROWS #<CLOSURE (LAMBDA (PGLOADER.LOAD::ROW) :IN PGLOADER.LOAD:QUEUE-RAW-DATA) {100938774B}> 49 #(#S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "id" :ORG-NAME "id" :CS-COLL 63 :COLUMN-LENGTH 11 :TYPE 3 :FLAGS 16899 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "rum_id" :ORG-NAME "rum_id" :CS-COLL 63 :COLUMN-LENGTH 11 :TYPE 3 :FLAGS 20489 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "rss_id" :ORG-NAME "rss_id" :CS-COLL 63 :COLUMN-LENGTH 11 :TYPE 3 :FLAGS 20489 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "NroRSS" :ORG-NAME "NroRSS" :CS-COLL 33 :COLUMN-LENGTH 81 :TYPE 254 :FLAGS 16392 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "NroSeq" :ORG-NAME "NroSeq" :CS-COLL 63 :COLUMN-LENGTH 4 :TYPE 1 :FLAGS 16384 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "etablissement_id" :ORG-NAME "etablissement_id" :CS-COLL 63 :COLUMN-LENGTH 11 :TYPE 3 :FLAGS 16392 :DECIMALS 0 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_EXH" :ORG-NAME "qte_Val_EXH" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_HD" :ORG-NAME "qte_Val_HD" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Dialyses" :ORG-NAME "qte_Val_Dialyses" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Ent1" :ORG-NAME "qte_Val_Ent1" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Ent2" :ORG-NAME "qte_Val_Ent2" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Ent3" :ORG-NAME "qte_Val_Ent3" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Tot_Dialyses" :ORG-NAME "qte_Val_Tot_Dialyses" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Chypb" :ORG-NAME "qte_Val_Chypb" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Radioth" :ORG-NAME "qte_Val_Radioth" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_687" :ORG-NAME "qte_Val_687" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_688" :ORG-NAME "qte_Val_688" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_689" :ORG-NAME "qte_Val_689" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Prot" :ORG-NAME "qte_Val_Prot" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Ict" :ORG-NAME "qte_Val_Ict" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Rcmi" :ORG-NAME "qte_Val_Rcmi" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9621" :ORG-NAME "qte_Val_9621" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9623" :ORG-NAME "qte_Val_9623" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9624" :ORG-NAME "qte_Val_9624" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9625" :ORG-NAME "qte_Val_9625" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9631" :ORG-NAME "qte_Val_9631" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9632" :ORG-NAME "qte_Val_9632" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_9633" :ORG-NAME "qte_Val_9633" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Rap" :ORG-NAME "qte_Val_Rap" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Apherese" :ORG-NAME "qte_Val_Apherese" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Sdc" :ORG-NAME "qte_Val_Sdc" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Jour" :ORG-NAME "qte_Sup_Jour" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_01" :ORG-NAME "qte_Sup_01" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_02" :ORG-NAME "qte_Sup_02" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_03" :ORG-NAME "qte_Sup_03" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_04" :ORG-NAME "qte_Sup_04" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_05" :ORG-NAME "qte_Sup_05" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_06" :ORG-NAME "qte_Sup_06" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_13" :ORG-NAME "qte_Sup_13" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_02_REA" :ORG-NAME "qte_Sup_02_REA" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_02_max" :ORG-NAME "qte_Sup_02_max" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_03_max" :ORG-NAME "qte_Sup_03_max" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Organes" :ORG-NAME "qte_Sup_Organes" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Organes_fg" :ORG-NAME "qte_Sup_Organes_fg" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Dialyses" :ORG-NAME "qte_Sup_Dialyses" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Antepartum" :ORG-NAME "qte_Sup_Antepartum" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Sup_Innovation" :ORG-NAME "qte_Sup_Innovation" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Cartcell" :ORG-NAME "qte_Val_Cartcell" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL) #S(QMYND-IMPL::COLUMN-DEFINITION-V41-PACKET :CATALOG "def" :SCHEMA "pmsipilot2" :TABLE "rum_supplements" :ORG-TABLE "rum_supplements" :NAME "qte_Val_Prot_Ped" :ORG-NAME "qte_Val_Prot_Ped" :CS-COLL 63 :COLUMN-LENGTH 14 :TYPE 246 :FLAGS 1 :DECIMALS 6 :DEFAULT-VALUE NIL)) :AS-TEXT T :RESULT-TYPE VECTOR)
15: (QMYND-IMPL:SEND-COMMAND-QUERY #<SIMPLE-BASE-STRING "SELECT `id`, `rum_id`, `rss_id`, `NroRSS`, `NroSeq..." (len=818) {101BB4775F}> :ROW-FN #<CLOSURE (LAMBDA (PGLOADER.LOAD::ROW) :IN PGLOADER.LOAD:QUEUE-RAW-DATA) {100938774B}> :AS-TEXT T :RESULT-TYPE VECTOR)
16: (QMYND:MYSQL-QUERY #<QMYND-IMPL::MYSQL-INET-CONNECTION {101B932FC3}> #<SIMPLE-BASE-STRING "SELECT `id`, `rum_id`, `rss_id`, `NroRSS`, `NroSeq..." (len=818) {101BB4775F}> :ROW-FN #<CLOSURE (LAMBDA (PGLOADER.LOAD::ROW) :IN PGLOADER.LOAD:QUEUE-RAW-DATA) {100938774B}> :AS-TEXT T :RESULT-TYPE VECTOR)
17: (PGLOADER.SOURCE.MYSQL::CALL-WITH-ENCODING-HANDLER #<PGLOADER.SOURCE.MYSQL:COPY-MYSQL {101B60CA73}> "rum_supplements" #<CLOSURE (LAMBDA NIL :IN PGLOADER.SOURCES:MAP-ROWS) {101BB47EBB}>)
18: ((:METHOD PGLOADER.SOURCES:MAP-ROWS (PGLOADER.SOURCE.MYSQL:COPY-MYSQL)) #<PGLOADER.SOURCE.MYSQL:COPY-MYSQL {101B60CA73}> :PROCESS-ROW-FN #<CLOSURE (LAMBDA (PGLOADER.LOAD::ROW) :IN PGLOADER.LOAD:QUEUE-RAW-DATA) {100938774B}>) [fast-method]
19: ((:METHOD PGLOADER.LOAD:QUEUE-RAW-DATA (PGLOADER.SOURCES:COPY T T)) #<PGLOADER.SOURCE.MYSQL:COPY-MYSQL {101B60CA73}> #S(LPARALLEL.VECTOR-QUEUE:VECTOR-QUEUE :IMPL #S(LPARALLEL.VECTOR-QUEUE::RAW-QUEUE :DATA #(NIL NIL NIL) :START 1 :COUNT 0) :LOCK #<SB-THREAD:MUTEX "Anonymous lock" (free)> :NOTIFY-PUSH #<SB-THREAD:WAITQUEUE #1=Anonymous condition variable {101A0E5793}> :NOTIFY-POP #<SB-THREAD:WAITQUEUE #1# {101BC3DBC3}>) 1) [fast-method]
20: ((FLET "BODY-FN0" :IN LPARALLEL.KERNEL::MAKE-CHANNELED-TASK))
21: ((LAMBDA NIL :IN LPARALLEL.KERNEL::MAKE-CHANNELED-TASK))
22: (LPARALLEL.KERNEL::EXEC-TASK/WORKER #<unavailable argument> #S(LPARALLEL.KERNEL::WORKER :HANDSHAKE/FROM-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1="Anonymous lock" (free)> :CVAR #<SB-THREAD:WAITQUEUE #2=Anonymous condition variable {1007C455E3}>) :HANDSHAKE/TO-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR #<SB-THREAD:WAITQUEUE #2# {1009386C73}>) :EXIT-NOTIFICATION #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR NIL) :THREAD #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}> :RUNNING-CATEGORY :DEFAULT :INDEX 3 :TASKS #S(LPARALLEL.SPIN-QUEUE:SPIN-QUEUE :HEAD (LPARALLEL.SPIN-QUEUE::DUMMY (#<CLOSURE #3=(LAMBDA NIL :IN LPARALLEL.KERNEL::MAKE-CHANNELED-TASK) {1007CEC96B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC99B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9CB}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9FB}> . :DEFAULT) (#<CLOSURE #3# {1007CECA2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECABB}> . :DEFAULT) (#<CLOSURE #3# {1007CECAEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECB1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECBAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECBDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECC0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC6B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC9B}> . :DEFAULT) (#<CLOSURE #3# {1007CECCCB}> . :DEFAULT) (#<CLOSURE #3# {1007CECCFB}> . :DEFAULT) (#<CLOSURE #3# {1007CECD2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECDBB}> . :DEFAULT) (#<CLOSURE #3# {1007CECDEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECE1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECEAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECEDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECF0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF6B}> . :DEFAULT) . #4=((#<CLOSURE #3# {1007CECF9B}> . :DEFAULT))) :TAIL #4#)))
23: (LPARALLEL.KERNEL::WORKER-LOOP #<LPARALLEL.KERNEL:KERNEL :NAME "lparallel" :WORKER-COUNT 4 :USE-CALLER NIL :ALIVE T :SPIN-COUNT 2000 {1009860363}> #S(LPARALLEL.KERNEL::WORKER :HANDSHAKE/FROM-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1="Anonymous lock" (free)> :CVAR #<SB-THREAD:WAITQUEUE #2=Anonymous condition variable {1007C455E3}>) :HANDSHAKE/TO-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR #<SB-THREAD:WAITQUEUE #2# {1009386C73}>) :EXIT-NOTIFICATION #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR NIL) :THREAD #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}> :RUNNING-CATEGORY :DEFAULT :INDEX 3 :TASKS #S(LPARALLEL.SPIN-QUEUE:SPIN-QUEUE :HEAD (LPARALLEL.SPIN-QUEUE::DUMMY (#<CLOSURE #3=(LAMBDA NIL :IN LPARALLEL.KERNEL::MAKE-CHANNELED-TASK) {1007CEC96B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC99B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9CB}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9FB}> . :DEFAULT) (#<CLOSURE #3# {1007CECA2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECABB}> . :DEFAULT) (#<CLOSURE #3# {1007CECAEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECB1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECBAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECBDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECC0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC6B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC9B}> . :DEFAULT) (#<CLOSURE #3# {1007CECCCB}> . :DEFAULT) (#<CLOSURE #3# {1007CECCFB}> . :DEFAULT) (#<CLOSURE #3# {1007CECD2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECDBB}> . :DEFAULT) (#<CLOSURE #3# {1007CECDEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECE1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECEAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECEDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECF0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF6B}> . :DEFAULT) . #4=((#<CLOSURE #3# {1007CECF9B}> . :DEFAULT))) :TAIL #4#)))
24: (LPARALLEL.KERNEL::%CALL-WITH-TASK-HANDLER #<unavailable argument>)
25: ((LAMBDA NIL :IN LPARALLEL.KERNEL::CALL-WITH-WORKER-CONTEXT))
26: (LPARALLEL.KERNEL::CALL-WITH-WORKER-CONTEXT #<CLOSURE (LAMBDA NIL :IN LPARALLEL.KERNEL::ENTER-WORKER-LOOP) {1009386C5B}> #<FUNCTION FUNCALL> #<LPARALLEL.KERNEL:KERNEL :NAME "lparallel" :WORKER-COUNT 4 :USE-CALLER NIL :ALIVE T :SPIN-COUNT 2000 {1009860363}> #S(LPARALLEL.KERNEL::WORKER :HANDSHAKE/FROM-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1="Anonymous lock" (free)> :CVAR #<SB-THREAD:WAITQUEUE #2=Anonymous condition variable {1007C455E3}>) :HANDSHAKE/TO-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR #<SB-THREAD:WAITQUEUE #2# {1009386C73}>) :EXIT-NOTIFICATION #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR NIL) :THREAD #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}> :RUNNING-CATEGORY :DEFAULT :INDEX 3 :TASKS #S(LPARALLEL.SPIN-QUEUE:SPIN-QUEUE :HEAD (LPARALLEL.SPIN-QUEUE::DUMMY (#<CLOSURE #3=(LAMBDA NIL :IN LPARALLEL.KERNEL::MAKE-CHANNELED-TASK) {1007CEC96B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC99B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9CB}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9FB}> . :DEFAULT) (#<CLOSURE #3# {1007CECA2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECABB}> . :DEFAULT) (#<CLOSURE #3# {1007CECAEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECB1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECBAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECBDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECC0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC6B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC9B}> . :DEFAULT) (#<CLOSURE #3# {1007CECCCB}> . :DEFAULT) (#<CLOSURE #3# {1007CECCFB}> . :DEFAULT) (#<CLOSURE #3# {1007CECD2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECDBB}> . :DEFAULT) (#<CLOSURE #3# {1007CECDEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECE1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECEAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECEDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECF0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF6B}> . :DEFAULT) . #4=((#<CLOSURE #3# {1007CECF9B}> . :DEFAULT))) :TAIL #4#)))
27: ((LAMBDA NIL :IN LPARALLEL.KERNEL::MAKE-WORKER-THREAD))
28: ((LAMBDA NIL :IN BORDEAUX-THREADS::BINDING-DEFAULT-SPECIALS))
29: ((FLET "WITHOUT-INTERRUPTS-BODY-4" :IN SB-THREAD::INITIAL-THREAD-FUNCTION-TRAMPOLINE))
30: ((FLET SB-THREAD::WITH-MUTEX-THUNK :IN SB-THREAD::INITIAL-THREAD-FUNCTION-TRAMPOLINE))
31: ((FLET "WITHOUT-INTERRUPTS-BODY-1" :IN SB-THREAD::CALL-WITH-MUTEX))
32: (SB-THREAD::CALL-WITH-MUTEX #<CLOSURE (FLET SB-THREAD::WITH-MUTEX-THUNK :IN SB-THREAD::INITIAL-THREAD-FUNCTION-TRAMPOLINE) {7FFFED1EED2B}> #<SB-THREAD:MUTEX "thread result lock" owner: #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}>> NIL T NIL)
33: (SB-THREAD::INITIAL-THREAD-FUNCTION-TRAMPOLINE #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}> NIL #<CLOSURE (LAMBDA NIL :IN BORDEAUX-THREADS::BINDING-DEFAULT-SPECIALS) {10098617EB}> (#<SB-THREAD:THREAD #1="lparallel" RUNNING {1009861843}> #<SB-THREAD:THREAD #1# RUNNING {10098612F3}> #<SB-THREAD:THREAD #1# RUNNING {1009860DA3}> #<SB-THREAD:THREAD #1# RUNNING {1009860853}> #<SB-THREAD:THREAD #1# RUNNING {1007BEB213}> #<SB-THREAD:THREAD "main thread" RUNNING {1007B8DE83}>) NIL NIL NIL NIL)
34: ("foreign function: call_into_lisp")
35: ("foreign function: new_thread_trampoline")

2025-03-02T18:10:33.733000+01:00 ERROR A thread failed with error: Couldn't write to #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}>:
                              Broken pipe
2025-03-02T18:10:33.735000+01:00 ERROR Date/time: 2025-03-02-18:10!
An unhandled error condition has been signalled:
   Couldn't write to #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}>:
     Broken pipe


Backtrace for: #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}>
0: (TRIVIAL-BACKTRACE:PRINT-BACKTRACE-TO-STREAM #<SB-IMPL::STRING-OUTPUT-STREAM {101B3EDD53}>)
1: (TRIVIAL-BACKTRACE:PRINT-BACKTRACE #<SB-INT:SIMPLE-STREAM-ERROR "~@<~?: ~2I~_~A~:>" {101B3EDBA3}> :OUTPUT NIL :IF-EXISTS :APPEND :VERBOSE NIL)
2: ((LAMBDA (CONDITION) :IN PGLOADER.LOAD:COPY-FROM) #<SB-INT:SIMPLE-STREAM-ERROR "~@<~?: ~2I~_~A~:>" {101B3EDBA3}>)
3: (LPARALLEL.KERNEL::CONDITION-HANDLER #<SB-INT:SIMPLE-STREAM-ERROR "~@<~?: ~2I~_~A~:>" {101B3EDBA3}>)
4: (SB-KERNEL::%SIGNAL #<SB-INT:SIMPLE-STREAM-ERROR "~@<~?: ~2I~_~A~:>" {101B3EDBA3}>)
5: (ERROR SB-INT:SIMPLE-STREAM-ERROR :STREAM #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}> :FORMAT-CONTROL "~@<~?: ~2I~_~A~:>" :FORMAT-ARGUMENTS ("Couldn't write to ~S" (#<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}>) "Broken pipe"))
6: (SB-IMPL::FLUSH-OUTPUT-BUFFER #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}>)
7: (FORCE-OUTPUT #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}>)
8: (QMYND-IMPL::WRITE-WIRE-PACKET #<SB-SYS:FD-STREAM for "socket 10.29.101.68:60290, peer: 10.29.101.67:3306" {1007BFF3F3}> #(1) :SEQUENCE-ID 0)
9: ((:METHOD QMYND-IMPL:MYSQL-CONNECTION-WRITE-PACKET (QMYND:MYSQL-BASE-CONNECTION T)) #<QMYND-IMPL::MYSQL-INET-CONNECTION {101B932FC3}> #(1)) [fast-method]
10: (QMYND-IMPL:SEND-COMMAND-QUIT)
11: ((:METHOD QMYND:MYSQL-DISCONNECT (QMYND:MYSQL-BASE-CONNECTION)) #<QMYND-IMPL::MYSQL-INET-CONNECTION {101B932FC3}>) [fast-method]
12: ((:METHOD PGLOADER.CONNECTION:CLOSE-CONNECTION (PGLOADER.SOURCE.MYSQL:MYSQL-CONNECTION)) #<PGLOADER.SOURCE.MYSQL:MYSQL-CONNECTION mysql://[email protected]:3306/pmsipilot2 {101B60C873}>) [fast-method]
13: ((FLET "CLEANUP-FUN-11" :IN PGLOADER.SOURCES:MAP-ROWS)) [cleanup]
14: ((:METHOD PGLOADER.SOURCES:MAP-ROWS (PGLOADER.SOURCE.MYSQL:COPY-MYSQL)) #<PGLOADER.SOURCE.MYSQL:COPY-MYSQL {101B60CA73}> :PROCESS-ROW-FN #<CLOSURE (LAMBDA (PGLOADER.LOAD::ROW) :IN PGLOADER.LOAD:QUEUE-RAW-DATA) {100938774B}>) [fast-method]
15: ((:METHOD PGLOADER.LOAD:QUEUE-RAW-DATA (PGLOADER.SOURCES:COPY T T)) #<PGLOADER.SOURCE.MYSQL:COPY-MYSQL {101B60CA73}> #S(LPARALLEL.VECTOR-QUEUE:VECTOR-QUEUE :IMPL #S(LPARALLEL.VECTOR-QUEUE::RAW-QUEUE :DATA #(NIL NIL NIL) :START 1 :COUNT 0) :LOCK #<SB-THREAD:MUTEX "Anonymous lock" (free)> :NOTIFY-PUSH #<SB-THREAD:WAITQUEUE #1=Anonymous condition variable {101A0E5793}> :NOTIFY-POP #<SB-THREAD:WAITQUEUE #1# {101BC3DBC3}>) 1) [fast-method]
16: ((FLET "BODY-FN0" :IN LPARALLEL.KERNEL::MAKE-CHANNELED-TASK))
17: ((LAMBDA NIL :IN LPARALLEL.KERNEL::MAKE-CHANNELED-TASK))
18: (LPARALLEL.KERNEL::EXEC-TASK/WORKER #<unavailable argument> #S(LPARALLEL.KERNEL::WORKER :HANDSHAKE/FROM-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1="Anonymous lock" (free)> :CVAR #<SB-THREAD:WAITQUEUE #2=Anonymous condition variable {1007C455E3}>) :HANDSHAKE/TO-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR #<SB-THREAD:WAITQUEUE #2# {1009386C73}>) :EXIT-NOTIFICATION #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR NIL) :THREAD #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}> :RUNNING-CATEGORY :DEFAULT :INDEX 3 :TASKS #S(LPARALLEL.SPIN-QUEUE:SPIN-QUEUE :HEAD (LPARALLEL.SPIN-QUEUE::DUMMY (#<CLOSURE #3=(LAMBDA NIL :IN LPARALLEL.KERNEL::MAKE-CHANNELED-TASK) {1007CEC96B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC99B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9CB}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9FB}> . :DEFAULT) (#<CLOSURE #3# {1007CECA2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECABB}> . :DEFAULT) (#<CLOSURE #3# {1007CECAEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECB1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECBAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECBDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECC0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC6B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC9B}> . :DEFAULT) (#<CLOSURE #3# {1007CECCCB}> . :DEFAULT) (#<CLOSURE #3# {1007CECCFB}> . :DEFAULT) (#<CLOSURE #3# {1007CECD2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECDBB}> . :DEFAULT) (#<CLOSURE #3# {1007CECDEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECE1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECEAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECEDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECF0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF6B}> . :DEFAULT) . #4=((#<CLOSURE #3# {1007CECF9B}> . :DEFAULT))) :TAIL #4#)))
19: (LPARALLEL.KERNEL::WORKER-LOOP #<LPARALLEL.KERNEL:KERNEL :NAME "lparallel" :WORKER-COUNT 4 :USE-CALLER NIL :ALIVE T :SPIN-COUNT 2000 {1009860363}> #S(LPARALLEL.KERNEL::WORKER :HANDSHAKE/FROM-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1="Anonymous lock" (free)> :CVAR #<SB-THREAD:WAITQUEUE #2=Anonymous condition variable {1007C455E3}>) :HANDSHAKE/TO-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR #<SB-THREAD:WAITQUEUE #2# {1009386C73}>) :EXIT-NOTIFICATION #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR NIL) :THREAD #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}> :RUNNING-CATEGORY :DEFAULT :INDEX 3 :TASKS #S(LPARALLEL.SPIN-QUEUE:SPIN-QUEUE :HEAD (LPARALLEL.SPIN-QUEUE::DUMMY (#<CLOSURE #3=(LAMBDA NIL :IN LPARALLEL.KERNEL::MAKE-CHANNELED-TASK) {1007CEC96B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC99B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9CB}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9FB}> . :DEFAULT) (#<CLOSURE #3# {1007CECA2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECABB}> . :DEFAULT) (#<CLOSURE #3# {1007CECAEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECB1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECBAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECBDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECC0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC6B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC9B}> . :DEFAULT) (#<CLOSURE #3# {1007CECCCB}> . :DEFAULT) (#<CLOSURE #3# {1007CECCFB}> . :DEFAULT) (#<CLOSURE #3# {1007CECD2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECDBB}> . :DEFAULT) (#<CLOSURE #3# {1007CECDEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECE1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECEAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECEDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECF0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF6B}> . :DEFAULT) . #4=((#<CLOSURE #3# {1007CECF9B}> . :DEFAULT))) :TAIL #4#)))
20: (LPARALLEL.KERNEL::%CALL-WITH-TASK-HANDLER #<unavailable argument>)
21: ((LAMBDA NIL :IN LPARALLEL.KERNEL::CALL-WITH-WORKER-CONTEXT))
22: (LPARALLEL.KERNEL::CALL-WITH-WORKER-CONTEXT #<CLOSURE (LAMBDA NIL :IN LPARALLEL.KERNEL::ENTER-WORKER-LOOP) {1009386C5B}> #<FUNCTION FUNCALL> #<LPARALLEL.KERNEL:KERNEL :NAME "lparallel" :WORKER-COUNT 4 :USE-CALLER NIL :ALIVE T :SPIN-COUNT 2000 {1009860363}> #S(LPARALLEL.KERNEL::WORKER :HANDSHAKE/FROM-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1="Anonymous lock" (free)> :CVAR #<SB-THREAD:WAITQUEUE #2=Anonymous condition variable {1007C455E3}>) :HANDSHAKE/TO-WORKER #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR #<SB-THREAD:WAITQUEUE #2# {1009386C73}>) :EXIT-NOTIFICATION #S(LPARALLEL.CONS-QUEUE:CONS-QUEUE :IMPL #S(LPARALLEL.RAW-QUEUE:RAW-QUEUE :HEAD NIL :TAIL NIL) :LOCK #<SB-THREAD:MUTEX #1# (free)> :CVAR NIL) :THREAD #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}> :RUNNING-CATEGORY :DEFAULT :INDEX 3 :TASKS #S(LPARALLEL.SPIN-QUEUE:SPIN-QUEUE :HEAD (LPARALLEL.SPIN-QUEUE::DUMMY (#<CLOSURE #3=(LAMBDA NIL :IN LPARALLEL.KERNEL::MAKE-CHANNELED-TASK) {1007CEC96B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC99B}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9CB}> . :DEFAULT) (#<CLOSURE #3# {1007CEC9FB}> . :DEFAULT) (#<CLOSURE #3# {1007CECA2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECA8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECABB}> . :DEFAULT) (#<CLOSURE #3# {1007CECAEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECB1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECB7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECBAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECBDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECC0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC6B}> . :DEFAULT) (#<CLOSURE #3# {1007CECC9B}> . :DEFAULT) (#<CLOSURE #3# {1007CECCCB}> . :DEFAULT) (#<CLOSURE #3# {1007CECCFB}> . :DEFAULT) (#<CLOSURE #3# {1007CECD2B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD5B}> . :DEFAULT) (#<CLOSURE #3# {1007CECD8B}> . :DEFAULT) (#<CLOSURE #3# {1007CECDBB}> . :DEFAULT) (#<CLOSURE #3# {1007CECDEB}> . :DEFAULT) (#<CLOSURE #3# {1007CECE1B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE4B}> . :DEFAULT) (#<CLOSURE #3# {1007CECE7B}> . :DEFAULT) (#<CLOSURE #3# {1007CECEAB}> . :DEFAULT) (#<CLOSURE #3# {1007CECEDB}> . :DEFAULT) (#<CLOSURE #3# {1007CECF0B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF3B}> . :DEFAULT) (#<CLOSURE #3# {1007CECF6B}> . :DEFAULT) . #4=((#<CLOSURE #3# {1007CECF9B}> . :DEFAULT))) :TAIL #4#)))
23: ((LAMBDA NIL :IN LPARALLEL.KERNEL::MAKE-WORKER-THREAD))
24: ((LAMBDA NIL :IN BORDEAUX-THREADS::BINDING-DEFAULT-SPECIALS))
25: ((FLET "WITHOUT-INTERRUPTS-BODY-4" :IN SB-THREAD::INITIAL-THREAD-FUNCTION-TRAMPOLINE))
26: ((FLET SB-THREAD::WITH-MUTEX-THUNK :IN SB-THREAD::INITIAL-THREAD-FUNCTION-TRAMPOLINE))
27: ((FLET "WITHOUT-INTERRUPTS-BODY-1" :IN SB-THREAD::CALL-WITH-MUTEX))
28: (SB-THREAD::CALL-WITH-MUTEX #<CLOSURE (FLET SB-THREAD::WITH-MUTEX-THUNK :IN SB-THREAD::INITIAL-THREAD-FUNCTION-TRAMPOLINE) {7FFFED1EED2B}> #<SB-THREAD:MUTEX "thread result lock" owner: #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}>> NIL T NIL)
29: (SB-THREAD::INITIAL-THREAD-FUNCTION-TRAMPOLINE #<SB-THREAD:THREAD "lparallel" RUNNING {1009861843}> NIL #<CLOSURE (LAMBDA NIL :IN BORDEAUX-THREADS::BINDING-DEFAULT-SPECIALS) {10098617EB}> (#<SB-THREAD:THREAD #1="lparallel" RUNNING {1009861843}> #<SB-THREAD:THREAD #1# RUNNING {10098612F3}> #<SB-THREAD:THREAD #1# RUNNING {1009860DA3}> #<SB-THREAD:THREAD #1# RUNNING {1009860853}> #<SB-THREAD:THREAD #1# RUNNING {1007BEB213}> #<SB-THREAD:THREAD "main thread" RUNNING {1007B8DE83}>) NIL NIL NIL NIL)
30: ("foreign function: call_into_lisp")
31: ("foreign function: new_thread_trampoline")

2025-03-02T18:10:33.735000+01:00 NOTICE COPY pmsipilot.rss_cancero with 1524407 rows estimated [3/4]
2025-03-02T18:10:33.735000+01:00 DEBUG Reader started for pmsipilot.rss_cancero
2025-03-02T18:10:33.735000+01:00 DEBUG start pmsipilot.rss_cancero   536745
2025-03-02T18:10:33.737000+01:00 DEBUG CONNECTED TO #<MYSQL-CONNECTION mysql://[email protected]:3306/pmsipilot2 {1007D7C153}>
2025-03-02T18:10:33.737000+01:00 SQL MySQL: sending query: set net_read_timeout = 240;
2025-03-02T18:10:33.737000+01:00 SQL MySQL: sending query: set net_write_timeout = 240;
2025-03-02T18:10:33.737000+01:00 SQL MySQL: sending query: SELECT `rss_id`, `etablissement_id`, `annee`, `seuil_chimio`, `seuil_radio`, `seuil_chir_sein`, `seuil_chir_orl`, `seuil_chir_thoracique`, `seuil_chir_urologique`, `seuil_chir_digestive`, `seuil_chir_estomac`, `seuil_chir_foie`, `seuil_chir_pancreas`, `seuil_chir_oesophage`, `seuil_chir_rectum`, `seuil_chir_ovaire`, `seuil_chir_gynecologique` FROM `rss_cancero`
2025-03-02T18:10:33.740000+01:00 INFO Stopping monitor

This is mariadb's output that

2025-03-02 18:10:34 175449 [Warning] Aborted connection 175449 to db: 'pmsipilot2' user: 'username' host: '10.29.101.68' (Got an error writing communication packets)
2025-03-02 18:10:34 175448 [Warning] Aborted connection 175448 to db: 'pmsipilot2' user: 'username host: '10.29.101.68' (Got an error writing communication packets)

2025-03-02 18:10:34 CET [60491]: [1-1] app=pgloader,user=usernamedb=ods_instance0LOG:  durée : 533325.562 ms, instruction :
        copy pmsipilot.rum (id,id_tmp,rss_id,etablissement_id, [...]finess_geo_id,conversion_hc,pec_raac,surveillance_part,admin_prod_rh,rescrit_tarifaire,nb_intervention,codesupinnovation,sup_innovation,non_programme,val_cartcell,val_prot_ped,passage_urgence) FROM STDIN
2025-03-02 18:10:34 CET [65621]: [1-1] app=pgloader,user=usernamedb=ods_instance0LOG:  durée : 133051.425 ms, instruction :
        copy pmsipilot.rss (id,id_tmp,n[...]_urgence,finess) FROM STDIN


MariaDB version  : 10.11.7

Postgresql version : 12.14.1

OS : CentOS7

At this point, the data copying stopped, and pgloader returned an exit code of 1, causing my pipeline to fail.
@Sarcouy
Copy link
Author

Sarcouy commented Mar 5, 2025

for information :
This is happening to multiple customers.
Even when the vm of pgloader and the vm of mariadb are on the same hypervisor, the network is fine.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@Sarcouy