2022-04-17 23:57:06 INFO WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.33.11-alpha 2022-04-17 23:57:07 INFO TemporalAttemptExecution(get):116 - Executing worker wrapper. Airbyte version: 0.33.11-alpha 2022-04-17 23:57:07 WARN Databases(createPostgresDatabaseWithRetry):41 - Waiting for database to become available... 2022-04-17 23:57:07 INFO JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready... 2022-04-17 23:57:07 INFO Databases(createPostgresDatabaseWithRetry):58 - Database available! 2022-04-17 23:57:07 INFO DefaultReplicationWorker(run):99 - start sync worker. job id: 32372 attempt id: 0 2022-04-17 23:57:07 INFO DefaultReplicationWorker(run):108 - configured sync modes: {ZLERNE.VALORI_GIULESTI_ANB=full_refresh - overwrite} 2022-04-17 23:57:07 INFO DefaultAirbyteDestination(start):64 - Running destination... 2022-04-17 23:57:07 INFO KubeProcessFactory(create):106 - destination-gcs-sync-32372-0-boqia stdoutLocalPort = 9026 2022-04-17 23:57:07 INFO KubeProcessFactory(create):109 - destination-gcs-sync-32372-0-boqia stderrLocalPort = 9027 2022-04-17 23:57:07 INFO KubePodProcess():395 - Creating pod... 2022-04-17 23:57:07 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):447 - Creating stderr socket server... 2022-04-17 23:57:07 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$5):436 - Creating stdout socket server... 2022-04-17 23:57:07 INFO KubePodProcess(waitForInitPodToRun):232 - Waiting for init container to be ready before copying files... 2022-04-17 23:57:07 INFO KubePodProcess(waitForInitPodToRun):235 - Init container present.. 2022-04-17 23:57:08 INFO KubePodProcess(waitForInitPodToRun):238 - Init container ready.. 2022-04-17 23:57:08 INFO KubePodProcess():400 - Copying files... 2022-04-17 23:57:08 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: destination_config.json 2022-04-17 23:57:08 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: destination_catalog.json 2022-04-17 23:57:08 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: FINISHED_UPLOADING 2022-04-17 23:57:08 INFO KubePodProcess():403 - Waiting until pod is ready... 2022-04-17 23:57:10 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$5):438 - Setting stdout... 2022-04-17 23:57:10 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):449 - Setting stderr... 2022-04-17 23:57:10 INFO KubePodProcess():417 - Reading pod IP... 2022-04-17 23:57:10 INFO KubePodProcess():419 - Pod IP: 10.216.1.6 2022-04-17 23:57:10 INFO KubePodProcess():422 - Creating stdin socket... 2022-04-17 23:57:10 INFO KubeProcessFactory(create):106 - source-oracle-sync-32372-0-aasnj stdoutLocalPort = 9030 2022-04-17 23:57:10 INFO KubeProcessFactory(create):109 - source-oracle-sync-32372-0-aasnj stderrLocalPort = 9031 destination - 2022-04-17 23:57:10 ERROR LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. destination - 2022-04-17 23:57:10 ERROR LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] destination - 2022-04-17 23:57:10 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-17 23:57:10 ERROR LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. destination - 2022-04-17 23:57:10 ERROR LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-17 23:57:10 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$5):436 - Creating stdout socket server... 2022-04-17 23:57:10 INFO KubePodProcess():395 - Creating pod... 2022-04-17 23:57:10 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):447 - Creating stderr socket server... 2022-04-17 23:57:10 INFO KubePodProcess(waitForInitPodToRun):232 - Waiting for init container to be ready before copying files... 2022-04-17 23:57:10 INFO KubePodProcess(waitForInitPodToRun):235 - Init container present.. 2022-04-17 23:57:12 INFO KubePodProcess(waitForInitPodToRun):238 - Init container ready.. 2022-04-17 23:57:12 INFO KubePodProcess():400 - Copying files... 2022-04-17 23:57:12 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: source_config.json 2022-04-17 23:57:12 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: source_catalog.json 2022-04-17 23:57:12 INFO KubePodProcess(copyFilesToKubeConfigVolume):210 - Uploading file: FINISHED_UPLOADING 2022-04-17 23:57:12 INFO KubePodProcess():403 - Waiting until pod is ready... 2022-04-17 23:57:13 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$5):438 - Setting stdout... 2022-04-17 23:57:13 INFO KubePodProcess(lambda$setupStdOutAndStdErrListeners$6):449 - Setting stderr... 2022-04-17 23:57:14 INFO KubePodProcess():417 - Reading pod IP... 2022-04-17 23:57:14 INFO KubePodProcess():419 - Pod IP: 10.216.0.43 2022-04-17 23:57:14 INFO KubePodProcess():426 - Using null stdin output stream... 2022-04-17 23:57:14 INFO DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):243 - Destination output thread started. destination - 2022-04-17 23:57:14 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:11 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} destination - 2022-04-17 23:57:14 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:11 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: b9ed3a1652384cf4a62fd8df9e8e5dea destination - 2022-04-17 23:57:14 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:11 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.destination.gcs.GcsDestination destination - 2022-04-17 23:57:14 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:11 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: WRITE destination - 2022-04-17 23:57:14 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:11 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-17 23:57:14 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:11 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-17 23:57:14 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:11 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-17 23:57:14 INFO DefaultReplicationWorker(run):136 - Waiting for source thread to join. 2022-04-17 23:57:14 INFO DefaultReplicationWorker(lambda$getReplicationRunnable$2):207 - Replication thread started. 2022-04-17 23:57:14 INFO KubePodProcess(getReturnCode):591 - Exit code for pod destination-gcs-sync-32372-0-boqia is 0 2022-04-17 23:57:14 INFO KubePodProcess(exitValue):606 - Closed all resources for pod destination-gcs-sync-32372-0-boqia source - 2022-04-17 23:57:14 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:14 INFO i.a.i.s.o.OracleSource(main):175 - starting source: class io.airbyte.integrations.source.oracle.OracleSource source - 2022-04-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, config=source_config.json} source - 2022-04-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: e8de42663dd1424883a2aadd42ef43a0 source - 2022-04-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource source - 2022-04-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: READ source - 2022-04-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 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-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 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-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 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-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 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-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 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 source - 2022-04-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL source - 2022-04-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null source - 2022-04-17 23:57:15 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:15 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='VALORI_GIULESTI_ANB', namespace='ZLERNE'}, New Cursor Field: null. Resetting cursor value source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_PLUVIOMETRE_ANB column NUME_INSTALATIE (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_PLUVIOMETRE_ANB column PARAMETRU (type VARCHAR2[50]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_PLUVIOMETRE_ANB column VALOARE (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_PLUVIOMETRE_ANB column DATA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_PLUVIOMETRE_ANB column TIP_SEMNAL (type VARCHAR2[11]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_GIULESTI_ANB column NUME_INSTALATIE (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_GIULESTI_ANB column PARAMETRU (type VARCHAR2[50]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_GIULESTI_ANB column VALOARE (type FLOAT[126]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_GIULESTI_ANB column DATA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_GIULESTI_ANB column IDTF (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_DEBITMETRE_ANB column NUME_INSTALATIE (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_DEBITMETRE_ANB column PARAMETRU (type VARCHAR2[50]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_DEBITMETRE_ANB column VALOARE (type FLOAT[126]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_DEBITMETRE_ANB column DATA (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table VALORI_DEBITMETRE_ANB column TIP_SEMNAL (type CHAR[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column STATEMENT_ID (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column PLAN_ID (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column TIMESTAMP (type DATE[7]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column REMARKS (type VARCHAR2[4000]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OPERATION (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OPTIONS (type VARCHAR2[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OBJECT_NODE (type VARCHAR2[128]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OBJECT_OWNER (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OBJECT_NAME (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OBJECT_ALIAS (type VARCHAR2[65]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OBJECT_INSTANCE (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OBJECT_TYPE (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OPTIMIZER (type VARCHAR2[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column SEARCH_COLUMNS (type NUMBER[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column ID (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column PARENT_ID (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column DEPTH (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column POSITION (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column COST (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column CARDINALITY (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column BYTES (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OTHER_TAG (type VARCHAR2[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column PARTITION_START (type VARCHAR2[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column PARTITION_STOP (type VARCHAR2[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column PARTITION_ID (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OTHER (type LONG[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column DISTRIBUTION (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column CPU_COST (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column IO_COST (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column TEMP_SPACE (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column ACCESS_PREDICATES (type VARCHAR2[4000]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column FILTER_PREDICATES (type VARCHAR2[4000]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column PROJECTION (type VARCHAR2[4000]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column TIME (type NUMBER[38]) -> Json type io.airbyte.protocol.models.JsonSchemaType@25d2f66 source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column QBLOCK_NAME (type VARCHAR2[30]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table TOAD_PLAN_TABLE column OTHER_XML (type CLOB[4000]) -> Json type io.airbyte.protocol.models.JsonSchemaType@73fb1d7f source - 2022-04-17 23:57:17 INFO DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-04-17 23:57:17 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: VALORI_GIULESTI_ANB 2022-04-17 23:58:17 INFO KubePodProcess(destroy):498 - Destroying Kube process: source-oracle-sync-32372-0-aasnj 2022-04-17 23:58:17 INFO KubePodProcess(destroy):504 - Destroyed Kube process: source-oracle-sync-32372-0-aasnj 2022-04-17 23:58:17 WARN LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Socket closed. Typically happens when cancelling a job. 2022-04-17 23:58:47 INFO KubePodProcess(getReturnCode):568 - Unable to find pod source-oracle-sync-32372-0-aasnj to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2022-04-17 23:58:47 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-32372-0-aasnj 2022-04-17 23:58:47 INFO KubePodProcess(getReturnCode):568 - Unable to find pod source-oracle-sync-32372-0-aasnj to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2022-04-17 23:58:47 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-32372-0-aasnj 2022-04-17 23:58:47 INFO KubePodProcess(getReturnCode):568 - Unable to find pod source-oracle-sync-32372-0-aasnj to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2022-04-17 23:58:47 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-32372-0-aasnj 2022-04-17 23:58:47 INFO KubePodProcess(getReturnCode):568 - Unable to find pod source-oracle-sync-32372-0-aasnj to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2022-04-17 23:58:47 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-32372-0-aasnj 2022-04-17 23:58:47 INFO KubePodProcess(getReturnCode):568 - Unable to find pod source-oracle-sync-32372-0-aasnj to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2022-04-17 23:58:47 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-32372-0-aasnj 2022-04-17 23:58:47 INFO KubePodProcess(getReturnCode):568 - Unable to find pod source-oracle-sync-32372-0-aasnj to retrieve exit value. Defaulting to value 143. This is expected if the job was cancelled. 2022-04-17 23:58:47 INFO KubePodProcess(exitValue):606 - Closed all resources for pod source-oracle-sync-32372-0-aasnj 2022-04-17 23:58:47 ERROR DefaultReplicationWorker(run):145 - Sync worker failed. java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.net.SocketException: Socket closed at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[?:?] at java.util.concurrent.FutureTask.get(FutureTask.java:191) ~[?:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:137) ~[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) [?:?] Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 143. 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:118) ~[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) [?:?] Suppressed: java.net.SocketException: Socket closed at sun.nio.ch.NioSocketImpl.ensureOpenAndConnected(NioSocketImpl.java:165) ~[?:?] at sun.nio.ch.NioSocketImpl.beginWrite(NioSocketImpl.java:366) ~[?:?] at sun.nio.ch.NioSocketImpl.implWrite(NioSocketImpl.java:411) ~[?:?] at sun.nio.ch.NioSocketImpl.write(NioSocketImpl.java:440) ~[?:?] at sun.nio.ch.NioSocketImpl$2.write(NioSocketImpl.java:826) ~[?:?] at java.net.Socket$SocketOutputStream.write(Socket.java:1035) ~[?:?] at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?] at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:313) ~[?:?] at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:318) ~[?:?] at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?] at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?] at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.notifyEndOfStream(DefaultAirbyteDestination.java:93) ~[io.airbyte-airbyte-workers-0.33.11-alpha.jar:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:106) ~[io.airbyte-airbyte-workers-0.33.11-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:118) ~[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) [?:?] Caused by: java.lang.RuntimeException: java.net.SocketException: Socket closed at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$2(DefaultReplicationWorker.java:231) ~[io.airbyte-airbyte-workers-0.33.11-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?] at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] ... 1 more Caused by: java.net.SocketException: Socket closed at sun.nio.ch.NioSocketImpl.ensureOpenAndConnected(NioSocketImpl.java:165) ~[?:?] at sun.nio.ch.NioSocketImpl.beginWrite(NioSocketImpl.java:366) ~[?:?] at sun.nio.ch.NioSocketImpl.implWrite(NioSocketImpl.java:411) ~[?:?] at sun.nio.ch.NioSocketImpl.write(NioSocketImpl.java:440) ~[?:?] at sun.nio.ch.NioSocketImpl$2.write(NioSocketImpl.java:826) ~[?:?] at java.net.Socket$SocketOutputStream.write(Socket.java:1035) ~[?:?] at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?] at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304) ~[?:?] at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282) ~[?:?] at sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132) ~[?:?] at java.io.OutputStreamWriter.write(OutputStreamWriter.java:205) ~[?:?] at java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120) ~[?:?] at java.io.BufferedWriter.write(BufferedWriter.java:233) ~[?:?] at java.io.Writer.write(Writer.java:249) ~[?:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.accept(DefaultAirbyteDestination.java:85) ~[io.airbyte-airbyte-workers-0.33.11-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$2(DefaultReplicationWorker.java:216) ~[io.airbyte-airbyte-workers-0.33.11-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?] at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] ... 1 more 2022-04-17 23:58:47 INFO DefaultReplicationWorker(run):169 - sync summary: io.airbyte.config.ReplicationAttemptSummary@78d57e96[status=failed,recordsSynced=64,bytesSynced=8992,startTime=1650239827210,endTime=1650239927923] 2022-04-17 23:58:47 INFO DefaultReplicationWorker(run):178 - Source did not output any state messages 2022-04-17 23:58:47 WARN DefaultReplicationWorker(run):189 - State capture: No state retained. 2022-04-17 23:58:47 INFO TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling... 2022-04-17 23:58:47 INFO ReplicationActivityImpl(replicate):121 - sync summary: io.airbyte.config.StandardSyncOutput@44dae90b[standardSyncSummary=io.airbyte.config.StandardSyncSummary@7b11c419[status=failed,recordsSynced=64,bytesSynced=8992,startTime=1650239827210,endTime=1650239927923],state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@68af6dc9[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@727b999d[stream=io.airbyte.protocol.models.AirbyteStream@617ab468[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={}]]