Temporal cancelling jobs with no clear reason

[tarsisazevedo]

I run an Airbyte 0.40.26 deployment on GKE and I am getting an error where Temporal is killing the job with no clear reason.

Job log bellow:

errors: $.auth_type: must be a constant value Client, $.auth_type: does not have a value in the enumeration [Client]
2024-02-03 18:52:28 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/8840/0/logs.log
2024-02-03 18:53:04 �[43mdestination�[0m > 2024-02-03 18:53:03 �[32mINFO�[m i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2024-02-03 18:53:04 �[44msource�[0m > Starting syncing SourcePipedrive
2024-02-03 18:52:28 �[32mINFO�[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed. 
errors: $.api_token: object found, string expected
2024-02-03 18:52:55 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/8840/0/logs.log
2024-02-03 18:52:55 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2024-02-03 18:52:55 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2024-02-03 18:52:57 �[32mINFO�[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2024-02-03 18:52:57 �[32mINFO�[m i.a.c.EnvConfigs(getEnvOrDefault):1161 - Using default value for environment variable METRIC_CLIENT: ''
2024-02-03 18:52:57 �[33mWARN�[m i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2024-02-03 18:52:57 �[32mINFO�[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(run):142 - start sync worker. job id: 8840 attempt id: 0
2024-02-03 18:52:57 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:52:57 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2024-02-03 18:52:57 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(run):157 - configured sync modes: {null.stages=full_refresh - append, null.activities=full_refresh - append, null.deals=full_refresh - append, null.activity_fields=full_refresh - append, null.leads=full_refresh - append, null.organizations=full_refresh - append, null.products=full_refresh - append, null.filters=full_refresh - append, null.lead_labels=full_refresh - append, null.organization_fields=full_refresh - append, null.notes=full_refresh - append, null.persons=full_refresh - append, null.deal_fields=full_refresh - append, null.deal_products=full_refresh - append, null.activity_types=full_refresh - append, null.currencies=full_refresh - append, null.product_fields=full_refresh - append, null.pipelines=full_refresh - append, null.person_fields=full_refresh - append, null.users=full_refresh - append, null.deals_deleted=full_refresh - append, null.note_fields=full_refresh - append}
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteDestination(start):72 - Running destination...
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):101 - Attempting to start pod = destination-kafka-write-8840-0-gkdpo for airbyte/destination-kafka:0.1.10 with resources io.airbyte.config.ResourceRequirements@41590e8f[cpuRequest=500m,cpuLimit=500m,memoryRequest=1Gi,memoryLimit=1Gi]
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):104 - destination-kafka-write-8840-0-gkdpo stdoutLocalPort = 9016
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):107 - destination-kafka-write-8840-0-gkdpo stderrLocalPort = 9017
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stdout socket server...
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):620 - Creating stderr socket server...
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):533 - Creating pod destination-kafka-write-8840-0-gkdpo...
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):313 - Waiting for init container to be ready before copying files...
2024-02-03 18:52:57 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):317 - Init container present..
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):320 - Init container ready..
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):564 - Copying files...
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: destination_config.json
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/1f175dc8-270d-4c15-bb3c-1832869f88ac/destination_config.json bigdata-airbyte/destination-kafka-write-8840-0-gkdpo:/config/destination_config.json -c init
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: destination_catalog.json
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/6becd199-3bcd-4686-9e8b-21902d8dabc9/destination_catalog.json bigdata-airbyte/destination-kafka-write-8840-0-gkdpo:/config/destination_catalog.json -c init
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: FINISHED_UPLOADING
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/e10438fe-7c17-431a-88b6-2d925e91d4c8/FINISHED_UPLOADING bigdata-airbyte/destination-kafka-write-8840-0-gkdpo:/config/FINISHED_UPLOADING -c init
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:52:59 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):567 - Waiting until pod is ready...
2024-02-03 18:53:00 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):611 - Setting stdout...
2024-02-03 18:53:00 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):623 - Setting stderr...
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):583 - Reading pod IP...
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):585 - Pod IP: 10.4.39.30
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):588 - Creating stdin socket...
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):33 - Writing messages to protocol version 0.2.0
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):101 - Attempting to start pod = source-pipedrive-read-8840-0-egwkb for us.gcr.io/jusbrasil-155317/airbyte/source-pipedrive:0.1.8 with resources io.airbyte.config.ResourceRequirements@756fd923[cpuRequest=500m,cpuLimit=500m,memoryRequest=1Gi,memoryLimit=1Gi]
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):104 - source-pipedrive-read-8840-0-egwkb stdoutLocalPort = 9018
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):107 - source-pipedrive-read-8840-0-egwkb stderrLocalPort = 9019
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stdout socket server...
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):620 - Creating stderr socket server...
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):533 - Creating pod source-pipedrive-read-8840-0-egwkb...
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):313 - Waiting for init container to be ready before copying files...
2024-02-03 18:53:01 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):317 - Init container present..
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):320 - Init container ready..
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):564 - Copying files...
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: source_config.json
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/0c7975ad-ad53-4b12-98d9-82758dcab120/source_config.json bigdata-airbyte/source-pipedrive-read-8840-0-egwkb:/config/source_config.json -c init
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: source_catalog.json
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/13ef767e-f9ce-472c-9067-2645b6a0028f/source_catalog.json bigdata-airbyte/source-pipedrive-read-8840-0-egwkb:/config/source_catalog.json -c init
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: FINISHED_UPLOADING
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/60836088-b6d6-4add-86fc-9ef7b81252fb/FINISHED_UPLOADING bigdata-airbyte/source-pipedrive-read-8840-0-egwkb:/config/FINISHED_UPLOADING -c init
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:53:02 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):567 - Waiting until pod is ready...
2024-02-03 18:53:03 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):611 - Setting stdout...
2024-02-03 18:53:03 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):623 - Setting stderr...
2024-02-03 18:53:04 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):583 - Reading pod IP...
2024-02-03 18:53:04 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):585 - Pod IP: 10.5.125.217
2024-02-03 18:53:04 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):592 - Using null stdin output stream...
2024-02-03 18:53:04 �[32mINFO�[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2024-02-03 18:53:04 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(replicate):234 - Waiting for source and destination threads to complete.
2024-02-03 18:53:04 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):260 - Destination output thread started.
2024-02-03 18:53:04 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):310 - Replication thread started.
2024-02-03 18:53:14 �[32mINFO�[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed. 
errors: $.trace.type: does not have a value in the enumeration [ERROR, ESTIMATE]
2024-02-03 18:53:14 �[1;31mERROR�[m i.a.w.i.DefaultAirbyteStreamFactory(validate):87 - Validation failed: {"type":"TRACE","trace":{"type":"STREAM_STATUS","emitted_at":1.706986394269594E12,"stream_status":{"stream_descriptor":{"name":"currencies","namespace":null},"status":"STARTED"}}}
2024-02-03 18:53:14 �[32mINFO�[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed. 
errors: $.trace.type: does not have a value in the enumeration [ERROR, ESTIMATE]
2024-02-03 18:53:14 �[1;31mERROR�[m i.a.w.i.DefaultAirbyteStreamFactory(validate):87 - Validation failed: {"type":"TRACE","trace":{"type":"STREAM_STATUS","emitted_at":1.706986394600127E12,"stream_status":{"stream_descriptor":{"name":"currencies","namespace":null},"status":"RUNNING"}}}
2024-02-03 18:53:14 �[32mINFO�[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed. 
errors: $.trace.type: does not have a value in the enumeration [ERROR, ESTIMATE]
2024-02-03 18:53:14 �[1;31mERROR�[m i.a.w.i.DefaultAirbyteStreamFactory(validate):87 - Validation failed: {"type":"TRACE","trace":{"type":"STREAM_STATUS","emitted_at":1.706986394630028E12,"stream_status":{"stream_descriptor":{"name":"currencies","namespace":null},"status":"COMPLETE"}}}
2024-02-03 18:53:15 �[32mINFO�[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed. 
errors: $.trace.type: does not have a value in the enumeration [ERROR, ESTIMATE]
2024-02-03 18:53:15 �[1;31mERROR�[m i.a.w.i.DefaultAirbyteStreamFactory(validate):87 - Validation failed: {"type":"TRACE","trace":{"type":"STREAM_STATUS","emitted_at":1.706986395361786E12,"stream_status":{"stream_descriptor":{"name":"activities","namespace":null},"status":"STARTED"}}}
2024-02-03 18:53:15 �[32mINFO�[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed. 
errors: $.trace.type: does not have a value in the enumeration [ERROR, ESTIMATE]
2024-02-03 18:53:15 �[1;31mERROR�[m i.a.w.i.DefaultAirbyteStreamFactory(validate):87 - Validation failed: {"type":"TRACE","trace":{"type":"STREAM_STATUS","emitted_at":1.70698639580671E12,"stream_status":{"stream_descriptor":{"name":"activities","namespace":null},"status":"RUNNING"}}}
2024-02-03 18:53:25 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 1000 (2 MB)
2024-02-03 18:52:29 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2024-02-03 18:52:29 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2024-02-03 18:52:29 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:52:29 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):101 - Attempting to start pod = source-pipedrive-check-8840-0-uoxuz for us.gcr.io/jusbrasil-155317/airbyte/source-pipedrive:0.1.8 with resources io.airbyte.config.ResourceRequirements@20bb036e[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2024-02-03 18:52:29 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2024-02-03 18:52:29 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):104 - source-pipedrive-check-8840-0-uoxuz stdoutLocalPort = 9028
2024-02-03 18:52:29 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:52:29 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):107 - source-pipedrive-check-8840-0-uoxuz stderrLocalPort = 9029
2024-02-03 18:52:29 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stdout socket server...
2024-02-03 18:52:29 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):620 - Creating stderr socket server...
2024-02-03 18:52:29 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):533 - Creating pod source-pipedrive-check-8840-0-uoxuz...
2024-02-03 18:52:29 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):313 - Waiting for init container to be ready before copying files...
2024-02-03 18:52:29 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):317 - Init container present..
2024-02-03 18:52:30 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):320 - Init container ready..
2024-02-03 18:52:30 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):564 - Copying files...
2024-02-03 18:52:30 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: source_config.json
2024-02-03 18:52:30 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/0673da2d-d56a-4eb6-beb5-b5010b35ed94/source_config.json bigdata-airbyte/source-pipedrive-check-8840-0-uoxuz:/config/source_config.json -c init
2024-02-03 18:52:30 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:52:30 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:52:30 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: FINISHED_UPLOADING
2024-02-03 18:52:30 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/5d07b0d9-61c0-48c6-8214-ca43a93559c6/FINISHED_UPLOADING bigdata-airbyte/source-pipedrive-check-8840-0-uoxuz:/config/FINISHED_UPLOADING -c init
2024-02-03 18:52:30 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:52:31 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:52:31 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):567 - Waiting until pod is ready...
2024-02-03 18:52:31 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):611 - Setting stdout...
2024-02-03 18:52:31 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):623 - Setting stderr...
2024-02-03 18:52:32 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):583 - Reading pod IP...
2024-02-03 18:52:32 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):585 - Pod IP: 10.5.126.115
2024-02-03 18:52:32 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):592 - Using null stdin output stream...
2024-02-03 18:52:32 �[32mINFO�[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - loading custom fields for deals using url dealFields
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Response Status Code: 200
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Título" to "titulo"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Proprietário" to "proprietario"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Valor ponderado" to "valor_ponderado"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Moeda do valor ponderado" to "moeda_do_valor_ponderado"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Organização" to "organizacao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Pessoa de contato" to "pessoa_de_contato"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de criação do negócio" to "data_de_criacao_do_negocio"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data atualizada" to "data_atualizada"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Última alteração de etapa" to "ultima_alteracao_de_etapa"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data da próxima atividade" to "data_da_proxima_atividade"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data da última atividade" to "data_da_ultima_atividade"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de ganho" to "data_de_ganho"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Último e-mail recebido" to "ultimo_e_mail_recebido"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Último e-mail enviado" to "ultimo_e_mail_enviado"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de perda" to "data_de_perda"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Negócio fechado em" to "negocio_fechado_em"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Motivo da perda" to "motivo_da_perda"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Visível para" to "visivel_para"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Total de atividades" to "total_de_atividades"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Atividades concluídas" to "atividades_concluidas"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Atividades para fazer" to "atividades_para_fazer"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Número de mensagens de e-mail" to "numero_de_mensagens_de_e_mail"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de fechamento esperada" to "data_de_fechamento_esperada"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Quantidade de produtos" to "quantidade_de_produtos"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Valor de produtos" to "valor_de_produtos"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Nome do produto" to "nome_do_produto"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de Expiração" to "data_de_expiracao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data da passagem" to "data_da_passagem"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Forma de pagamento?" to "forma_de_pagamento"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Tipo de Venda" to "tipo_de_venda"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Indicativo de Expansão" to "indicativo_de_expansao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Origem da Oportunidade" to "origem_da_oportunidade"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Levantada enganada?" to "levantada_enganada"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Solução triada" to "solucao_triada"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Média de checks" to "media_de_checks"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "[Inbound] Quantidade de logins" to "inbound_quantidade_de_logins"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "[Inbound] Categoria da organização" to "inbound_categoria_da_organizacao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "RD Jusbrasil link" to "rd_jusbrasil_link"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Origem do Lead" to "origem_do_lead"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Última conversão " to "ultima_conversao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Estratégia ABM " to "estrategia_abm"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Numero de Advogados no Escritório" to "numero_de_advogados_no_escritorio"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Id Deal Vinculado" to "id_deal_vinculado"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Canal primeira conversão" to "canal_primeira_conversao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Campanha primeira conversão" to "campanha_primeira_conversao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Mídia primeira conversão" to "midia_primeira_conversao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "[Inbound] Quantidade de processos ativos" to "inbound_quantidade_de_processos_ativos"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "E-mails para envio de NF/relatórios" to "e_mails_para_envio_de_nf_relatorios"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Tamanho do deal" to "tamanho_do_deal"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Tag da lp" to "tag_da_lp"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Soluções adquiridas " to "solucoes_adquiridas"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Campanha última conversão" to "campanha_ultima_conversao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Origem da ultima conversão" to "origem_da_ultima_conversao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Fonte / evento Inbound" to "fonte_evento_inbound"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Histórico do lead link" to "historico_do_lead_link"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Canal última conversão" to "canal_ultima_conversao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "RD Digesto link" to "rd_digesto_link"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "URL de conversão do chat" to "url_de_conversao_do_chat"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Excluído" to "excluido"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Relacionamento com o decisor" to "relacionamento_com_o_decisor"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Finalidade da informação" to "finalidade_da_informacao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Amplitude da informação" to "amplitude_da_informacao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Profundidade da informação" to "profundidade_da_informacao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Como resolvem?" to "como_resolvem"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Principais dores" to "principais_dores"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Objeções" to "objecoes"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Modo de consumo" to "modo_de_consumo"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de ativação" to "data_de_ativacao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de Renovação" to "data_de_renovacao"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Pessoa física ou jurídica?" to "pessoa_fisica_ou_juridica"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Último MRR" to "ultimo_mrr"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Moeda de Último MRR" to "moeda_de_ultimo_mrr"
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Check succeeded
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.p.KubePodProcess(close):721 - (pod: bigdata-airbyte / source-pipedrive-check-8840-0-uoxuz) - Closed all resources for pod
2024-02-03 18:52:50 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2024-02-03 18:52:50 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2024-02-03 18:52:50 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/8840/0/logs.log
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2024-02-03 18:52:50 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2024-02-03 18:52:50 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):101 - Attempting to start pod = destination-kafka-check-8840-0-urajo for airbyte/destination-kafka:0.1.10 with resources io.airbyte.config.ResourceRequirements@20bb036e[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2024-02-03 18:52:50 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):104 - destination-kafka-check-8840-0-urajo stdoutLocalPort = 9030
2024-02-03 18:52:50 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):107 - destination-kafka-check-8840-0-urajo stderrLocalPort = 9031
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stdout socket server...
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):620 - Creating stderr socket server...
2024-02-03 18:52:50 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):533 - Creating pod destination-kafka-check-8840-0-urajo...
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):313 - Waiting for init container to be ready before copying files...
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):317 - Init container present..
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):320 - Init container ready..
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):564 - Copying files...
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: source_config.json
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/b4b1b3e5-1698-4909-9aba-039a042231eb/source_config.json bigdata-airbyte/destination-kafka-check-8840-0-urajo:/config/source_config.json -c init
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: FINISHED_UPLOADING
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/63fd4ffc-25f1-4eae-a06f-139e0dc640ed/FINISHED_UPLOADING bigdata-airbyte/destination-kafka-check-8840-0-urajo:/config/FINISHED_UPLOADING -c init
2024-02-03 18:52:51 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:52:52 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:52:52 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):567 - Waiting until pod is ready...
2024-02-03 18:52:52 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):611 - Setting stdout...
2024-02-03 18:52:52 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):623 - Setting stderr...
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):583 - Reading pod IP...
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):585 - Pod IP: 10.5.126.116
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):592 - Using null stdin output stream...
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 18:52:53 �[32mINFO�[m i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 18:52:53 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 18:52:53 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 18:52:53 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 18:52:53 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 18:52:53 �[33mWARN�[m 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
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 18:52:53 �[33mWARN�[m 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
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 18:52:53 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2024-02-03 18:52:53 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 18:52:53 �[32mINFO�[m i.a.i.d.k.KafkaDestination(main):86 - Completed destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2024-02-03 18:52:54 �[32mINFO�[m i.a.w.p.KubePodProcess(close):721 - (pod: bigdata-airbyte / destination-kafka-check-8840-0-urajo) - Closed all resources for pod
2024-02-03 18:52:54 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2024-02-03 18:52:54 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:52:54 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2024-02-03 18:52:54 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:53:04 �[43mdestination�[0m > 2024-02-03 18:53:04 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2024-02-03 18:53:04 �[43mdestination�[0m > 2024-02-03 18:53:04 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2024-02-03 18:53:04 �[43mdestination�[0m > 2024-02-03 18:53:04 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):105 - Command: WRITE
2024-02-03 18:53:04 �[43mdestination�[0m > 2024-02-03 18:53:04 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2024-02-03 18:53:04 �[43mdestination�[0m > 2024-02-03 18:53:04 �[33mWARN�[m 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
2024-02-03 18:53:04 �[43mdestination�[0m > 2024-02-03 18:53:04 �[33mWARN�[m 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
2024-02-03 18:53:05 �[43mdestination�[0m > 2024-02-03 18:53:05 �[32mINFO�[m i.a.i.d.k.KafkaDestinationConfig(propertiesByProtocol):81 - Kafka protocol config: {"security_protocol":"PLAINTEXT"}
2024-02-03 18:53:12 �[44msource�[0m > loading custom fields for activities using url activityFields
2024-02-03 18:53:12 �[44msource�[0m > Response Status Code: 200
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Concluído" to "concluido"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Horário de marcado como feito" to "horario_de_marcado_como_feito"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Organização" to "organizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Pessoa de contato" to "pessoa_de_contato"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Negócio" to "negocio"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data de vencimento" to "data_de_vencimento"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Horário de vencimento" to "horario_de_vencimento"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Duração" to "duracao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data adicionada" to "data_adicionada"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Atribuído a usuário" to "atribuido_a_usuario"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data atualizada" to "data_atualizada"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Hora da última notificação" to "hora_da_ultima_notificacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Localização" to "localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Latitude de Localização" to "latitude_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Longitude de Localização" to "longitude_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Nº de apartamento de Localização" to "no_de_apartamento_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Número da casa de Localização" to "numero_da_casa_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Nome da rua de Localização" to "nome_da_rua_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Distrito/sub-localidade de Localização" to "distrito_sub_localidade_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Cidade/município/vila/localidade de Localização" to "cidade_municipio_vila_localidade_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Estado de Localização" to "estado_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Região de Localização" to "regiao_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "País de Localização" to "pais_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "CEP/Código postal de Localização" to "cep_codigo_postal_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Endereço completo/combinado de Localização" to "endereco_completo_combinado_de_localizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Livre/Ocupado" to "livre_ocupado"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Descrição pública" to "descricao_publica"
2024-02-03 18:53:12 �[44msource�[0m > loading custom fields for deals using url dealFields
2024-02-03 18:53:12 �[44msource�[0m > Response Status Code: 200
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Título" to "titulo"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Proprietário" to "proprietario"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Valor ponderado" to "valor_ponderado"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Moeda do valor ponderado" to "moeda_do_valor_ponderado"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Organização" to "organizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Pessoa de contato" to "pessoa_de_contato"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data de criação do negócio" to "data_de_criacao_do_negocio"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data atualizada" to "data_atualizada"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Última alteração de etapa" to "ultima_alteracao_de_etapa"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data da próxima atividade" to "data_da_proxima_atividade"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data da última atividade" to "data_da_ultima_atividade"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data de ganho" to "data_de_ganho"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Último e-mail recebido" to "ultimo_e_mail_recebido"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Último e-mail enviado" to "ultimo_e_mail_enviado"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data de perda" to "data_de_perda"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Negócio fechado em" to "negocio_fechado_em"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Motivo da perda" to "motivo_da_perda"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Visível para" to "visivel_para"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Total de atividades" to "total_de_atividades"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Atividades concluídas" to "atividades_concluidas"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Atividades para fazer" to "atividades_para_fazer"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Número de mensagens de e-mail" to "numero_de_mensagens_de_e_mail"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data de fechamento esperada" to "data_de_fechamento_esperada"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Quantidade de produtos" to "quantidade_de_produtos"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Valor de produtos" to "valor_de_produtos"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Nome do produto" to "nome_do_produto"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data de Expiração" to "data_de_expiracao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data da passagem" to "data_da_passagem"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Forma de pagamento?" to "forma_de_pagamento"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Tipo de Venda" to "tipo_de_venda"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Indicativo de Expansão" to "indicativo_de_expansao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Origem da Oportunidade" to "origem_da_oportunidade"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Levantada enganada?" to "levantada_enganada"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Solução triada" to "solucao_triada"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Média de checks" to "media_de_checks"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "[Inbound] Quantidade de logins" to "inbound_quantidade_de_logins"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "[Inbound] Categoria da organização" to "inbound_categoria_da_organizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "RD Jusbrasil link" to "rd_jusbrasil_link"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Origem do Lead" to "origem_do_lead"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Última conversão " to "ultima_conversao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Estratégia ABM " to "estrategia_abm"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Numero de Advogados no Escritório" to "numero_de_advogados_no_escritorio"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Id Deal Vinculado" to "id_deal_vinculado"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Canal primeira conversão" to "canal_primeira_conversao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Campanha primeira conversão" to "campanha_primeira_conversao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Mídia primeira conversão" to "midia_primeira_conversao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "[Inbound] Quantidade de processos ativos" to "inbound_quantidade_de_processos_ativos"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "E-mails para envio de NF/relatórios" to "e_mails_para_envio_de_nf_relatorios"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Tamanho do deal" to "tamanho_do_deal"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Tag da lp" to "tag_da_lp"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Soluções adquiridas " to "solucoes_adquiridas"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Campanha última conversão" to "campanha_ultima_conversao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Origem da ultima conversão" to "origem_da_ultima_conversao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Fonte / evento Inbound" to "fonte_evento_inbound"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Histórico do lead link" to "historico_do_lead_link"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Canal última conversão" to "canal_ultima_conversao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "RD Digesto link" to "rd_digesto_link"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "URL de conversão do chat" to "url_de_conversao_do_chat"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Excluído" to "excluido"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Relacionamento com o decisor" to "relacionamento_com_o_decisor"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Finalidade da informação" to "finalidade_da_informacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Amplitude da informação" to "amplitude_da_informacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Profundidade da informação" to "profundidade_da_informacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Como resolvem?" to "como_resolvem"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Principais dores" to "principais_dores"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Objeções" to "objecoes"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Modo de consumo" to "modo_de_consumo"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data de ativação" to "data_de_ativacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data de Renovação" to "data_de_renovacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Pessoa física ou jurídica?" to "pessoa_fisica_ou_juridica"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Último MRR" to "ultimo_mrr"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Moeda de Último MRR" to "moeda_de_ultimo_mrr"
2024-02-03 18:53:12 �[44msource�[0m > loading custom fields for deals_deleted using url dealFields
2024-02-03 18:53:12 �[44msource�[0m > Response Status Code: 200
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Título" to "titulo"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Proprietário" to "proprietario"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Valor ponderado" to "valor_ponderado"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Moeda do valor ponderado" to "moeda_do_valor_ponderado"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Organização" to "organizacao"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Pessoa de contato" to "pessoa_de_contato"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data de criação do negócio" to "data_de_criacao_do_negocio"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Data atualizada" to "data_atualizada"
2024-02-03 18:53:12 �[44msource�[0m > Sanitizing field name: "Última alteração de etapa" to "ultima_alteracao_de_etapa"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data da próxima atividade" to "data_da_proxima_atividade"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data da última atividade" to "data_da_ultima_atividade"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data de ganho" to "data_de_ganho"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Último e-mail recebido" to "ultimo_e_mail_recebido"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Último e-mail enviado" to "ultimo_e_mail_enviado"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data de perda" to "data_de_perda"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Negócio fechado em" to "negocio_fechado_em"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Motivo da perda" to "motivo_da_perda"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Visível para" to "visivel_para"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Total de atividades" to "total_de_atividades"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Atividades concluídas" to "atividades_concluidas"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Atividades para fazer" to "atividades_para_fazer"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Número de mensagens de e-mail" to "numero_de_mensagens_de_e_mail"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data de fechamento esperada" to "data_de_fechamento_esperada"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Quantidade de produtos" to "quantidade_de_produtos"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Valor de produtos" to "valor_de_produtos"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Nome do produto" to "nome_do_produto"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data de Expiração" to "data_de_expiracao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data da passagem" to "data_da_passagem"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Forma de pagamento?" to "forma_de_pagamento"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Tipo de Venda" to "tipo_de_venda"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Indicativo de Expansão" to "indicativo_de_expansao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Origem da Oportunidade" to "origem_da_oportunidade"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Levantada enganada?" to "levantada_enganada"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Solução triada" to "solucao_triada"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Média de checks" to "media_de_checks"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "[Inbound] Quantidade de logins" to "inbound_quantidade_de_logins"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "[Inbound] Categoria da organização" to "inbound_categoria_da_organizacao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "RD Jusbrasil link" to "rd_jusbrasil_link"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Origem do Lead" to "origem_do_lead"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Última conversão " to "ultima_conversao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Estratégia ABM " to "estrategia_abm"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Numero de Advogados no Escritório" to "numero_de_advogados_no_escritorio"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Id Deal Vinculado" to "id_deal_vinculado"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Canal primeira conversão" to "canal_primeira_conversao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Campanha primeira conversão" to "campanha_primeira_conversao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Mídia primeira conversão" to "midia_primeira_conversao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "[Inbound] Quantidade de processos ativos" to "inbound_quantidade_de_processos_ativos"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "E-mails para envio de NF/relatórios" to "e_mails_para_envio_de_nf_relatorios"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Tamanho do deal" to "tamanho_do_deal"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Tag da lp" to "tag_da_lp"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Soluções adquiridas " to "solucoes_adquiridas"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Campanha última conversão" to "campanha_ultima_conversao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Origem da ultima conversão" to "origem_da_ultima_conversao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Fonte / evento Inbound" to "fonte_evento_inbound"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Histórico do lead link" to "historico_do_lead_link"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Canal última conversão" to "canal_ultima_conversao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "RD Digesto link" to "rd_digesto_link"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "URL de conversão do chat" to "url_de_conversao_do_chat"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Excluído" to "excluido"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Relacionamento com o decisor" to "relacionamento_com_o_decisor"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Finalidade da informação" to "finalidade_da_informacao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Amplitude da informação" to "amplitude_da_informacao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Profundidade da informação" to "profundidade_da_informacao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Como resolvem?" to "como_resolvem"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Principais dores" to "principais_dores"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Objeções" to "objecoes"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Modo de consumo" to "modo_de_consumo"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data de ativação" to "data_de_ativacao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data de Renovação" to "data_de_renovacao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Pessoa física ou jurídica?" to "pessoa_fisica_ou_juridica"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Último MRR" to "ultimo_mrr"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Moeda de Último MRR" to "moeda_de_ultimo_mrr"
2024-02-03 18:53:13 �[44msource�[0m > loading custom fields for notes using url noteFields
2024-02-03 18:53:13 �[44msource�[0m > Response Status Code: 200
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Conteúdo" to "conteudo"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Organização" to "organizacao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Pessoa de contato" to "pessoa_de_contato"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Título do negócio" to "titulo_do_negocio"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data adicionada" to "data_adicionada"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data atualizada" to "data_atualizada"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Usuário" to "usuario"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Anotação fixada ao negócio" to "anotacao_fixada_ao_negocio"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Anotação fixada à organização" to "anotacao_fixada_a_organizacao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Anotação fixada à pessoa" to "anotacao_fixada_a_pessoa"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Anotação fixada ao lead" to "anotacao_fixada_ao_lead"
2024-02-03 18:53:13 �[44msource�[0m > loading custom fields for organizations using url organizationFields
2024-02-03 18:53:13 �[44msource�[0m > Response Status Code: 200
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Proprietário" to "proprietario"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Negócios em aberto" to "negocios_em_aberto"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Organização criada" to "organizacao_criada"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data atualizada" to "data_atualizada"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Visível para" to "visivel_para"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data da próxima atividade" to "data_da_proxima_atividade"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Data da última atividade" to "data_da_ultima_atividade"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Negócios ganhos" to "negocios_ganhos"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Negócios perdidos" to "negocios_perdidos"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Negócios fechados" to "negocios_fechados"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Total de atividades" to "total_de_atividades"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Atividades concluídas" to "atividades_concluidas"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Atividades para fazer" to "atividades_para_fazer"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Número de mensagens de e-mail" to "numero_de_mensagens_de_e_mail"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Foto de perfil" to "foto_de_perfil"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Tipo de Organização" to "tipo_de_organizacao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Touch Level" to "touch_level"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "CNPJ/CPF da Organização" to "cnpj_cpf_da_organizacao"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Razão Social" to "razao_social"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Linkedin Org" to "linkedin_org"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Nome no OP" to "nome_no_op"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "ID no OP" to "id_no_op"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Nº pessoas/advs" to "no_pessoas_advs"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Endereço" to "endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Latitude de Endereço" to "latitude_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Longitude de Endereço" to "longitude_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Nº de apartamento de Endereço" to "no_de_apartamento_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Número da casa de Endereço" to "numero_da_casa_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Nome da rua de Endereço" to "nome_da_rua_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Distrito/sub-localidade de Endereço" to "distrito_sub_localidade_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Cidade/município/vila/localidade de Endereço" to "cidade_municipio_vila_localidade_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Estado de Endereço" to "estado_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Região de Endereço" to "regiao_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "País de Endereço" to "pais_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "CEP/Código postal de Endereço" to "cep_codigo_postal_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Endereço completo/combinado de Endereço" to "endereco_completo_combinado_de_endereco"
2024-02-03 18:53:13 �[44msource�[0m > Sanitizing field name: "Tipo de uso" to "tipo_de_uso"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Categoria da Organização" to "categoria_da_organizacao"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Segmentação" to "segmentacao"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Link Lexio" to "link_lexio"
2024-02-03 18:53:14 �[44msource�[0m > loading custom fields for products using url productFields
2024-02-03 18:53:14 �[44msource�[0m > Response Status Code: 200
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Proprietário" to "proprietario"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Código do produto" to "codigo_do_produto"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Visível para" to "visivel_para"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Preço" to "preco"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Descrição" to "descricao"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Preços unitários" to "precos_unitarios"
2024-02-03 18:53:14 �[44msource�[0m > loading custom fields for persons using url personFields
2024-02-03 18:53:14 �[44msource�[0m > Response Status Code: 200
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Pessoa criada" to "pessoa_criada"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Data atualizada" to "data_atualizada"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Organização" to "organizacao"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Proprietário" to "proprietario"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Negócios em aberto" to "negocios_em_aberto"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Visível para" to "visivel_para"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Data da próxima atividade" to "data_da_proxima_atividade"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Data da última atividade" to "data_da_ultima_atividade"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Negócios ganhos" to "negocios_ganhos"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Negócios perdidos" to "negocios_perdidos"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Negócios fechados" to "negocios_fechados"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Total de atividades" to "total_de_atividades"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Atividades concluídas" to "atividades_concluidas"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Atividades para fazer" to "atividades_para_fazer"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Número de mensagens de e-mail" to "numero_de_mensagens_de_e_mail"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Foto de perfil" to "foto_de_perfil"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Último e-mail recebido" to "ultimo_e_mail_recebido"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Último e-mail enviado" to "ultimo_e_mail_enviado"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Status de marketing" to "status_de_marketing"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "E-mail" to "e_mail"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Cargo gestor" to "cargo_gestor"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Conta Jusbrasil" to "conta_jusbrasil"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Nome Comprador" to "nome_comprador"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "E-mail Comprador" to "e_mail_comprador"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Telefone Comprador" to "telefone_comprador"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Mensageiro instantâneo" to "mensageiro_instantaneo"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "MQL Job" to "mql_job"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Endereço postal" to "endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Latitude de Endereço postal" to "latitude_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Longitude de Endereço postal" to "longitude_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Nº de apartamento de Endereço postal" to "no_de_apartamento_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Número da casa de Endereço postal" to "numero_da_casa_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Nome da rua de Endereço postal" to "nome_da_rua_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Distrito/sub-localidade de Endereço postal" to "distrito_sub_localidade_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Cidade/município/vila/localidade de Endereço postal" to "cidade_municipio_vila_localidade_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Estado de Endereço postal" to "estado_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Região de Endereço postal" to "regiao_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "País de Endereço postal" to "pais_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "CEP/Código postal de Endereço postal" to "cep_codigo_postal_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Endereço completo/combinado de Endereço postal" to "endereco_completo_combinado_de_endereco_postal"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Anotações" to "anotacoes"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Aniversário" to "aniversario"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "CPF/CNPJ" to "cpf_cnpj"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Data de assinatura da campanha" to "data_de_assinatura_da_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Data de cancelamento de assinatura da campanha" to "data_de_cancelamento_de_assinatura_da_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Título da campanha" to "titulo_da_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Data de envio da campanha" to "data_de_envio_da_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Data de envio da última campanha" to "data_de_envio_da_ultima_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Data de abertura da campanha" to "data_de_abertura_da_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Aberturas de campanha" to "aberturas_de_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Data de clique na campanha" to "data_de_clique_na_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Cliques na campanha" to "cliques_na_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "URL de link clicado da campanha" to "url_de_link_clicado_da_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Sanitizing field name: "Motivo de devolução da campanha" to "motivo_de_devolucao_da_campanha"
2024-02-03 18:53:14 �[44msource�[0m > Marking stream currencies as STARTED
2024-02-03 18:53:14 �[44msource�[0m > Syncing stream: currencies 
2024-02-03 18:53:14 �[44msource�[0m > Marking stream currencies as RUNNING
2024-02-03 18:53:14 �[44msource�[0m > Read 183 records from currencies stream
2024-02-03 18:53:14 �[44msource�[0m > Marking stream currencies as STOPPED
2024-02-03 18:53:14 �[44msource�[0m > Finished syncing currencies
2024-02-03 18:53:14 �[44msource�[0m > SourcePipedrive runtimes:
Syncing stream currencies 0:00:00.794181
2024-02-03 18:53:15 �[44msource�[0m > Marking stream activities as STARTED
2024-02-03 18:53:15 �[44msource�[0m > Syncing stream: activities 
2024-02-03 18:53:15 �[44msource�[0m > Marking stream activities as RUNNING
2024-02-03 18:53:36 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 2000 (4 MB)
2024-02-03 18:53:46 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 3000 (6 MB)
2024-02-03 18:53:56 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 4000 (8 MB)
2024-02-03 18:54:06 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 5000 (10 MB)
2024-02-03 18:54:17 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 6000 (12 MB)
2024-02-03 18:54:27 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 7000 (14 MB)
2024-02-03 18:54:37 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 8000 (15 MB)
2024-02-03 18:54:47 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 9000 (17 MB)
2024-02-03 18:54:57 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 10000 (19 MB)
2024-02-03 18:55:07 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 11000 (21 MB)
2024-02-03 18:55:17 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 12000 (23 MB)
2024-02-03 18:55:27 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 13000 (24 MB)
2024-02-03 18:55:37 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 14000 (26 MB)
2024-02-03 18:55:47 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 15000 (28 MB)
2024-02-03 18:55:57 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 16000 (30 MB)
2024-02-03 18:56:07 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 17000 (31 MB)
2024-02-03 18:56:17 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 18000 (33 MB)
2024-02-03 18:56:28 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 19000 (35 MB)
2024-02-03 18:56:38 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 20000 (37 MB)
2024-02-03 18:56:48 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 21000 (38 MB)
2024-02-03 18:56:58 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 22000 (40 MB)
2024-02-03 18:57:08 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 23000 (42 MB)
2024-02-03 18:57:18 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 24000 (44 MB)
2024-02-03 18:57:28 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 25000 (46 MB)
2024-02-03 18:57:38 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 26000 (48 MB)
2024-02-03 18:57:48 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 27000 (50 MB)
2024-02-03 18:57:58 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 28000 (52 MB)
2024-02-03 18:58:09 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 29000 (54 MB)
2024-02-03 18:58:19 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 30000 (56 MB)
2024-02-03 18:58:30 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 31000 (57 MB)
2024-02-03 18:58:42 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 32000 (59 MB)
2024-02-03 18:58:52 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 33000 (61 MB)
2024-02-03 18:59:02 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 34000 (63 MB)
2024-02-03 18:59:12 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 35000 (65 MB)
2024-02-03 18:59:22 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 36000 (67 MB)
2024-02-03 18:59:33 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 37000 (68 MB)
2024-02-03 18:59:43 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 38000 (70 MB)
2024-02-03 18:59:53 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 39000 (72 MB)
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(cancel):623 - Cancelling replication worker...
2024-02-03 19:00:03 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 40000 (74 MB)
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(cancel):632 - Cancelling destination...
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.i.DefaultAirbyteDestination(cancel):131 - Attempting to cancel destination process...
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.i.DefaultAirbyteDestination(cancel):136 - Destination process exists, cancelling...
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.p.KubePodProcess(destroy):653 - (pod: bigdata-airbyte / destination-kafka-write-8840-0-gkdpo) - Destroying Kube process.
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(replicate):239 - One of source or destination thread complete. Waiting on the other.
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.p.KubePodProcess(close):721 - (pod: bigdata-airbyte / destination-kafka-write-8840-0-gkdpo) - Closed all resources for pod
2024-02-03 19:00:07 �[33mWARN�[m i.a.c.i.LineGobbler(voidCall):119 - airbyte-destination gobbler IOException: Socket closed. Typically happens when cancelling a job.
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.p.KubePodProcess(destroy):659 - (pod: bigdata-airbyte / destination-kafka-write-8840-0-gkdpo) - Destroyed Kube process.
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.i.DefaultAirbyteDestination(cancel):138 - Cancelled destination process!
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(cancel):640 - Cancelling source...
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.i.DefaultAirbyteSource(cancel):151 - Attempting to cancel source process...
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.i.DefaultAirbyteSource(cancel):156 - Source process exists, cancelling...
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.p.KubePodProcess(destroy):653 - (pod: bigdata-airbyte / source-pipedrive-read-8840-0-egwkb) - Destroying Kube process.
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.p.KubePodProcess(close):721 - (pod: bigdata-airbyte / source-pipedrive-read-8840-0-egwkb) - Closed all resources for pod
2024-02-03 19:00:07 �[33mWARN�[m i.a.c.i.LineGobbler(voidCall):119 - airbyte-source gobbler IOException: Socket closed. Typically happens when cancelling a job.
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(replicate):241 - Source and destination threads complete.
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.p.KubePodProcess(destroy):659 - (pod: bigdata-airbyte / source-pipedrive-read-8840-0-egwkb) - Destroyed Kube process.
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.i.DefaultAirbyteSource(cancel):158 - Cancelled source process!
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2024-02-03 19:00:07 �[1;31mERROR�[m i.a.w.g.DefaultReplicationWorker(replicate):246 - Sync worker failed.
io.airbyte.workers.exception.WorkerException: Source process exit with code 143. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:144) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:243) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
	Suppressed: java.net.SocketException: Socket closed
		at sun.nio.ch.NioSocketImpl.ensureOpenAndConnected(NioSocketImpl.java:163) ~[?:?]
		at sun.nio.ch.NioSocketImpl.beginWrite(NioSocketImpl.java:356) ~[?:?]
		at sun.nio.ch.NioSocketImpl.implWrite(NioSocketImpl.java:401) ~[?:?]
		at sun.nio.ch.NioSocketImpl.write(NioSocketImpl.java:433) ~[?:?]
		at sun.nio.ch.NioSocketImpl$2.write(NioSocketImpl.java:812) ~[?:?]
		at java.net.Socket$SocketOutputStream.write(Socket.java:1120) ~[?:?]
		at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:313) ~[?:?]
		at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:385) ~[?:?]
		at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:361) ~[?:?]
		at sun.nio.cs.StreamEncoder.lockedWrite(StreamEncoder.java:162) ~[?:?]
		at sun.nio.cs.StreamEncoder.write(StreamEncoder.java:143) ~[?:?]
		at java.io.OutputStreamWriter.write(OutputStreamWriter.java:220) ~[?:?]
		at java.io.BufferedWriter.implFlushBuffer(BufferedWriter.java:178) ~[?:?]
		at java.io.BufferedWriter.flushBuffer(BufferedWriter.java:163) ~[?:?]
		at java.io.BufferedWriter.implFlush(BufferedWriter.java:371) ~[?:?]
		at java.io.BufferedWriter.flush(BufferedWriter.java:359) ~[?:?]
		at io.airbyte.workers.internal.DefaultAirbyteMessageBufferedWriter.flush(DefaultAirbyteMessageBufferedWriter.java:28) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.internal.DefaultAirbyteDestination.notifyEndOfInput(DefaultAirbyteDestination.java:102) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:116) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:185) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
		at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2024-02-03 19:00:07 �[33mWARN�[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2024-02-03 19:00:07 �[33mWARN�[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2024-02-03 19:00:07 �[32mINFO�[m i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):503 - Source did not output any state messages
2024-02-03 19:00:07 �[33mWARN�[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):514 - State capture: No state retained.
2024-02-03 19:00:07 �[33mWARN�[m i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=95e669bb-66c4-3a82-9751-9dcf24886800, activityType=Replicate, attempt=1
java.lang.RuntimeException: java.util.concurrent.CancellationException
	at io.airbyte.commons.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:281) ~[io.airbyte-airbyte-commons-temporal-0.40.26.jar:?]
	at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:156) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
	at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?]
	at io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:64) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:43) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:95) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:92) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:241) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.util.concurrent.CancellationException
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.26.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	... 3 more
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):434 - sync summary: {
  "status" : "cancelled",
  "recordsSynced" : 40382,
  "bytesSynced" : 78723091,
  "startTime" : 1706986377660,
  "endTime" : 1706986807762,
  "totalStats" : {
    "recordsEmitted" : 40382,
    "bytesEmitted" : 78723091,
    "sourceStateMessagesEmitted" : 0,
    "destinationStateMessagesEmitted" : 0,
    "recordsCommitted" : 0,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "replicationStartTime" : 1706986377660,
    "replicationEndTime" : 1706986807762,
    "sourceReadStartTime" : 1706986381269,
    "sourceReadEndTime" : 0,
    "destinationWriteStartTime" : 1706986384042,
    "destinationWriteEndTime" : 0
  },
  "streamStats" : [ {
    "streamName" : "activities",
    "streamNamespace" : "pipedrive",
    "stats" : {
      "recordsEmitted" : 40199,
      "bytesEmitted" : 78700415
    }
  }, {
    "streamName" : "currencies",
    "streamNamespace" : "pipedrive",
    "stats" : {
      "recordsEmitted" : 183,
      "bytesEmitted" : 22676
    }
  } ]
}
2024-02-03 19:00:07 �[32mINFO�[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):435 - failures: [ ]
2024-02-03 19:00:07 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 19:00:07 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2024-02-03 19:00:07 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 19:00:07 �[33mWARN�[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = 95e669bb-66c4-3a82-9751-9dcf24886800, ActivityType = Replicate, WorkflowId=sync_8840, WorkflowType=SyncWorkflow, RunId=f6db9f82-331d-4997-aac5-dfd81f7631b4
io.grpc.StatusRuntimeException: NOT_FOUND: workflow execution already completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.50.2.jar:1.50.2]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.50.2.jar:1.50.2]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.50.2.jar:1.50.2]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskFailed(WorkflowServiceGrpc.java:3866) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$1(ActivityWorker.java:320) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:315) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2024-02-03 18:59:52 �[32mINFO�[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed. 
errors: $.auth_type: must be a constant value Client, $.auth_type: does not have a value in the enumeration [Client]
2024-02-03 18:59:52 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/8840/1/logs.log
2024-02-03 18:59:52 �[32mINFO�[m i.a.v.j.JsonSchemaValidator(test):130 - JSON schema validation failed. 
errors: $.api_token: object found, string expected
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/8840/1/logs.log
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2024-02-03 18:59:58 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2024-02-03 18:59:58 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):101 - Attempting to start pod = destination-kafka-check-8840-1-jiwkq for airbyte/destination-kafka:0.1.10 with resources io.airbyte.config.ResourceRequirements@20bb036e[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2024-02-03 18:59:58 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):104 - destination-kafka-check-8840-1-jiwkq stdoutLocalPort = 9032
2024-02-03 18:59:58 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):107 - destination-kafka-check-8840-1-jiwkq stderrLocalPort = 9033
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stdout socket server...
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):620 - Creating stderr socket server...
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):533 - Creating pod destination-kafka-check-8840-1-jiwkq...
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):313 - Waiting for init container to be ready before copying files...
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):317 - Init container present..
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):320 - Init container ready..
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):564 - Copying files...
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: source_config.json
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/3dba6efc-f2da-4026-ae36-ad1edbb80340/source_config.json bigdata-airbyte/destination-kafka-check-8840-1-jiwkq:/config/source_config.json -c init
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: FINISHED_UPLOADING
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/1d4fafc0-06de-4c1c-aed4-1616ff78eeb1/FINISHED_UPLOADING bigdata-airbyte/destination-kafka-check-8840-1-jiwkq:/config/FINISHED_UPLOADING -c init
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 19:00:00 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):567 - Waiting until pod is ready...
2024-02-03 19:00:01 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):611 - Setting stdout...
2024-02-03 19:00:01 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):623 - Setting stderr...
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):583 - Reading pod IP...
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):585 - Pod IP: 10.5.126.118
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):592 - Using null stdin output stream...
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 19:00:01 �[32mINFO�[m i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 19:00:02 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 19:00:02 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 19:00:02 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 19:00:02 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 19:00:02 �[33mWARN�[m 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
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 19:00:02 �[33mWARN�[m 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
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 19:00:02 �[32mINFO�[m i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2024-02-03 19:00:02 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2024-02-03 19:00:02 �[32mINFO�[m i.a.i.d.k.KafkaDestination(main):86 - Completed destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2024-02-03 19:00:03 �[32mINFO�[m i.a.w.p.KubePodProcess(close):721 - (pod: bigdata-airbyte / destination-kafka-check-8840-1-jiwkq) - Closed all resources for pod
2024-02-03 19:00:03 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 19:00:03 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2024-02-03 19:00:03 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2024-02-03 19:00:03 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:59:52 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2024-02-03 18:59:52 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2024-02-03 18:59:52 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:59:52 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):101 - Attempting to start pod = source-pipedrive-check-8840-1-qkmom for us.gcr.io/jusbrasil-155317/airbyte/source-pipedrive:0.1.8 with resources io.airbyte.config.ResourceRequirements@3357c49a[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2024-02-03 18:59:52 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2024-02-03 18:59:52 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):104 - source-pipedrive-check-8840-1-qkmom stdoutLocalPort = 9020
2024-02-03 18:59:52 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:59:52 �[32mINFO�[m i.a.w.p.KubeProcessFactory(create):107 - source-pipedrive-check-8840-1-qkmom stderrLocalPort = 9021
2024-02-03 18:59:52 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stdout socket server...
2024-02-03 18:59:52 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):620 - Creating stderr socket server...
2024-02-03 18:59:52 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):533 - Creating pod source-pipedrive-check-8840-1-qkmom...
2024-02-03 18:59:52 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):313 - Waiting for init container to be ready before copying files...
2024-02-03 18:59:52 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):317 - Init container present..
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(waitForInitPodToRun):320 - Init container ready..
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):564 - Copying files...
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: source_config.json
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/ac5c6260-ebea-445c-8065-36a9ebf26ebb/source_config.json bigdata-airbyte/source-pipedrive-check-8840-1-qkmom:/config/source_config.json -c init
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - Uploading file: FINISHED_UPLOADING
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):270 - kubectl cp /tmp/ab500f90-5953-4c4e-b1f5-3865186f123f/FINISHED_UPLOADING bigdata-airbyte/source-pipedrive-check-8840-1-qkmom:/config/FINISHED_UPLOADING -c init
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):273 - Waiting for kubectl cp to complete
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):287 - kubectl cp complete, closing process
2024-02-03 18:59:54 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):567 - Waiting until pod is ready...
2024-02-03 18:59:55 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):611 - Setting stdout...
2024-02-03 18:59:55 �[32mINFO�[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$11):623 - Setting stderr...
2024-02-03 18:59:56 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):583 - Reading pod IP...
2024-02-03 18:59:56 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):585 - Pod IP: 10.5.126.117
2024-02-03 18:59:56 �[32mINFO�[m i.a.w.p.KubePodProcess(<init>):592 - Using null stdin output stream...
2024-02-03 18:59:56 �[32mINFO�[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - loading custom fields for deals using url dealFields
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Response Status Code: 200
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Título" to "titulo"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Proprietário" to "proprietario"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Valor ponderado" to "valor_ponderado"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Moeda do valor ponderado" to "moeda_do_valor_ponderado"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Organização" to "organizacao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Pessoa de contato" to "pessoa_de_contato"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de criação do negócio" to "data_de_criacao_do_negocio"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data atualizada" to "data_atualizada"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Última alteração de etapa" to "ultima_alteracao_de_etapa"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data da próxima atividade" to "data_da_proxima_atividade"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data da última atividade" to "data_da_ultima_atividade"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de ganho" to "data_de_ganho"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Último e-mail recebido" to "ultimo_e_mail_recebido"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Último e-mail enviado" to "ultimo_e_mail_enviado"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de perda" to "data_de_perda"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Negócio fechado em" to "negocio_fechado_em"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Motivo da perda" to "motivo_da_perda"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Visível para" to "visivel_para"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Total de atividades" to "total_de_atividades"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Atividades concluídas" to "atividades_concluidas"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Atividades para fazer" to "atividades_para_fazer"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Número de mensagens de e-mail" to "numero_de_mensagens_de_e_mail"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de fechamento esperada" to "data_de_fechamento_esperada"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Quantidade de produtos" to "quantidade_de_produtos"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Valor de produtos" to "valor_de_produtos"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Nome do produto" to "nome_do_produto"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de Expiração" to "data_de_expiracao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data da passagem" to "data_da_passagem"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Forma de pagamento?" to "forma_de_pagamento"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Tipo de Venda" to "tipo_de_venda"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Indicativo de Expansão" to "indicativo_de_expansao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Origem da Oportunidade" to "origem_da_oportunidade"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Levantada enganada?" to "levantada_enganada"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Solução triada" to "solucao_triada"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Média de checks" to "media_de_checks"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "[Inbound] Quantidade de logins" to "inbound_quantidade_de_logins"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "[Inbound] Categoria da organização" to "inbound_categoria_da_organizacao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "RD Jusbrasil link" to "rd_jusbrasil_link"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Origem do Lead" to "origem_do_lead"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Última conversão " to "ultima_conversao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Estratégia ABM " to "estrategia_abm"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Numero de Advogados no Escritório" to "numero_de_advogados_no_escritorio"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Id Deal Vinculado" to "id_deal_vinculado"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Canal primeira conversão" to "canal_primeira_conversao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Campanha primeira conversão" to "campanha_primeira_conversao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Mídia primeira conversão" to "midia_primeira_conversao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "[Inbound] Quantidade de processos ativos" to "inbound_quantidade_de_processos_ativos"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "E-mails para envio de NF/relatórios" to "e_mails_para_envio_de_nf_relatorios"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Tamanho do deal" to "tamanho_do_deal"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Tag da lp" to "tag_da_lp"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Soluções adquiridas " to "solucoes_adquiridas"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Campanha última conversão" to "campanha_ultima_conversao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Origem da ultima conversão" to "origem_da_ultima_conversao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Fonte / evento Inbound" to "fonte_evento_inbound"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Histórico do lead link" to "historico_do_lead_link"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Canal última conversão" to "canal_ultima_conversao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "RD Digesto link" to "rd_digesto_link"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "URL de conversão do chat" to "url_de_conversao_do_chat"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Excluído" to "excluido"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Relacionamento com o decisor" to "relacionamento_com_o_decisor"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Finalidade da informação" to "finalidade_da_informacao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Amplitude da informação" to "amplitude_da_informacao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Profundidade da informação" to "profundidade_da_informacao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Como resolvem?" to "como_resolvem"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Principais dores" to "principais_dores"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Objeções" to "objecoes"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Modo de consumo" to "modo_de_consumo"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de ativação" to "data_de_ativacao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Data de Renovação" to "data_de_renovacao"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Pessoa física ou jurídica?" to "pessoa_fisica_ou_juridica"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Último MRR" to "ultimo_mrr"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - Sanitizing field name: "Moeda de Último MRR" to "moeda_de_ultimo_mrr"
2024-02-03 18:59:57 �[32mINFO�[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Check succeeded
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.p.KubePodProcess(close):721 - (pod: bigdata-airbyte / source-pipedrive-check-8840-1-qkmom) - Closed all resources for pod
2024-02-03 18:59:58 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2024-02-03 18:59:58 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 18:59:58 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2024-02-03 18:59:58 �[32mINFO�[m i.a.c.i.LineGobbler(voidCall):114 - 
2024-02-03 19:00:03 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):138 - Cloud storage job log path: /workspace/8840/1/logs.log
2024-02-03 19:00:03 �[32mINFO�[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2024-02-03 19:00:03 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2024-02-03 19:00:11 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):177 - Attempt 0 to save workflow id for cancellation error: io.airbyte.api.client.invoker.generated.ApiException: java.net.ConnectException
2024-02-03 19:00:12 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 1 to save workflow id for cancellation
2024-02-03 19:00:12 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):177 - Attempt 1 to save workflow id for cancellation error: io.airbyte.api.client.invoker.generated.ApiException: java.net.ConnectException
2024-02-03 19:00:17 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 2 to save workflow id for cancellation
2024-02-03 19:00:17 �[32mINFO�[m i.a.a.c.AirbyteApiClient(retryWithJitter):177 - Attempt 2 to save workflow id for cancellation error: io.airbyte.api.client.invoker.generated.ApiException: java.net.ConnectException```