2022-04-21 13:48:53 INFO WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.33.11-alpha 2022-04-21 13:48:53 INFO TemporalAttemptExecution(get):116 - Executing worker wrapper. Airbyte version: 0.33.11-alpha 2022-04-21 13:48:53 WARN Databases(createPostgresDatabaseWithRetry):41 - Waiting for database to become available... 2022-04-21 13:48:53 INFO JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready... 2022-04-21 13:48:53 INFO Databases(createPostgresDatabaseWithRetry):58 - Database available! 2022-04-21 13:48:53 INFO DefaultReplicationWorker(run):99 - start sync worker. job id: 33653 attempt id: 0 2022-04-21 13:48:53 INFO DefaultReplicationWorker(run):108 - configured sync modes: {ZLERNE.VALORI_GIULESTI_ANB=full_refresh - overwrite} 2022-04-21 13:48:53 INFO DefaultAirbyteDestination(start):64 - Running destination... 2022-04-21 13:48:53 INFO KubeProcessFactory(create):106 - destination-gcs-sync-33653-0-eltig stdoutLocalPort = 9020 2022-04-21 13:48:53 INFO KubeProcessFactory(create):109 - destination-gcs-sync-33653-0-eltig stderrLocalPort = 9021 2022-04-21 13:48:53 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$5):436 - Creating stdout socket server... 2022-04-21 13:48:53 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):447 - Creating stderr socket server... 2022-04-21 13:48:53 INFO KubePodProcess():395 - Creating pod... 2022-04-21 13:48:53 INFO KubePodProcess(waitForInitPodToRun):232 - Waiting for init container to be ready before copying files... 2022-04-21 13:48:53 INFO KubePodProcess(waitForInitPodToRun):235 - Init container present.. 2022-04-21 13:48:54 INFO KubePodProcess(waitForInitPodToRun):238 - Init container ready.. 2022-04-21 13:48:54 INFO KubePodProcess():400 - Copying files... 2022-04-21 13:48:54 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: destination_config.json 2022-04-21 13:48:54 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: destination_catalog.json 2022-04-21 13:48:54 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: FINISHED_UPLOADING 2022-04-21 13:48:54 INFO KubePodProcess():403 - Waiting until pod is ready... 2022-04-21 13:48:55 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$5):438 - Setting stdout... 2022-04-21 13:48:55 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):449 - Setting stderr... 2022-04-21 13:48:56 INFO KubePodProcess():417 - Reading pod IP... 2022-04-21 13:48:56 INFO KubePodProcess():419 - Pod IP: 10.176.2.66 2022-04-21 13:48:56 INFO KubePodProcess():422 - Creating stdin socket... destination - 2022-04-21 13:48:56 ERROR LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-04-21 13:48:56 INFO KubeProcessFactory(create):106 - source-oracle-sync-33653-0-etxkk stdoutLocalPort = 9030 destination - 2022-04-21 13:48:56 ERROR LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-21 13:48:56 INFO KubeProcessFactory(create):109 - source-oracle-sync-33653-0-etxkk stderrLocalPort = 9031 destination - 2022-04-21 13:48:56 ERROR LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] destination - 2022-04-21 13:48:56 ERROR LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. destination - 2022-04-21 13:48:56 ERROR LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-21 13:48:56 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$5):436 - Creating stdout socket server... 2022-04-21 13:48:56 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):447 - Creating stderr socket server... 2022-04-21 13:48:56 INFO KubePodProcess():395 - Creating pod... 2022-04-21 13:48:56 INFO KubePodProcess(waitForInitPodToRun):232 - Waiting for init container to be ready before copying files... 2022-04-21 13:48:56 INFO KubePodProcess(waitForInitPodToRun):235 - Init container present.. 2022-04-21 13:48:57 INFO KubePodProcess(waitForInitPodToRun):238 - Init container ready.. 2022-04-21 13:48:57 INFO KubePodProcess():400 - Copying files... 2022-04-21 13:48:57 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: source_config.json 2022-04-21 13:48:58 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: source_catalog.json 2022-04-21 13:48:58 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: FINISHED_UPLOADING 2022-04-21 13:48:58 INFO KubePodProcess():403 - Waiting until pod is ready... 2022-04-21 13:48:59 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$5):438 - Setting stdout... 2022-04-21 13:48:59 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):449 - Setting stderr... 2022-04-21 13:49:00 INFO KubePodProcess():417 - Reading pod IP... 2022-04-21 13:49:00 INFO KubePodProcess():419 - Pod IP: 10.176.0.85 2022-04-21 13:49:00 INFO KubePodProcess():426 - Using null stdin output stream... 2022-04-21 13:49:00 INFO DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):243 - Destination output thread started. destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:57 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:57 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: 93bdad3837d14af9acde2d67224a4c18 destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:57 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.destination.gcs.GcsDestination destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:57 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: WRITE destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:57 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:57 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:57 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:57 INFO i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - S3 format config: {"format_type":"JSONL","part_size_mb":100} destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:58 INFO i.a.i.d.g.j.GcsJsonlWriter():53 - Full GCS path for stream 'VALORI_GIULESTI_ANB': ingestion_veoliaro/zamolxis/ZLERNE/VALORI_GIULESTI_ANB/2022_04_21_1650548938273_0.jsonl destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:58 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 100 MB destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:58 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to ingestion_veoliaro/zamolxis/ZLERNE/VALORI_GIULESTI_ANB/2022_04_21_1650548938273_0.jsonl with full ID ABPnzm7eAbOpguXpR9pGRaain0Ss1B5Y8YLwFpo3LdY4LCDFU9krYNWqkUjZozSf0qqiiqxo destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:58 INFO i.a.i.d.g.w.BaseGcsWriter(initialize):73 - Overwrite mode destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:58 INFO i.a.i.d.g.w.BaseGcsWriter(initialize):82 - Purging non-empty output path for stream 'VALORI_GIULESTI_ANB' under OVERWRITE mode... destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:58 INFO i.a.i.d.g.w.BaseGcsWriter(initialize):87 - Deleted 1 file(s) for stream 'VALORI_GIULESTI_ANB'. destination - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:48:58 INFO i.a.i.d.g.w.BaseGcsWriter(initialize):90 - Overwrite is finished 2022-04-21 13:49:00 INFO DefaultReplicationWorker(run):136 - Waiting for source thread to join. 2022-04-21 13:49:00 INFO DefaultReplicationWorker(lambda$getReplicationRunnable$2):207 - Replication thread started. source - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:00 INFO i.a.i.s.o.OracleSource(main):175 - starting source: class io.airbyte.integrations.source.oracle.OracleSource source - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:00 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, config=source_config.json} source - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:00 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: 3f3d9054e1f54ab48e2cafccb694cfbb source - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:00 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource source - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:00 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: READ source - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:00 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='null'} source - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:00 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword source - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:00 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword source - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:00 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword source - 2022-04-21 13:49:00 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:00 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-21 13:49:31 INFO KubePodProcess(getReturnCode):591 - Exit code for pod source-oracle-sync-33653-0-etxkk is 1 2022-04-21 13:49:31 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-33653-0-etxkk 2022-04-21 13:49:31 INFO DefaultReplicationWorker(run):138 - Source thread complete. 2022-04-21 13:49:31 INFO DefaultReplicationWorker(run):139 - Waiting for destination thread to join. destination - 2022-04-21 13:49:31 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:31 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. destination - 2022-04-21 13:49:31 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:31 INFO i.a.i.d.g.w.BaseGcsWriter(close):120 - Uploading remaining data for stream 'VALORI_GIULESTI_ANB'. destination - 2022-04-21 13:49:31 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:31 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000] destination - 2022-04-21 13:49:31 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:31 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000] destination - 2022-04-21 13:49:31 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:31 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed destination - 2022-04-21 13:49:32 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:32 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to ingestion_veoliaro/zamolxis/ZLERNE/VALORI_GIULESTI_ANB/2022_04_21_1650548938273_0.jsonl with id ABPnzm7eA...f0qqiiqxo]: Completed destination - 2022-04-21 13:49:32 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:32 INFO i.a.i.d.g.w.BaseGcsWriter(close):122 - Upload completed for stream 'VALORI_GIULESTI_ANB'. 2022-04-21 13:49:32 INFO JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $: null found, object expected 2022-04-21 13:49:32 ERROR DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: null destination - 2022-04-21 13:49:32 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-21 13:49:32 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.destination.gcs.GcsDestination 2022-04-21 13:50:02 INFO KubePodProcess(getReturnCode):591 - Exit code for pod destination-gcs-sync-33653-0-eltig is 0 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod destination-gcs-sync-33653-0-eltig 2022-04-21 13:50:02 INFO DefaultReplicationWorker(run):141 - Destination thread complete. 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-33653-0-etxkk 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-33653-0-etxkk 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-33653-0-etxkk 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-33653-0-etxkk 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-33653-0-etxkk 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-33653-0-etxkk 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod destination-gcs-sync-33653-0-eltig 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod destination-gcs-sync-33653-0-eltig 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod destination-gcs-sync-33653-0-eltig 2022-04-21 13:50:02 INFO KubePodProcess(exitValue):606 - Closed all resources for pod destination-gcs-sync-33653-0-eltig 2022-04-21 13:50:02 ERROR DefaultReplicationWorker(run):145 - Sync worker failed. io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:117) ~[io.airbyte-airbyte-workers-0.33.11-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:143) ~[io.airbyte-airbyte-workers-0.33.11-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:49) ~[io.airbyte-airbyte-workers-0.33.11-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:167) ~[io.airbyte-airbyte-workers-0.33.11-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] 2022-04-21 13:50:02 INFO DefaultReplicationWorker(run):169 - sync summary: io.airbyte.config.ReplicationAttemptSummary@4922dca2[status=failed,recordsSynced=0,bytesSynced=0,startTime=1650548933248,endTime=1650549002057] 2022-04-21 13:50:02 INFO DefaultReplicationWorker(run):178 - Source did not output any state messages 2022-04-21 13:50:02 WARN DefaultReplicationWorker(run):189 - State capture: No state retained. 2022-04-21 13:50:02 INFO TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling... 2022-04-21 13:50:02 INFO ReplicationActivityImpl(replicate):121 - sync summary: io.airbyte.config.StandardSyncOutput@14d43c9d[standardSyncSummary=io.airbyte.config.StandardSyncSummary@1025dc3a[status=failed,recordsSynced=0,bytesSynced=0,startTime=1650548933248,endTime=1650549002057],state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@7edb04a3[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@5e69fb9b[stream=io.airbyte.protocol.models.AirbyteStream@6bec041f[name=VALORI_GIULESTI_ANB,jsonSchema={"type":"object","properties":{"DATA":{"type":"string"},"IDTF":{"type":"number"},"VALOARE":{"type":"number"},"PARAMETRU":{"type":"string"},"NUME_INSTALATIE":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=ZLERNE,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}]]