2022-08-17 14:28:57 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.storage: must be a constant value HTTPS
2022-08-17 14:28:57 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.storage: must be a constant value GCS
2022-08-17 14:28:57 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-08-17 14:28:57 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.storage: must be a constant value S3
2022-08-17 14:28:57 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.storage_account: is missing but it is required, $.storage: must be a constant value AzBlob
2022-08-17 14:28:57 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.user: is missing but it is required, $.host: is missing but it is required, $.storage: must be a constant value SSH
2022-08-17 14:28:57 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.user: is missing but it is required, $.host: is missing but it is required, $.storage: must be a constant value SCP
2022-08-17 14:28:57 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.user: is missing but it is required, $.host: is missing but it is required, $.storage: must be a constant value SFTP
2022-08-17 14:28:57 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/0/logs.log
2022-08-17 14:28:57 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha
2022-08-17 14:28:58 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-file:0.2.18 exists...
2022-08-17 14:28:58 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-file:0.2.18 was found locally.
2022-08-17 14:28:58 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82
2022-08-17 14:28:58 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/0 --log-driver none --name source-file-check-82-0-hbucf --network host -v airbyte_workspace:/data -v /usr/src/priimer-hifasdaterra/volumes/airbyte/local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-file:0.2.18 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/source-file:0.2.18 check --config source_config.json
2022-08-17 14:29:00 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):99 - Checking access to file:///local/prueba.csv...
2022-08-17 14:29:00 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):99 - Check succeeded
2022-08-17 14:29:00 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-08-17 14:29:01 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/0/logs.log
2022-08-17 14:29:01 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha
2022-08-17 14:29:01 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-csv:0.2.10 exists...
2022-08-17 14:29:01 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-csv:0.2.10 was found locally.
2022-08-17 14:29:01 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82
2022-08-17 14:29:01 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/0 --log-driver none --name destination-csv-check-82-0-rwoxp --network host -v airbyte_workspace:/data -v /usr/src/priimer-hifasdaterra/volumes/airbyte/local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-csv:0.2.10 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/destination-csv:0.2.10 check --config source_config.json
2022-08-17 14:29:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-17 14:29:03 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-08-17 14:29:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-17 14:29:03 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.csv.CsvDestination
2022-08-17 14:29:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-17 14:29:03 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-08-17 14:29:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-17 14:29:03 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-08-17 14:29:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-17 14:29:03 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-08-17 14:29:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-17 14:29:03 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.destination.csv.CsvDestination
2022-08-17 14:29:03 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-08-17 14:29:03 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/0/logs.log
2022-08-17 14:29:03 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha
2022-08-17 14:29:03 INFO i.a.w.g.DefaultReplicationWorker(run):116 - start sync worker. job id: 82 attempt id: 0
2022-08-17 14:29:03 INFO i.a.w.g.DefaultReplicationWorker(run):128 - configured sync modes: {null.pruebalocal=full_refresh - overwrite}
2022-08-17 14:29:03 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-08-17 14:29:03 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-csv:0.2.10 exists...
2022-08-17 14:29:04 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-csv:0.2.10 was found locally.
2022-08-17 14:29:04 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82
2022-08-17 14:29:04 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/0 --log-driver none --name destination-csv-write-82-0-ggdza --network host -v airbyte_workspace:/data -v /usr/src/priimer-hifasdaterra/volumes/airbyte/local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-csv:0.2.10 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/destination-csv:0.2.10 write --config destination_config.json --catalog destination_catalog.json
2022-08-17 14:29:04 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-file:0.2.18 exists...
2022-08-17 14:29:04 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-file:0.2.18 was found locally.
2022-08-17 14:29:04 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82
2022-08-17 14:29:04 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/0 --log-driver none --name source-file-read-82-0-galwp --network host -v airbyte_workspace:/data -v /usr/src/priimer-hifasdaterra/volumes/airbyte/local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-file:0.2.18 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/source-file:0.2.18 read --config source_config.json --catalog source_catalog.json
2022-08-17 14:29:04 INFO i.a.w.g.DefaultReplicationWorker(run):170 - Waiting for source and destination threads to complete.
2022-08-17 14:29:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):299 - Replication thread started.
2022-08-17 14:29:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):406 - Destination output thread started.
2022-08-17 14:29:08 destination > 2022-08-17 14:29:08 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-08-17 14:29:08 destination > 2022-08-17 14:29:08 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.csv.CsvDestination
2022-08-17 14:29:08 destination > 2022-08-17 14:29:08 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-08-17 14:29:08 destination > 2022-08-17 14:29:08 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-08-17 14:29:08 destination > 2022-08-17 14:29:08 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-08-17 14:29:08 destination > 2022-08-17 14:29:08 INFO i.a.i.d.c.CsvDestination$CsvConsumer(<init>):140 - initializing consumer.
2022-08-17 14:29:08 source > Reading pruebalocal (file:///local/prueba.csv)...
2022-08-17 14:29:08 source > {"type": "RECORD", "record": {"stream": "pruebalocal", "data": {"COLUMNA2": "VECINO", "Unnamed: 2": NaN, "COLUMNA1": "HOLA"}, "emitted_at": 1660746548000}}
2022-08-17 14:29:08 source > {"type": "RECORD", "record": {"stream": "pruebalocal", "data": {"COLUMNA2": "VECINITO3", "Unnamed: 2": NaN, "COLUMNA1": "HOLITA"}, "emitted_at": 1660746548000}}
2022-08-17 14:29:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):328 - Source has no more messages, closing connection.
2022-08-17 14:29:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):336 - Total records read: 0 (0 bytes)
2022-08-17 14:29:09 INFO i.a.w.g.DefaultReplicationWorker(run):175 - One of source or destination thread complete. Waiting on the other.
2022-08-17 14:29:09 destination > 2022-08-17 14:29:09 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-08-17 14:29:09 destination > 2022-08-17 14:29:09 INFO i.a.i.d.c.CsvDestination$CsvConsumer(close):179 - finalizing consumer.
2022-08-17 14:29:09 destination > 2022-08-17 14:29:09 INFO i.a.i.d.c.CsvDestination$CsvConsumer(close):195 - File output: /local/_airbyte_raw_fapruebalocal.csv
2022-08-17 14:29:09 destination > 2022-08-17 14:29:09 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.destination.csv.CsvDestination
2022-08-17 14:29:09 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Source and destination threads complete.
2022-08-17 14:29:09 INFO i.a.w.g.DefaultReplicationWorker(run):240 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6374468a[status=completed,recordsSynced=0,bytesSynced=0,startTime=1660746543969,endTime=1660746549358,totalStats=io.airbyte.config.SyncStats@6b1f2ef9[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-08-17 14:29:09 INFO i.a.w.g.DefaultReplicationWorker(run):269 - Source did not output any state messages
2022-08-17 14:29:09 WARN i.a.w.g.DefaultReplicationWorker(run):280 - State capture: No state retained.
2022-08-17 14:29:09 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-08-17 14:29:09 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):161 - sync summary: io.airbyte.config.StandardSyncOutput@743163ac[standardSyncSummary=io.airbyte.config.StandardSyncSummary@6730925b[status=completed,recordsSynced=0,bytesSynced=0,startTime=1660746543969,endTime=1660746549358,totalStats=io.airbyte.config.SyncStats@6b1f2ef9[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@5a8d114c[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@280f89f1[stream=io.airbyte.protocol.models.AirbyteStream@57dcb35f[name=fapruebalocal,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"COLUMNA1":{"type":["string","null"]},"COLUMNA2":{"type":["string","null"]},"Unnamed: 2":{"type":["number","null"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-08-17 14:29:09 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...