2022-04-20 03:34:10 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.1-alpha
2022-04-20 03:34:12 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/114/0/logs.log
2022-04-20 03:34:12 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.1-alpha
2022-04-20 03:34:12 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword example - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-20 03:34:12 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword existingJavaType - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-20 03:34:12 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 114 attempt id: 0
2022-04-20 03:34:12 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.gl_periods=full_refresh - overwrite}
2022-04-20 03:34:12 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-20 03:34:13 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-mysql:0.1.18 exists...
2022-04-20 03:34:13 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-mysql:0.1.18 was found locally.
2022-04-20 03:34:13 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 114
2022-04-20 03:34:13 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/114/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mysql:0.1.18 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=114 airbyte/destination-mysql:0.1.18 write --config destination_config.json --catalog destination_catalog.json
2022-04-20 03:34:13 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-fusion-data-loader:dev exists...
2022-04-20 03:34:13 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-fusion-data-loader:dev was found locally.
2022-04-20 03:34:13 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 114
2022-04-20 03:34:13 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/114/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-fusion-data-loader:dev -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=114 airbyte/source-fusion-data-loader:dev read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-04-20 03:34:13 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-20 03:34:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-20 03:34:13 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-20 03:34:29 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-20 03:34:29 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-20 03:34:29 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-20 03:34:29 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-20 03:34:29 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-20 03:34:31 destination > 2022-04-20 03:34:31 INFO i.a.i.d.m.MySQLDestination(main):125 - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-04-20 03:34:32 source > Begins reading streams !!
2022-04-20 03:34:32 source > cursor start date: 2018-09-11T20:01:03.200+00:00
2022-04-20 03:34:32 source > cursor end date : 2018-09-11T20:01:04.669+00:00
2022-04-20 03:34:32 source > no of rows to be fetched in incremental processing: 25
2022-04-20 03:34:32 source > >> start reading stream : gl_periods
2022-04-20 03:34:32 source > is incremental ? :False
2022-04-20 03:34:32 source > cursor field : None
2022-04-20 03:34:32 source > state : {}
2022-04-20 03:34:32 source > stream query : SELECT END_DATE,ATTRIBUTE1,ATTRIBUTE2,ATTRIBUTE3,ATTRIBUTE4,ATTRIBUTE5,ATTRIBUTE6,ATTRIBUTE7,ATTRIBUTE8,CREATED_BY,PERIOD_NUM,START_DATE,DESCRIPTION,FISCAL_YEAR,PERIOD_NAME,PERIOD_TYPE,PERIOD_YEAR,QUARTER_NUM,CREATION_DATE,ENTERPRISE_ID,ATTRIBUTE_DATE1,ATTRIBUTE_DATE2,ATTRIBUTE_DATE3,ATTRIBUTE_DATE4,ATTRIBUTE_DATE5,LAST_UPDATED_BY,PERIOD_SET_NAME,YEAR_START_DATE,LAST_UPDATE_DATE,ATTRIBUTE_NUMBER1,ATTRIBUTE_NUMBER2,ATTRIBUTE_NUMBER3,ATTRIBUTE_NUMBER4,ATTRIBUTE_NUMBER5,GLOBAL_ATTRIBUTE1,GLOBAL_ATTRIBUTE2,GLOBAL_ATTRIBUTE3,GLOBAL_ATTRIBUTE4,GLOBAL_ATTRIBUTE5,GLOBAL_ATTRIBUTE6,GLOBAL_ATTRIBUTE7,GLOBAL_ATTRIBUTE8,GLOBAL_ATTRIBUTE9,LAST_UPDATE_LOGIN,ATTRIBUTE_CATEGORY,GLOBAL_ATTRIBUTE10,GLOBAL_ATTRIBUTE11,GLOBAL_ATTRIBUTE12,GLOBAL_ATTRIBUTE13,GLOBAL_ATTRIBUTE14,GLOBAL_ATTRIBUTE15,GLOBAL_ATTRIBUTE16,GLOBAL_ATTRIBUTE17,GLOBAL_ATTRIBUTE18,GLOBAL_ATTRIBUTE19,GLOBAL_ATTRIBUTE20,QUARTER_START_DATE,CONFIRMATION_STATUS,ENTERED_PERIOD_NAME,OBJECT_VERSION_NUMBER,ADJUSTMENT_PERIOD_FLAG,GLOBAL_ATTRIBUTE_DATE1,GLOBAL_ATTRIBUTE_DATE2,GLOBAL_ATTRIBUTE_DATE3,GLOBAL_ATTRIBUTE_DATE4,GLOBAL_ATTRIBUTE_DATE5,GLOBAL_ATTRIBUTE_NUMBER1,GLOBAL_ATTRIBUTE_NUMBER2,GLOBAL_ATTRIBUTE_NUMBER3,GLOBAL_ATTRIBUTE_NUMBER4,GLOBAL_ATTRIBUTE_NUMBER5,GLOBAL_ATTRIBUTE_CATEGORY FROM gl_periods  WHERE 1=1 AND last_update_date>=TO_UTC_TIMESTAMP_TZ('2018-09-11T20:01:03.200+00:00') AND last_update_date<TO_UTC_TIMESTAMP_TZ('2018-09-11T20:01:04.669+00:00')
2022-04-20 03:34:32 destination > 2022-04-20 03:34:32 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-20 03:34:32 destination > 2022-04-20 03:34:32 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: dde6a9007fe44f5683bdfae64bdfb179
2022-04-20 03:34:32 destination > 2022-04-20 03:34:32 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-04-20 03:34:32 destination > 2022-04-20 03:34:32 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: WRITE
2022-04-20 03:34:32 destination > 2022-04-20 03:34:32 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-20 03:34:38 destination > 2022-04-20 03:34:38 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-20 03:34:38 destination > 2022-04-20 03:34:38 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-20 03:34:38 destination > 2022-04-20 03:34:38 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-20 03:34:40 destination > 2022-04-20 03:34:38 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-20 03:34:44 destination > 2022-04-20 03:34:44 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-04-20 03:34:44 destination > 2022-04-20 03:34:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=gl_periods, namespace=null, outputSchemaName=discometa, tmpTableName=_airbyte_tmp_zwx_gl_periods, outputTableName=_airbyte_raw_gl_periods, syncMode=overwrite}
2022-04-20 03:34:44 destination > 2022-04-20 03:34:44 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-20 03:34:44 destination > 2022-04-20 03:34:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - Preparing tmp tables in destination started for 1 streams
2022-04-20 03:34:44 destination > 2022-04-20 03:34:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream gl_periods. schema: discometa, tmp table name: _airbyte_tmp_zwx_gl_periods
2022-04-20 03:34:46 destination > 2022-04-20 03:34:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - Preparing tables in destination completed.
2022-04-20 03:35:53 source > WCC server : None, WCC Security group: None
2022-04-20 03:35:53 source > bischeduleservice->scheduleReport: Begins Scheduling bi report...
2022-04-20 03:35:53 source > scheduledReport: {'reportAbsolutePath': '/Custom/OrbitQueryService/OrbitQueryReport.xdo', 'parameters': {'query': 'U0VMRUNUIEVORF9EQVRFLEFUVFJJQlVURTEsQVRUUklCVVRFMixBVFRSSUJVVEUzLEFUVFJJQlVURTQsQVRUUklCVVRFNSxBVFRSSUJVVEU2LEFUVFJJQlVURTcsQVRUUklCVVRFOCxDUkVBVEVEX0JZLFBFUklPRF9OVU0sU1RBUlRfREFURSxERVNDUklQVElPTixGSVNDQUxfWUVBUixQRVJJT0RfTkFNRSxQRVJJT0RfVFlQRSxQRVJJT0RfWUVBUixRVUFSVEVSX05VTSxDUkVBVElPTl9EQVRFLEVOVEVSUFJJU0VfSUQsQVRUUklCVVRFX0RBVEUxLEFUVFJJQlVURV9EQVRFMixBVFRSSUJVVEVfREFURTMsQVRUUklCVVRFX0RBVEU0LEFUVFJJQlVURV9EQVRFNSxMQVNUX1VQREFURURfQlksUEVSSU9EX1NFVF9OQU1FLFlFQVJfU1RBUlRfREFURSxMQVNUX1VQREFURV9EQVRFLEFUVFJJQlVURV9OVU1CRVIxLEFUVFJJQlVURV9OVU1CRVIyLEFUVFJJQlVURV9OVU1CRVIzLEFUVFJJQlVURV9OVU1CRVI0LEFUVFJJQlVURV9OVU1CRVI1LEdMT0JBTF9BVFRSSUJVVEUxLEdMT0JBTF9BVFRSSUJVVEUyLEdMT0JBTF9BVFRSSUJVVEUzLEdMT0JBTF9BVFRSSUJVVEU0LEdMT0JBTF9BVFRSSUJVVEU1LEdMT0JBTF9BVFRSSUJVVEU2LEdMT0JBTF9BVFRSSUJVVEU3LEdMT0JBTF9BVFRSSUJVVEU4LEdMT0JBTF9BVFRSSUJVVEU5LExBU1RfVVBEQVRFX0xPR0lOLEFUVFJJQlVURV9DQVRFR09SWSxHTE9CQUxfQVRUUklCVVRFMTAsR0xPQkFMX0FUVFJJQlVURTExLEdMT0JBTF9BVFRSSUJVVEUxMixHTE9CQUxfQVRUUklCVVRFMTMsR0xPQkFMX0FUVFJJQlVURTE0LEdMT0JBTF9BVFRSSUJVVEUxNSxHTE9CQUxfQVRUUklCVVRFMTYsR0xPQkFMX0FUVFJJQlVURTE3LEdMT0JBTF9BVFRSSUJVVEUxOCxHTE9CQUxfQVRUUklCVVRFMTksR0xPQkFMX0FUVFJJQlVURTIwLFFVQVJURVJfU1RBUlRfREFURSxDT05GSVJNQVRJT05fU1RBVFVTLEVOVEVSRURfUEVSSU9EX05BTUUsT0JKRUNUX1ZFUlNJT05fTlVNQkVSLEFESlVTVE1FTlRfUEVSSU9EX0ZMQUcsR0xPQkFMX0FUVFJJQlVURV9EQVRFMSxHTE9CQUxfQVRUUklCVVRFX0RBVEUyLEdMT0JBTF9BVFRSSUJVVEVfREFURTMsR0xPQkFMX0FUVFJJQlVURV9EQVRFNCxHTE9CQUxfQVRUUklCVVRFX0RBVEU1LEdMT0JBTF9BVFRSSUJVVEVfTlVNQkVSMSxHTE9CQUxfQVRUUklCVVRFX05VTUJFUjIsR0xPQkFMX0FUVFJJQlVURV9OVU1CRVIzLEdMT0JBTF9BVFRSSUJVVEVfTlVNQkVSNCxHTE9CQUxfQVRUUklCVVRFX05VTUJFUjUsR0xPQkFMX0FUVFJJQlVURV9DQVRFR09SWSBGUk9NIGdsX3BlcmlvZHMgIFdIRVJFIDE9MSBBTkQgbGFzdF91cGRhdGVfZGF0ZT49VE9fVVRDX1RJTUVTVEFNUF9UWignMjAxOC0wOS0xMVQyMDowMTowMy4yMDArMDA6MDAnKSBBTkQgbGFzdF91cGRhdGVfZGF0ZTxUT19VVENfVElNRVNUQU1QX1RaKCcyMDE4LTA5LTExVDIwOjAxOjA0LjY2OSswMDowMCcp'}, 'wccServerName': None, 'wccSecurityGroup': None, 'reportFormat': 'csv'}
2022-04-20 03:35:53 source > bischeduleservice->scheduleReport-> scheduleRequest: {'userJobDesc': '', 'userJobName': 'BG7GC5PFUXO96WM', 'saveDataOption': True, 'saveOutputOption': True, 'schedulePublicOption': True, 'startDate': 'SYSDATE', 'reportRequest': {'reportAbsolutePath': '/Custom/OrbitQueryService/OrbitQueryReport.xdo', 'byPassCache': True, 'flattenXML': False, 'sizeOfDataChunkDownload': -1, 'parameterNameValues': {'listOfParamNameValues': {'item': [{'name': 'query', 'values': {'item': 'U0VMRUNUIEVORF9EQVRFLEFUVFJJQlVURTEsQVRUUklCVVRFMixBVFRSSUJVVEUzLEFUVFJJQlVURTQsQVRUUklCVVRFNSxBVFRSSUJVVEU2LEFUVFJJQlVURTcsQVRUUklCVVRFOCxDUkVBVEVEX0JZLFBFUklPRF9OVU0sU1RBUlRfREFURSxERVNDUklQVElPTixGSVNDQUxfWUVBUixQRVJJT0RfTkFNRSxQRVJJT0RfVFlQRSxQRVJJT0RfWUVBUixRVUFSVEVSX05VTSxDUkVBVElPTl9EQVRFLEVOVEVSUFJJU0VfSUQsQVRUUklCVVRFX0RBVEUxLEFUVFJJQlVURV9EQVRFMixBVFRSSUJVVEVfREFURTMsQVRUUklCVVRFX0RBVEU0LEFUVFJJQlVURV9EQVRFNSxMQVNUX1VQREFURURfQlksUEVSSU9EX1NFVF9OQU1FLFlFQVJfU1RBUlRfREFURSxMQVNUX1VQREFURV9EQVRFLEFUVFJJQlVURV9OVU1CRVIxLEFUVFJJQlVURV9OVU1CRVIyLEFUVFJJQlVURV9OVU1CRVIzLEFUVFJJQlVURV9OVU1CRVI0LEFUVFJJQlVURV9OVU1CRVI1LEdMT0JBTF9BVFRSSUJVVEUxLEdMT0JBTF9BVFRSSUJVVEUyLEdMT0JBTF9BVFRSSUJVVEUzLEdMT0JBTF9BVFRSSUJVVEU0LEdMT0JBTF9BVFRSSUJVVEU1LEdMT0JBTF9BVFRSSUJVVEU2LEdMT0JBTF9BVFRSSUJVVEU3LEdMT0JBTF9BVFRSSUJVVEU4LEdMT0JBTF9BVFRSSUJVVEU5LExBU1RfVVBEQVRFX0xPR0lOLEFUVFJJQlVURV9DQVRFR09SWSxHTE9CQUxfQVRUUklCVVRFMTAsR0xPQkFMX0FUVFJJQlVURTExLEdMT0JBTF9BVFRSSUJVVEUxMixHTE9CQUxfQVRUUklCVVRFMTMsR0xPQkFMX0FUVFJJQlVURTE0LEdMT0JBTF9BVFRSSUJVVEUxNSxHTE9CQUxfQVRUUklCVVRFMTYsR0xPQkFMX0FUVFJJQlVURTE3LEdMT0JBTF9BVFRSSUJVVEUxOCxHTE9CQUxfQVRUUklCVVRFMTksR0xPQkFMX0FUVFJJQlVURTIwLFFVQVJURVJfU1RBUlRfREFURSxDT05GSVJNQVRJT05fU1RBVFVTLEVOVEVSRURfUEVSSU9EX05BTUUsT0JKRUNUX1ZFUlNJT05fTlVNQkVSLEFESlVTVE1FTlRfUEVSSU9EX0ZMQUcsR0xPQkFMX0FUVFJJQlVURV9EQVRFMSxHTE9CQUxfQVRUUklCVVRFX0RBVEUyLEdMT0JBTF9BVFRSSUJVVEVfREFURTMsR0xPQkFMX0FUVFJJQlVURV9EQVRFNCxHTE9CQUxfQVRUUklCVVRFX0RBVEU1LEdMT0JBTF9BVFRSSUJVVEVfTlVNQkVSMSxHTE9CQUxfQVRUUklCVVRFX05VTUJFUjIsR0xPQkFMX0FUVFJJQlVURV9OVU1CRVIzLEdMT0JBTF9BVFRSSUJVVEVfTlVNQkVSNCxHTE9CQUxfQVRUUklCVVRFX05VTUJFUjUsR0xPQkFMX0FUVFJJQlVURV9DQVRFR09SWSBGUk9NIGdsX3BlcmlvZHMgIFdIRVJFIDE9MSBBTkQgbGFzdF91cGRhdGVfZGF0ZT49VE9fVVRDX1RJTUVTVEFNUF9UWignMjAxOC0wOS0xMVQyMDowMTowMy4yMDArMDA6MDAnKSBBTkQgbGFzdF91cGRhdGVfZGF0ZTxUT19VVENfVElNRVNUQU1QX1RaKCcyMDE4LTA5LTExVDIwOjAxOjA0LjY2OSswMDowMCcp'}}]}}, 'attributeFormat': 'csv'}}
2022-04-20 03:35:53 source > scheduled report job id : 1795
2022-04-20 03:35:53 source > downloading report data for report job 1795
2022-04-20 03:35:53 source > Scheduled report history is yet to be prepare.. wait for 30 seconds
2022-04-20 03:35:53 source > Scheduled report history is yet to be prepare.. wait for 30 seconds
2022-04-20 03:35:53 source > job instance id : 1796
2022-04-20 03:35:53 source > Scheduled job is success
2022-04-20 03:35:53 source > output id : 1482
2022-04-20 03:35:53 source > temp file location : documents/xmlpwsMnBK1hEFY89182993634266366511.tmp
2022-04-20 03:35:53 source > csv file path : /tmp/1482.csv
2022-04-20 03:35:53 source > offSet : -1
2022-04-20 03:35:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 5 (9 KB)
2022-04-20 03:35:53 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-04-20 03:35:53 destination > 2022-04-20 03:35:53 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-20 03:35:53 destination > 2022-04-20 03:35:53 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure.
2022-04-20 03:35:53 destination > 2022-04-20 03:35:53 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 37480 bytes
2022-04-20 03:35:53 destination > 2022-04-20 03:35:53 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing gl_periods: 5 records
2022-04-20 03:35:53 destination > 2022-04-20 03:35:53 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):160 - Finalizing tables in destination started for 1 streams
2022-04-20 03:35:53 destination > 2022-04-20 03:35:53 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream gl_periods. schema discometa, tmp table _airbyte_tmp_zwx_gl_periods, final table _airbyte_raw_gl_periods
2022-04-20 03:35:54 destination > 2022-04-20 03:35:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):178 - Executing finalization of tables.
2022-04-20 03:35:54 destination > 2022-04-20 03:35:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - Finalizing tables in destination completed.
2022-04-20 03:35:54 destination > 2022-04-20 03:35:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Cleaning tmp tables in destination started for 1 streams
2022-04-20 03:35:54 destination > 2022-04-20 03:35:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream gl_periods. schema discometa, tmp table name: _airbyte_tmp_zwx_gl_periods
2022-04-20 03:35:54 destination > 2022-04-20 03:35:54 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):192 - Cleaning tmp tables in destination completed.
2022-04-20 03:35:54 destination > 2022-04-20 03:35:54 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-04-20 03:35:54 destination > 2022-04-20 03:35:54 INFO i.a.i.d.m.MySQLDestination(main):127 - completed destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-04-20 03:35:54 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete.
2022-04-20 03:35:54 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6f4eb5ba[status=completed,recordsSynced=5,bytesSynced=9370,startTime=1650425652965,endTime=1650425754390,totalStats=io.airbyte.config.SyncStats@264fe482[recordsEmitted=5,bytesEmitted=9370,stateMessagesEmitted=0,recordsCommitted=5],streamStats=[io.airbyte.config.StreamSyncStats@72ed5645[streamName=gl_periods,stats=io.airbyte.config.SyncStats@4aced748[recordsEmitted=5,bytesEmitted=9370,stateMessagesEmitted=<null>,recordsCommitted=5]]]]
2022-04-20 03:35:54 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-04-20 03:35:54 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@985cdbe[state={}]
2022-04-20 03:35:54 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-20 03:35:54 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@79228541[standardSyncSummary=io.airbyte.config.StandardSyncSummary@32945978[status=completed,recordsSynced=5,bytesSynced=9370,startTime=1650425652965,endTime=1650425754390,totalStats=io.airbyte.config.SyncStats@264fe482[recordsEmitted=5,bytesEmitted=9370,stateMessagesEmitted=0,recordsCommitted=5],streamStats=[io.airbyte.config.StreamSyncStats@72ed5645[streamName=gl_periods,stats=io.airbyte.config.SyncStats@4aced748[recordsEmitted=5,bytesEmitted=9370,stateMessagesEmitted=<null>,recordsCommitted=5]]]],normalizationSummary=<null>,state=io.airbyte.config.State@985cdbe[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@55fb8ac4[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@6fa9cd92[stream=io.airbyte.protocol.models.AirbyteStream@24c45ab[name=gl_periods,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"END_DATE":{"type":["string","null"],"format":"date"},"ATTRIBUTE1":{"type":["string","null"]},"ATTRIBUTE2":{"type":["string","null"]},"ATTRIBUTE3":{"type":["string","null"]},"ATTRIBUTE4":{"type":["string","null"]},"ATTRIBUTE5":{"type":["string","null"]},"ATTRIBUTE6":{"type":["string","null"]},"ATTRIBUTE7":{"type":["string","null"]},"ATTRIBUTE8":{"type":["string","null"]},"CREATED_BY":{"type":["string","null"]},"PERIOD_NUM":{"type":["number","null"]},"START_DATE":{"type":["string","null"],"format":"date"},"DESCRIPTION":{"type":["string","null"]},"FISCAL_YEAR":{"type":["string","null"]},"PERIOD_NAME":{"type":["string","null"]},"PERIOD_TYPE":{"type":["string","null"]},"PERIOD_YEAR":{"type":["number","null"]},"QUARTER_NUM":{"type":["number","null"]},"CREATION_DATE":{"type":["string","null"],"format":"date-time"},"ENTERPRISE_ID":{"type":["number","null"]},"ATTRIBUTE_DATE1":{"type":["string","null"],"format":"date"},"ATTRIBUTE_DATE2":{"type":["string","null"],"format":"date"},"ATTRIBUTE_DATE3":{"type":["string","null"],"format":"date"},"ATTRIBUTE_DATE4":{"type":["string","null"],"format":"date"},"ATTRIBUTE_DATE5":{"type":["string","null"],"format":"date"},"LAST_UPDATED_BY":{"type":["string","null"]},"PERIOD_SET_NAME":{"type":["string","null"]},"YEAR_START_DATE":{"type":["string","null"],"format":"date"},"LAST_UPDATE_DATE":{"type":["string","null"],"format":"date-time"},"ATTRIBUTE_NUMBER1":{"type":["number","null"]},"ATTRIBUTE_NUMBER2":{"type":["number","null"]},"ATTRIBUTE_NUMBER3":{"type":["number","null"]},"ATTRIBUTE_NUMBER4":{"type":["number","null"]},"ATTRIBUTE_NUMBER5":{"type":["number","null"]},"GLOBAL_ATTRIBUTE1":{"type":["string","null"]},"GLOBAL_ATTRIBUTE2":{"type":["string","null"]},"GLOBAL_ATTRIBUTE3":{"type":["string","null"]},"GLOBAL_ATTRIBUTE4":{"type":["string","null"]},"GLOBAL_ATTRIBUTE5":{"type":["string","null"]},"GLOBAL_ATTRIBUTE6":{"type":["string","null"]},"GLOBAL_ATTRIBUTE7":{"type":["string","null"]},"GLOBAL_ATTRIBUTE8":{"type":["string","null"]},"GLOBAL_ATTRIBUTE9":{"type":["string","null"]},"LAST_UPDATE_LOGIN":{"type":["string","null"]},"ATTRIBUTE_CATEGORY":{"type":["string","null"]},"GLOBAL_ATTRIBUTE10":{"type":["string","null"]},"GLOBAL_ATTRIBUTE11":{"type":["string","null"]},"GLOBAL_ATTRIBUTE12":{"type":["string","null"]},"GLOBAL_ATTRIBUTE13":{"type":["string","null"]},"GLOBAL_ATTRIBUTE14":{"type":["string","null"]},"GLOBAL_ATTRIBUTE15":{"type":["string","null"]},"GLOBAL_ATTRIBUTE16":{"type":["string","null"]},"GLOBAL_ATTRIBUTE17":{"type":["string","null"]},"GLOBAL_ATTRIBUTE18":{"type":["string","null"]},"GLOBAL_ATTRIBUTE19":{"type":["string","null"]},"GLOBAL_ATTRIBUTE20":{"type":["string","null"]},"QUARTER_START_DATE":{"type":["string","null"],"format":"date"},"CONFIRMATION_STATUS":{"type":["string","null"]},"ENTERED_PERIOD_NAME":{"type":["string","null"]},"OBJECT_VERSION_NUMBER":{"type":["number","null"]},"ADJUSTMENT_PERIOD_FLAG":{"type":["string","null"]},"GLOBAL_ATTRIBUTE_DATE1":{"type":["string","null"],"format":"date"},"GLOBAL_ATTRIBUTE_DATE2":{"type":["string","null"],"format":"date"},"GLOBAL_ATTRIBUTE_DATE3":{"type":["string","null"],"format":"date"},"GLOBAL_ATTRIBUTE_DATE4":{"type":["string","null"],"format":"date"},"GLOBAL_ATTRIBUTE_DATE5":{"type":["string","null"],"format":"date"},"GLOBAL_ATTRIBUTE_NUMBER1":{"type":["number","null"]},"GLOBAL_ATTRIBUTE_NUMBER2":{"type":["number","null"]},"GLOBAL_ATTRIBUTE_NUMBER3":{"type":["number","null"]},"GLOBAL_ATTRIBUTE_NUMBER4":{"type":["number","null"]},"GLOBAL_ATTRIBUTE_NUMBER5":{"type":["number","null"]},"GLOBAL_ATTRIBUTE_CATEGORY":{"type":["string","null"]}},"additionalProperties":true},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[LAST_UPDATE_DATE],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[LAST_UPDATE_DATE],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-04-20 03:35:54 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-20 03:35:54 INFO i.a.c.p.ConfigRepository(updateConnectionState):773 - Updating connection aea17fbd-5f22-407e-975d-d1859b9d5820 state: io.airbyte.config.State@3c474f0[state={}]
2022-04-20 03:35:54 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/114/0/logs.log
2022-04-20 03:35:54 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.1-alpha
2022-04-20 03:35:54 INFO i.a.w.DefaultNormalizationWorker(run):47 - Running normalization.
2022-04-20 03:35:54 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-mysql:0.1.75
2022-04-20 03:35:54 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-mysql:0.1.75 exists...
2022-04-20 03:35:54 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-mysql:0.1.75 was found locally.
2022-04-20 03:35:54 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 114
2022-04-20 03:35:54 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/114/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha airbyte/normalization-mysql:0.1.75 run --integration-type mysql --config destination_config.json --catalog destination_catalog.json
2022-04-20 03:35:55 normalization > Running: transform-config --config destination_config.json --integration-type mysql --out /data/114/0/normalize
2022-04-20 03:35:56 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.mysql: 'mysql'>, out='/data/114/0/normalize')
2022-04-20 03:35:56 normalization > transform_mysql
2022-04-20 03:35:56 normalization > Running: transform-catalog --integration-type mysql --profile-config-dir /data/114/0/normalize --catalog destination_catalog.json --out /data/114/0/normalize/models/generated/ --json-column _airbyte_data
2022-04-20 03:35:56 normalization > Processing destination_catalog.json...
2022-04-20 03:35:56 normalization >   Generating airbyte_ctes/discometa/gl_periods_ab1.sql from gl_periods
2022-04-20 03:35:56 normalization >   Generating airbyte_ctes/discometa/gl_periods_ab2.sql from gl_periods
2022-04-20 03:35:56 normalization >   Generating airbyte_ctes/discometa/gl_periods_ab3.sql from gl_periods
2022-04-20 03:35:56 normalization >   Generating airbyte_tables/discometa/gl_periods.sql from gl_periods
2022-04-20 03:35:56 normalization > detected no config file for ssh, assuming ssh is off.
2022-04-20 03:35:59 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):158 - Completing future exceptionally...
io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:61) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:19) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:58) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	... 3 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:160) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:46) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:19) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
2022-04-20 03:35:59 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-20 03:35:59 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-20 03:35:59 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=0430209e-0414-3923-99ab-cc5beae2b98f, activityType=Normalize, attempt=1
java.lang.RuntimeException: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:233) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:72) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.temporal.serviceclient.CheckedExceptionWrapper.wrap(CheckedExceptionWrapper.java:56) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInternal.wrap(WorkflowInternal.java:448) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.activity.Activity.wrap(Activity.java:51) ~[temporal-sdk-1.8.1.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:135) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$1(NormalizationActivityImpl.java:98) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	... 14 more
Caused by: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:129) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$1(NormalizationActivityImpl.java:98) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	... 14 more
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:61) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:19) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	... 1 more
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:58) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:19) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
	... 1 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:160) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:46) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:19) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]