2022-03-25 20:57:21 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.60-alpha
2022-03-25 20:57:21 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/844/2/logs.log
2022-03-25 20:57:21 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.60-alpha
2022-03-25 20:57:21 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 844 attempt id: 2
2022-03-25 20:57:21 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {EREA.SAP_V_COMPRAS=incremental - append}
2022-03-25 20:57:21 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-03-25 20:57:21 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-redshift:0.3.28 exists...
2022-03-25 20:57:21 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-redshift:0.3.28 was found locally.
2022-03-25 20:57:21 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 844
2022-03-25 20:57:21 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/844/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-redshift:0.3.28 -e WORKER_JOB_ATTEMPT=2 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.35.60-alpha -e WORKER_JOB_ID=844 airbyte/destination-redshift:0.3.28 write --config destination_config.json --catalog destination_catalog.json
2022-03-25 20:57:21 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-oracle:0.3.14 exists...
2022-03-25 20:57:21 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 844
2022-03-25 20:57:21 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-oracle:0.3.14 was found locally.
2022-03-25 20:57:21 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/844/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-oracle:0.3.14 -e WORKER_JOB_ATTEMPT=2 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.35.60-alpha -e WORKER_JOB_ID=844 airbyte/source-oracle:0.3.14 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-03-25 20:57:21 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-03-25 20:57:21 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-03-25 20:57:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-03-25 20:57:22 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-03-25 20:57:22 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-03-25 20:57:22 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-03-25 20:57:22 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-03-25 20:57:22 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-03-25 20:57:23 source > 2022-03-25 20:57:23 INFO i.a.i.s.o.OracleSource(main):175 - starting source: class io.airbyte.integrations.source.oracle.OracleSource
2022-03-25 20:57:23 destination > 2022-03-25 20:57:23 INFO i.a.i.d.r.RedshiftDestination(main):77 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-03-25 20:57:23 source > 2022-03-25 20:57:23 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2022-03-25 20:57:23 destination > 2022-03-25 20:57:23 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-03-25 20:57:23 destination > 2022-03-25 20:57:23 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-03-25 20:57:23 source > 2022-03-25 20:57:23 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: 4767b1e5806047c1b43a8cbb178078e5
2022-03-25 20:57:23 destination > 2022-03-25 20:57:23 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-03-25 20:57:23 source > 2022-03-25 20:57:23 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-03-25 20:57:23 source > 2022-03-25 20:57:23 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: READ
2022-03-25 20:57:23 source > 2022-03-25 20:57:23 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-03-25 20:57:23 destination > 2022-03-25 20:57:23 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-03-25 20:57:24 source > 2022-03-25 20:57:24 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-03-25 20:57:24 source > 2022-03-25 20:57:24 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-03-25 20:57:24 destination > 2022-03-25 20:57:24 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-03-25 20:57:24 destination > 2022-03-25 20:57:24 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-03-25 20:57:24 source > 2022-03-25 20:57:24 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-03-25 20:57:24 source > 2022-03-25 20:57:24 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-03-25 20:57:24 destination > 2022-03-25 20:57:24 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: COPY_S3
2022-03-25 20:57:24 source > 2022-03-25 20:57:24 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-03-25 20:57:24 source > 2022-03-25 20:57:24 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
2022-03-25 20:57:24 source > 2022-03-25 20:57:24 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):108 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='SAP_V_COMPRAS', namespace='EREA'}. Cursor Field: COM_FECHA Value: 2022-03-02T00:00:00.000000Z
2022-03-25 20:57:24 destination > 2022-03-25 20:57:24 INFO i.a.i.d.s.S3DestinationConfig(createS3Client):169 - Creating S3 client...
2022-03-25 20:57:25 destination > 2022-03-25 20:57:25 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_ID_DESC column MANDT (type VARCHAR2[9]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_ID_DESC column ZZADID (type NUMBER[2]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_ID_DESC column DESCRIPCION (type VARCHAR2[105]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_VENTAS column VTA_ALMACEN (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_VENTAS column VTA_FECHA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_VENTAS column VTA_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_VENTAS column VTA_COSTO (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_VENTAS column VTA_VENTA (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COMPRAS column COM_DOCUMENTO (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COMPRAS column COM_FECHA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COMPRAS column COM_ALMACEN (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COMPRAS column COM_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COMPRAS column COM_TIPO (type CHAR[3]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COMPRAS column COM_CANTIDAD (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COMPRAS column COM_PRE_COSTO_EXT (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COMPRAS column COM_PRE_VENTA_EXT (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COMPRAS column COM_PRE_VENTA_UNI (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COMPRAS column COM_INV_ACT (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_AJUSTE_INV column AJU_ALMACEN (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_AJUSTE_INV column AJU_FECHA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_AJUSTE_INV column AJU_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_AJUSTE_INV column AJU_MONTO (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CIAS column CIA_CODIGO (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CIAS column CIA_NOMBRE (type VARCHAR2[90]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PROVEEDOR column MAT_CODIGO (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PROVEEDOR column MAT_DIVISION (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PROVEEDOR column COD_PROD (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PROVEEDOR column PROVEEDOR (type VARCHAR2[105]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PROVEEDOR column ORIGEN (type VARCHAR2[9]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PROVEEDOR column BORRADO_REG_INFO (type VARCHAR2[3]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_BARCODE column BAR_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_BARCODE column BAR_CODIGO (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_BARCODE column BAR_PRINCIPAL (type VARCHAR2[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PRECIO_COSTO column PRE_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PRECIO_COSTO column PRE_COSTO (type NUMBER[11]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PRECIO_COSTO column PRE_COSTO_EXT (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PRECIO_COSTO column INV_MATERIAL (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PRECIO_COSTO column PRE_ALMACEN (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PRECIO_COSTO column PRE_VENTA (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_CP_AJUSTE_INV column AJU_FECHA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_CP_AJUSTE_INV column AJU_ALMACEN (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_CP_AJUSTE_INV column AJU_MONTO (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_CP_AJUSTE_INV column AJU_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_DOCUMENTO (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_FECHA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_ALMACEN_ORIG (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_ALMACEN_DEST (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_TIPO (type VARCHAR2[8]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_CANTIDAD (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_PRE_COSTO_EXT (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_PRE_VENTA_EXT (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_PRE_VENTA_UNI (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_INV_ACT (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_REFERENCIA (type VARCHAR2[48]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_FECHA_ENTREGA (type VARCHAR2[24]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_BWART (type VARCHAR2[9]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRASPASOS column TRA_AUTO (type VARCHAR2[3]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_CAB column DOC_ZPRECIOL (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_CAB column GRUPO_ART (type VARCHAR2[27]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_CAB column FECHA_CREACION (type VARCHAR2[24]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_CAB column STATUS (type VARCHAR2[3]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_CAB column COMENTARIO (type VARCHAR2[6]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_CAB column RAZON (type VARCHAR2[150]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_CAB column FECHA_ULT_COMPRA (type VARCHAR2[24]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_CAB column DESCUENTO (type NUMBER[11]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_CAB column ORG_VENTA (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_CAB column CREADO_POR (type VARCHAR2[36]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COLORES_RGB column COLOR_IMSA (type VARCHAR2[150]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COLORES_RGB column COLOR_RGB (type VARCHAR2[150]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_COLORES_RGB column COLOR_HTML (type VARCHAR2[150]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CASAS column CAS_CODIGO (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CASAS column CAS_NOMBRE (type VARCHAR2[90]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TRX_DOCUMENTO (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TRX_FECHA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TRX_ALMACEN (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TRX_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TRX_TIPO (type VARCHAR2[3]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TRX_CANTIDAD (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TRX_PRE_COSTO_EXT (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TRX_PRE_VENTA_EXT (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TRX_PRE_VENTA_UNI (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column COM_INV_ACT (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TIPO_REPOS (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_TRANSACCIONES column TRX_DIVISION (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS column COM_DOCUMENTO (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS column VTA_FECHA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS column VTA_ALMACEN (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS column VTA_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS column COM_TIPO (type CHAR[3]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS column VTA_CANTIDAD (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS column VTA_PRE_COSTO_EXT (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS column VTA_PRE_VENTA_EXT (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS column VTA_PRE_VENTA_UNI (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS column COM_INV_ACT (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_INVENTARIO column INV_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_INVENTARIO column INV_ALMACEN (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_INVENTARIO column INV_CANTIDAD (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_DIVISIONES column DIV_CODIGO (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_DIVISIONES column DIV_NOMBRE (type VARCHAR2[75]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_REVALORIZACION column REV_ALMACEN (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_REVALORIZACION column REV_FECHA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_REVALORIZACION column REV_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_FIN_REVALORIZACION column REV_MONTO (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_GRUPO_ARTICULO column GRP_CODIGO (type VARCHAR2[27]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_GRUPO_ARTICULO column GRP_NOMBRE (type VARCHAR2[180]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PRECIO_VENTA column PRE_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_PRECIO_VENTA column PRE_VENTA (type NUMBER[11]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS_COS column TIPO (type VARCHAR2[60]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS_COS column CATEGORIA (type VARCHAR2[9]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS_COS column MARCA (type VARCHAR2[90]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS_COS column VENTA (type NUMBER[15]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_VENTAS_COS column FECHA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_POS column DOC_ZPRECIO (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_POS column MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_POS column PROVEEDOR (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_POS column ESTILO (type VARCHAR2[105]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_POS column MONEDA (type VARCHAR2[15]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_POS column PRECIO_ANTERIOR (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_CAMBIO_PRECIO_POS column PRECIO_NUEVO (type NUMBER[13]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_CP_VENTAS column VTA_ALMACEN (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_CP_VENTAS column VTA_FECHA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_CP_VENTAS column VTA_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_CP_VENTAS column VTA_COSTO (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_CP_VENTAS column VTA_VENTA (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_KPI_CP_VENTAS column VTA_CANTIDAD (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_ARANCELES column ARA_MATERIAL (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_ARANCELES column ARA_ARANCEL (type VARCHAR2[51]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_ARANCELES column ARA_CATEGORIA (type VARCHAR2[120]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_CODIGO (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_DESCRIPCION (type VARCHAR2[120]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_MARCA (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_CASA (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_DESC_CASA (type VARCHAR2[90]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_GRUPO_ARTICULO (type VARCHAR2[27]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_JERARQUIA_COD (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_FECHA_ENTRADA_TIENDA (type VARCHAR2[24]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_TEMPORADA (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_ANIO (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_SAITY (type VARCHAR2[120]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_JERARQUIA_DESC (type VARCHAR2[120]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_MUNDO (type VARCHAR2[9]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_MUNDO_DESC (type VARCHAR2[120]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_CATEGORIA_NIV4 (type VARCHAR2[39]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_DESC_CATEGORIA_NIV4 (type VARCHAR2[120]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_DIVISION (type VARCHAR2[12]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_FECHA_COMPRA (type VARCHAR2[24]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_FECHA_CREACION (type VARCHAR2[24]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_COLOR (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_TALLA (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_CATEGORIA (type VARCHAR2[120]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_ESTILO (type VARCHAR2[360]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_ID_AUTODESCUENTO (type NUMBER[2]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_CONSIG (type VARCHAR2[3]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_EVENTO (type VARCHAR2[6]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_TIPO_PRODUCTO (type VARCHAR2[6]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_CICLO_VIDA (type VARCHAR2[8]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_VENTANA_RECEP (type VARCHAR2[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_DESCRIP_CONCAT (type VARCHAR2[296]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_BAR_CODE (type VARCHAR2[54]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_MATERIAL column MAT_ULTIMA_MODIFICACION (type VARCHAR2[24]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_AUTODISCOUNT column STORE_ID (type NUMBER[4]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_AUTODISCOUNT column DISC_ID (type NUMBER[4]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_AUTODISCOUNT column DISC_DESC (type VARCHAR2[100]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_AUTODISCOUNT column PER_SET (type NUMBER[5]) -> Json type io.airbyte.protocol.models.JsonSchemaType@44c13103
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_AUTODISCOUNT column START_DATE (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table SAP_V_AUTODISCOUNT column STOP_DATE (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@1daf3b44
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(queryTableIncremental):261 - Queueing query for table: SAP_V_COMPRAS
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$queryTableIncremental$16):266 - Preparing query for table: SAP_V_COMPRAS
2022-03-25 20:57:28 source > 2022-03-25 20:57:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$queryTableIncremental$16):275 - Executing query for table: SAP_V_COMPRAS
2022-03-25 20:59:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (243 KB)
2022-03-25 20:59:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 2000 (487 KB)
2022-03-25 20:59:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 3000 (732 KB)
2022-03-25 20:59:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 4000 (975 KB)
2022-03-25 20:59:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 5000 (1 MB)
2022-03-25 20:59:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 6000 (1 MB)
2022-03-25 20:59:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 7000 (1 MB)
2022-03-25 20:59:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 8000 (1 MB)
2022-03-25 20:59:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 9000 (2 MB)
2022-03-25 20:59:56 source > 2022-03-25 20:59:56 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream SAP_V_COMPRAS. Records read: 10000
2022-03-25 20:59:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 10000 (2 MB)
2022-03-25 20:59:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 11000 (2 MB)
2022-03-25 20:59:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 12000 (2 MB)
2022-03-25 20:59:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 13000 (3 MB)
2022-03-25 20:59:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 14000 (3 MB)
2022-03-25 20:59:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 15000 (3 MB)
2022-03-25 20:59:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 16000 (3 MB)
2022-03-25 20:59:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 17000 (4 MB)
2022-03-25 20:59:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 18000 (4 MB)
2022-03-25 20:59:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 19000 (4 MB)
2022-03-25 20:59:59 source > 2022-03-25 20:59:59 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream SAP_V_COMPRAS. Records read: 20000
2022-03-25 20:59:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 20000 (4 MB)
2022-03-25 20:59:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 21000 (5 MB)
2022-03-25 20:59:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 22000 (5 MB)
2022-03-25 21:00:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 23000 (5 MB)
2022-03-25 21:00:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 24000 (5 MB)
2022-03-25 21:00:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 25000 (5 MB)
2022-03-25 21:00:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 26000 (6 MB)
2022-03-25 21:00:01 destination > 2022-03-25 21:00:01 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 26213601 bytes
2022-03-25 21:00:01 destination > 2022-03-25 21:00:01 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing SAP_V_COMPRAS: 26159 records
2022-03-25 21:00:01 destination > 2022-03-25 21:00:01 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):95 - S3 upload part size: 20 MB
2022-03-25 21:00:01 destination > 2022-03-25 21:00:01 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'SAP_V_COMPRAS': s3://felix-airbyte-staging/null/SAP_V_COMPRAS/2022_03_25_1648241845332_df9361df-7726-4372-a168-d88473a9afb2.csv
2022-03-25 21:00:01 destination > 2022-03-25 21:00:01 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 20 MB
2022-03-25 21:00:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 27000 (6 MB)
2022-03-25 21:00:01 destination > 2022-03-25 21:00:01 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to felix-airbyte-staging/null/SAP_V_COMPRAS/2022_03_25_1648241845332_df9361df-7726-4372-a168-d88473a9afb2.csv with full ID nbiCCSYDsufehAdTdj365TwgaZD0nJTAkE77ZRblHb7B2h7Mh82fVLkugm4iWHCYF5YAwKbSY.23jFxZduPZpMLnmkjyhv4iCYwrdWZgj4Ze2kFumL1Xk_x877ktGgAp
2022-03-25 21:00:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 28000 (6 MB)
2022-03-25 21:00:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 29000 (6 MB)
2022-03-25 21:00:02 source > 2022-03-25 21:00:01 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream SAP_V_COMPRAS. Records read: 30000
2022-03-25 21:00:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 30000 (7 MB)
2022-03-25 21:00:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 31000 (7 MB)
2022-03-25 21:00:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 32000 (7 MB)
2022-03-25 21:00:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 33000 (7 MB)
2022-03-25 21:00:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 34000 (8 MB)
2022-03-25 21:00:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 35000 (8 MB)
2022-03-25 21:00:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 36000 (8 MB)
2022-03-25 21:00:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 37000 (8 MB)
2022-03-25 21:00:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 38000 (9 MB)
2022-03-25 21:00:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 39000 (9 MB)
2022-03-25 21:00:04 source > 2022-03-25 21:00:04 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream SAP_V_COMPRAS. Records read: 40000
2022-03-25 21:00:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 40000 (9 MB)
2022-03-25 21:00:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 41000 (9 MB)
2022-03-25 21:00:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 42000 (10 MB)
2022-03-25 21:00:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 43000 (10 MB)
2022-03-25 21:00:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 44000 (10 MB)
2022-03-25 21:00:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 45000 (10 MB)
2022-03-25 21:00:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 46000 (11 MB)
2022-03-25 21:00:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 47000 (11 MB)
2022-03-25 21:00:06 source > 2022-03-25 21:00:06 INFO i.a.i.s.r.StateDecoratingIterator(computeNext):60 - State Report: stream name: AirbyteStreamNameNamespacePair{name='SAP_V_COMPRAS', namespace='EREA'}, original cursor field: COM_FECHA, original cursor 2022-03-02T00:00:00.000000Z, cursor field: COM_FECHA, new cursor: 2022-03-25T00:00:00.000000Z
2022-03-25 21:00:06 source > 2022-03-25 21:00:06 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):124 - Closing database connection pool.
2022-03-25 21:00:06 source > 2022-03-25 21:00:06 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):126 - Closed database connection pool.
2022-03-25 21:00:06 source > 2022-03-25 21:00:06 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-03-25 21:00:06 source > 2022-03-25 21:00:06 INFO i.a.i.s.o.OracleSource(main):177 - completed source: class io.airbyte.integrations.source.oracle.OracleSource
2022-03-25 21:00:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 47212 (11 MB)
2022-03-25 21:00:06 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):229 - The main thread is exiting while children non-daemon threads from a connector are still active.
2022-03-25 21:00:06 destination > Ideally, this situation should not happen...
2022-03-25 21:00:06 destination > Please check with maintainers if the connector or library code should safely clean up its threads before quitting instead.
2022-03-25 21:00:06 destination > The main thread is: main (RUNNABLE)
2022-03-25 21:00:06 destination >  Thread stacktrace: java.base/java.lang.Thread.getStackTrace(Thread.java:1610)
2022-03-25 21:00:06 destination >         at io.airbyte.integrations.base.IntegrationRunner.dumpThread(IntegrationRunner.java:264)
2022-03-25 21:00:06 destination >         at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:233)
2022-03-25 21:00:06 destination >         at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190)
2022-03-25 21:00:06 destination >         at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163)
2022-03-25 21:00:06 destination >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-03-25 21:00:06 destination >         at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38)
2022-03-25 21:00:06 destination >         at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163)
2022-03-25 21:00:06 destination >         at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-03-25 21:00:06 destination >         at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:78)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-1 (WAITING)
2022-03-25 21:00:06 destination >  Thread stacktrace: java.base@17.0.1/jdk.internal.misc.Unsafe.park(Native Method)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.locks.LockSupport.park(LockSupport.java:341)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionNode.block(AbstractQueuedSynchronizer.java:506)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ForkJoinPool.unmanagedBlock(ForkJoinPool.java:3463)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3434)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1623)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:420)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:484)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-2 (BLOCKED)
2022-03-25 21:00:06 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-3 (BLOCKED)
2022-03-25 21:00:06 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-4 (BLOCKED)
2022-03-25 21:00:06 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-5 (BLOCKED)
2022-03-25 21:00:06 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-6 (BLOCKED)
2022-03-25 21:00:06 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-7 (BLOCKED)
2022-03-25 21:00:06 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-8 (BLOCKED)
2022-03-25 21:00:06 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-9 (BLOCKED)
2022-03-25 21:00:06 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-2-thread-10 (BLOCKED)
2022-03-25 21:00:06 destination >  Thread stacktrace: app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:483)
2022-03-25 21:00:06 destination >         at app//alex.mojaki.s3upload.StreamTransferManager$UploadTask.call(StreamTransferManager.java:474)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:06 destination >         at java.base@17.0.1/java.lang.Thread.run(Thread.java:833)
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure.
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 21164474 bytes
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing SAP_V_COMPRAS: 21052 records
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'SAP_V_COMPRAS'.
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-03-25 21:00:06 destination > 2022-03-25 21:00:06 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-03-25 21:00:07 destination > 2022-03-25 21:00:07 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to felix-airbyte-staging/null/SAP_V_COMPRAS/2022_03_25_1648241845332_df9361df-7726-4372-a168-d88473a9afb2.csv with id nbiCCSYDs...877ktGgAp]: Finished uploading [Part number 1 containing 15.58 MB]
2022-03-25 21:00:07 destination > 2022-03-25 21:00:07 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to felix-airbyte-staging/null/SAP_V_COMPRAS/2022_03_25_1648241845332_df9361df-7726-4372-a168-d88473a9afb2.csv with id nbiCCSYDs...877ktGgAp]: Completed
2022-03-25 21:00:07 destination > 2022-03-25 21:00:07 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'SAP_V_COMPRAS'.
2022-03-25 21:00:07 destination > 2022-03-25 21:00:07 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):152 - Creating schema in destination if it doesn't exist: null
2022-03-25 21:00:07 destination > 2022-03-25 21:00:07 ERROR i.a.i.d.j.c.CopyConsumerFactory(closeAsOneTransaction):149 - Failed to finalize copy to temp table due to: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-03-25 21:00:07 destination > Position: 29;
2022-03-25 21:00:07 destination > 2022-03-25 21:00:07 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):198 - S3 staging file null/SAP_V_COMPRAS/2022_03_25_1648241845332_df9361df-7726-4372-a168-d88473a9afb2.csv cleaned.
2022-03-25 21:00:07 destination > 2022-03-25 21:00:07 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):202 - Begin cleaning _airbyte_tmp_ibv_sap_v_compras tmp table in destination.
2022-03-25 21:00:08 destination > 2022-03-25 21:00:08 ERROR i.a.i.d.b.BufferedStreamConsumer(close):237 - Close failed.
2022-03-25 21:00:08 destination > java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-03-25 21:00:08 destination > Position: 22;
2022-03-25 21:00:08 destination > Exception in thread "main" java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-03-25 21:00:08 destination > Position: 22;
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source)
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source)
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-03-25 21:00:08 destination > 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-03-25 21:00:08 destination > 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
2022-03-25 21:00:08 destination > 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
2022-03-25 21:00:08 destination > 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
2022-03-25 21:00:08 destination > Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-03-25 21:00:08 destination > Position: 22;
2022-03-25 21:00:08 destination > 	... 13 more
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source)
2022-03-25 21:00:08 destination > 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source)
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source)
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source)
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source)
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source)
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source)
2022-03-25 21:00:08 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source)
2022-03-25 21:00:08 destination > 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-03-25 21:00:08 destination > 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-03-25 21:00:08 destination > 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-03-25 21:00:08 destination > Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-03-25 21:00:08 destination > Position: 22;
2022-03-25 21:00:08 destination > 	... 13 more
2022-03-25 21:00:08 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	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:164) ~[io.airbyte-airbyte-workers-0.35.60-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.60-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.60-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.WorkerException: Destination process exit with code 1. 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.60-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.60-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.60-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.60-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) ~[io.airbyte-airbyte-workers-0.35.60-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-03-25 21:00:08 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@709cb115[status=failed,recordsSynced=47211,bytesSynced=11851577,startTime=1648241841514,endTime=1648242008435,totalStats=io.airbyte.config.SyncStats@3c22bdf4[recordsEmitted=47211,bytesEmitted=11851577,stateMessagesEmitted=1,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@51c10207[streamName=SAP_V_COMPRAS,stats=io.airbyte.config.SyncStats@21f5f16a[recordsEmitted=47211,bytesEmitted=11851577,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-03-25 21:00:08 INFO i.a.w.DefaultReplicationWorker(run):248 - Source output at least one state message
2022-03-25 21:00:08 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@3474e858[state={"cdc":false,"streams":[{"cursor":"2022-03-02T00:00:00.000000Z","stream_name":"SAP_V_COMPRAS","cursor_field":["COM_FECHA"],"stream_namespace":"EREA"}]}]
2022-03-25 21:00:08 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-03-25 21:00:08 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@a81191[standardSyncSummary=io.airbyte.config.StandardSyncSummary@ed6fc5b[status=failed,recordsSynced=47211,bytesSynced=11851577,startTime=1648241841514,endTime=1648242008435,totalStats=io.airbyte.config.SyncStats@3c22bdf4[recordsEmitted=47211,bytesEmitted=11851577,stateMessagesEmitted=1,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@51c10207[streamName=SAP_V_COMPRAS,stats=io.airbyte.config.SyncStats@21f5f16a[recordsEmitted=47211,bytesEmitted=11851577,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]],state=io.airbyte.config.State@3474e858[state={"cdc":false,"streams":[{"cursor":"2022-03-02T00:00:00.000000Z","stream_name":"SAP_V_COMPRAS","cursor_field":["COM_FECHA"],"stream_namespace":"EREA"}]}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@7837b486[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@5f8cf8b6[stream=io.airbyte.protocol.models.AirbyteStream@1fe85e4f[name=SAP_V_COMPRAS,jsonSchema={"type":"object","properties":{"COM_TIPO":{"type":"string"},"COM_FECHA":{"type":"string"},"COM_ALMACEN":{"type":"string"},"COM_INV_ACT":{"type":"number"},"COM_CANTIDAD":{"type":"number"},"COM_MATERIAL":{"type":"string"},"COM_DOCUMENTO":{"type":"string"},"COM_PRE_COSTO_EXT":{"type":"number"},"COM_PRE_VENTA_EXT":{"type":"number"},"COM_PRE_VENTA_UNI":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=null,additionalProperties={}],syncMode=incremental,cursorField=[COM_FECHA],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@26e55dcd[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@63335e13[additionalProperties={attemptNumber=2, jobId=844}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	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$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1648242008433]]]
2022-03-25 21:00:08 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-03-25 21:00:08 INFO i.a.c.p.ConfigRepository(updateConnectionState):637 - Updating connection 69614d5c-9459-459e-96bf-54d39524ed0c state: io.airbyte.config.State@7d7ac92d[state={"cdc":false,"streams":[{"cursor":"2022-03-02T00:00:00.000000Z","stream_name":"SAP_V_COMPRAS","cursor_field":["COM_FECHA"],"stream_namespace":"EREA"}]}]