2022-05-07 01:10:22 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha 2022-05-07 01:10:22 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/7696/0/logs.log 2022-05-07 01:10:22 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha 2022-05-07 01:10:22 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 7696 attempt id: 0 2022-05-07 01:10:22 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.activity_types=full_refresh - overwrite, null.programs=full_refresh - overwrite, null.activities_change_data_value=full_refresh - overwrite, null.leads=full_refresh - overwrite, null.campaigns=full_refresh - overwrite} 2022-05-07 01:10:22 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-05-07 01:10:22 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.25 exists... 2022-05-07 01:10:22 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.25 was found locally. 2022-05-07 01:10:22 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 7696 2022-05-07 01:10:22 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/7696/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.25 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=7696 airbyte/destination-snowflake:0.4.25 write --config destination_config.json --catalog destination_catalog.json 2022-05-07 01:10:22 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-05-07 01:10:22 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-05-07 01:10:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-05-07 01:10:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 1 (0 bytes) 2022-05-07 01:10:22 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other. 2022-05-07 01:10:23 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-05-07 01:10:23 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-07 01:10:23 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-07 01:10:23 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-05-07 01:10:23 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-05-07 01:10:23 destination > 2022-05-07 01:10:23 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-05-07 01:10:23 destination > 2022-05-07 01:10:23 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-05-07 01:10:23 destination > 2022-05-07 01:10:23 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-05-07 01:10:23 destination > 2022-05-07 01:10:23 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-05-07 01:10:24 destination > 2022-05-07 01:10:24 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-05-07 01:10:24 destination > 2022-05-07 01:10:24 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-05-07 01:10:24 destination > 2022-05-07 01:10:24 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-05-07 01:10:24 destination > 2022-05-07 01:10:24 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-05-07 01:10:24 destination > 2022-05-07 01:10:24 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2022-05-07 01:10:24 destination > 2022-05-07 01:10:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=activities_change_data_value, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_jmk_activities_change_data_value, outputTableName=_airbyte_raw_activities_change_data_value, syncMode=overwrite} 2022-05-07 01:10:24 destination > 2022-05-07 01:10:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=activity_types, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_pun_activity_types, outputTableName=_airbyte_raw_activity_types, syncMode=overwrite} 2022-05-07 01:10:24 destination > 2022-05-07 01:10:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=campaigns, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_ayc_campaigns, outputTableName=_airbyte_raw_campaigns, syncMode=overwrite} 2022-05-07 01:10:24 destination > 2022-05-07 01:10:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=leads, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_nnx_leads, outputTableName=_airbyte_raw_leads, syncMode=overwrite} 2022-05-07 01:10:24 destination > 2022-05-07 01:10:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=programs, namespace=MARKETO, outputSchemaName=MARKETO, tmpTableName=_airbyte_tmp_qzb_programs, outputTableName=_airbyte_raw_programs, syncMode=overwrite} 2022-05-07 01:10:24 destination > 2022-05-07 01:10:24 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-05-07 01:10:24 destination > 2022-05-07 01:10:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 5 streams 2022-05-07 01:10:24 destination > 2022-05-07 01:10:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MARKETO stream activities_change_data_value: tmp table: _airbyte_tmp_jmk_activities_change_data_value, stage: 2022/05/07/01/0CEE0CC2-236C-41D7-B9C1-1A477280A535/ 2022-05-07 01:10:24 destination > 2022-05-07 01:10:24 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-05-07 01:10:25 destination > 2022-05-07 01:10:25 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@1d50a7ca 2022-05-07 01:10:25 destination > 2022-05-07 01:10:25 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-05-07 01:10:25 destination > 2022-05-07 01:10:25 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-05-07 01:10:26 destination > 2022-05-07 01:10:26 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MARKETO stream activities_change_data_value 2022-05-07 01:10:26 destination > 2022-05-07 01:10:26 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MARKETO stream activity_types: tmp table: _airbyte_tmp_pun_activity_types, stage: 2022/05/07/01/0CEE0CC2-236C-41D7-B9C1-1A477280A535/ 2022-05-07 01:10:26 destination > 2022-05-07 01:10:26 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-05-07 01:10:26 destination > 2022-05-07 01:10:26 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MARKETO stream activity_types 2022-05-07 01:10:26 destination > 2022-05-07 01:10:26 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MARKETO stream campaigns: tmp table: _airbyte_tmp_ayc_campaigns, stage: 2022/05/07/01/0CEE0CC2-236C-41D7-B9C1-1A477280A535/ 2022-05-07 01:10:26 destination > 2022-05-07 01:10:26 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MARKETO stream campaigns 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MARKETO stream leads: tmp table: _airbyte_tmp_nnx_leads, stage: 2022/05/07/01/0CEE0CC2-236C-41D7-B9C1-1A477280A535/ 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MARKETO stream leads 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema MARKETO stream programs: tmp table: _airbyte_tmp_qzb_programs, stage: 2022/05/07/01/0CEE0CC2-236C-41D7-B9C1-1A477280A535/ 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema MARKETO stream programs 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed. 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):229 - The main thread is exiting while children non-daemon threads from a connector are still active. 2022-05-07 01:10:27 destination > Ideally, this situation should not happen... 2022-05-07 01:10:27 destination > Please check with maintainers if the connector or library code should safely clean up its threads before quitting instead. 2022-05-07 01:10:27 destination > The main thread is: main (RUNNABLE) 2022-05-07 01:10:27 destination > Thread stacktrace: java.base/java.lang.Thread.getStackTrace(Thread.java:1610) 2022-05-07 01:10:27 destination > at io.airbyte.integrations.base.IntegrationRunner.dumpThread(IntegrationRunner.java:264) 2022-05-07 01:10:27 destination > at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:233) 2022-05-07 01:10:27 destination > at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190) 2022-05-07 01:10:27 destination > at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163) 2022-05-07 01:10:27 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) 2022-05-07 01:10:27 destination > at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) 2022-05-07 01:10:27 destination > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163) 2022-05-07 01:10:27 destination > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) 2022-05-07 01:10:27 destination > at io.airbyte.integrations.destination.snowflake.SnowflakeDestination.main(SnowflakeDestination.java:30) 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 WARN i.a.i.b.IntegrationRunner(watchForOrphanThreads):243 - Active non-daemon thread: pool-4-thread-1 (RUNNABLE) 2022-05-07 01:10:27 destination > Thread stacktrace: java.base@17.0.1/sun.nio.ch.Net.poll(Native Method) 2022-05-07 01:10:27 destination > at java.base@17.0.1/sun.nio.ch.NioSocketImpl.park(NioSocketImpl.java:181) 2022-05-07 01:10:27 destination > at java.base@17.0.1/sun.nio.ch.NioSocketImpl.timedRead(NioSocketImpl.java:285) 2022-05-07 01:10:27 destination > at java.base@17.0.1/sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:309) 2022-05-07 01:10:27 destination > at java.base@17.0.1/sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:350) 2022-05-07 01:10:27 destination > at java.base@17.0.1/sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:803) 2022-05-07 01:10:27 destination > at java.base@17.0.1/java.net.Socket$SocketInputStream.read(Socket.java:966) 2022-05-07 01:10:27 destination > at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:478) 2022-05-07 01:10:27 destination > at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:472) 2022-05-07 01:10:27 destination > at java.base@17.0.1/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70) 2022-05-07 01:10:27 destination > at java.base@17.0.1/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1455) 2022-05-07 01:10:27 destination > at java.base@17.0.1/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1059) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:137) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.fillBuffer(SessionInputBufferImpl.java:153) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.SessionInputBufferImpl.readLine(SessionInputBufferImpl.java:280) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:138) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:56) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:259) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.DefaultBHttpClientConnection.receiveResponseHeader(DefaultBHttpClientConnection.java:163) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.conn.CPoolProxy.receiveResponseHeader(CPoolProxy.java:157) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:273) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:125) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:272) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.internal.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.RestRequest.execute(RestRequest.java:160) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.core.HttpUtil.executeRequestInternal(HttpUtil.java:639) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.core.HttpUtil.executeRequest(HttpUtil.java:584) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.core.HttpUtil.executeGeneralRequest(HttpUtil.java:551) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.telemetry.TelemetryClient.sendBatch(TelemetryClient.java:256) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.telemetry.TelemetryClient.lambda$sendBatchAsync$0(TelemetryClient.java:204) 2022-05-07 01:10:27 destination > at app//net.snowflake.client.jdbc.telemetry.TelemetryClient$$Lambda$254/0x0000000801000818.call(Unknown Source) 2022-05-07 01:10:27 destination > at java.base@17.0.1/java.util.concurrent.FutureTask.run(FutureTask.java:264) 2022-05-07 01:10:27 destination > at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) 2022-05-07 01:10:27 destination > at java.base@17.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) 2022-05-07 01:10:27 destination > at java.base@17.0.1/java.lang.Thread.run(Thread.java:833) 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure. 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 0 current buffers (0 bytes in total) 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):186 - Copying into tables in destination started for 5 streams 2022-05-07 01:10:27 destination > 2022-05-07 01:10:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream activities_change_data_value of schema MARKETO into tmp table _airbyte_tmp_jmk_activities_change_data_value to final table _airbyte_raw_activities_change_data_value from stage path 2022/05/07/01/0CEE0CC2-236C-41D7-B9C1-1A477280A535/ with 0 file(s) [] 2022-05-07 01:10:29 destination > 2022-05-07 01:10:29 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream activity_types of schema MARKETO into tmp table _airbyte_tmp_pun_activity_types to final table _airbyte_raw_activity_types from stage path 2022/05/07/01/0CEE0CC2-236C-41D7-B9C1-1A477280A535/ with 0 file(s) [] 2022-05-07 01:10:30 destination > 2022-05-07 01:10:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream campaigns of schema MARKETO into tmp table _airbyte_tmp_ayc_campaigns to final table _airbyte_raw_campaigns from stage path 2022/05/07/01/0CEE0CC2-236C-41D7-B9C1-1A477280A535/ with 0 file(s) [] 2022-05-07 01:10:30 destination > 2022-05-07 01:10:30 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream leads of schema MARKETO into tmp table _airbyte_tmp_nnx_leads to final table _airbyte_raw_leads from stage path 2022/05/07/01/0CEE0CC2-236C-41D7-B9C1-1A477280A535/ with 0 file(s) [] 2022-05-07 01:10:31 destination > 2022-05-07 01:10:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):195 - Copying stream programs of schema MARKETO into tmp table _airbyte_tmp_qzb_programs to final table _airbyte_raw_programs from stage path 2022/05/07/01/0CEE0CC2-236C-41D7-B9C1-1A477280A535/ with 0 file(s) [] 2022-05-07 01:10:31 destination > 2022-05-07 01:10:31 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):217 - Executing finalization of tables. 2022-05-07 01:10:34 destination > 2022-05-07 01:10:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):219 - Finalizing tables in destination completed. 2022-05-07 01:10:34 destination > 2022-05-07 01:10:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):221 - Cleaning up destination started for 5 streams 2022-05-07 01:10:34 destination > 2022-05-07 01:10:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream activities_change_data_value. schema MARKETO, tmp table name: _airbyte_tmp_jmk_activities_change_data_value 2022-05-07 01:10:34 destination > 2022-05-07 01:10:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream activities_change_data_value. schema MARKETO, stage: MARKETO_ACTIVITIES_CHANGE_DATA_VALUE 2022-05-07 01:10:34 destination > 2022-05-07 01:10:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream activity_types. schema MARKETO, tmp table name: _airbyte_tmp_pun_activity_types 2022-05-07 01:10:34 destination > 2022-05-07 01:10:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream activity_types. schema MARKETO, stage: MARKETO_ACTIVITY_TYPES 2022-05-07 01:10:34 destination > 2022-05-07 01:10:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream campaigns. schema MARKETO, tmp table name: _airbyte_tmp_ayc_campaigns 2022-05-07 01:10:34 destination > 2022-05-07 01:10:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream campaigns. schema MARKETO, stage: MARKETO_CAMPAIGNS 2022-05-07 01:10:34 destination > 2022-05-07 01:10:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream leads. schema MARKETO, tmp table name: _airbyte_tmp_nnx_leads 2022-05-07 01:10:34 destination > 2022-05-07 01:10:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream leads. schema MARKETO, stage: MARKETO_LEADS 2022-05-07 01:10:35 destination > 2022-05-07 01:10:35 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):225 - Cleaning tmp table in destination started for stream programs. schema MARKETO, tmp table name: _airbyte_tmp_qzb_programs 2022-05-07 01:10:35 destination > 2022-05-07 01:10:35 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):231 - Cleaning stage in destination started for stream programs. schema MARKETO, stage: MARKETO_PROGRAMS 2022-05-07 01:10:35 destination > 2022-05-07 01:10:35 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):236 - Cleaning up destination completed. 2022-05-07 01:10:35 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):349 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@5a886447[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@544f8166[data={},additionalProperties={}],additionalProperties={}] 2022-05-07 01:10:35 destination > 2022-05-07 01:10:35 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-05-07 01:10:36 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete. 2022-05-07 01:10:36 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@327f280e[status=completed,recordsSynced=0,bytesSynced=0,startTime=1651885822223,endTime=1651885836572,totalStats=io.airbyte.config.SyncStats@351884e7[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=1,recordsCommitted=0],streamStats=[]] 2022-05-07 01:10:36 INFO i.a.w.DefaultReplicationWorker(run):248 - Source output at least one state message 2022-05-07 01:10:36 INFO i.a.w.DefaultReplicationWorker(run):254 - State capture: Updated state to: Optional[io.airbyte.config.State@13e086d3[state={}]] 2022-05-07 01:10:36 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-05-07 01:10:36 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@1e875ee4[standardSyncSummary=io.airbyte.config.StandardSyncSummary@13987471[status=completed,recordsSynced=0,bytesSynced=0,startTime=1651885822223,endTime=1651885836572,totalStats=io.airbyte.config.SyncStats@351884e7[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=1,recordsCommitted=0],streamStats=[]],state=io.airbyte.config.State@13e086d3[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@6685a5e6[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@425f2e9a[stream=io.airbyte.protocol.models.AirbyteStream@668b284b[name=activities_change_data_value,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"leadId":{"type":["null","integer"]},"reason":{"type":["string","null"]},"source":{"type":["string","null"]},"new_value":{"type":["string","null"]},"old_value":{"type":["string","null"]},"campaignId":{"type":["null","integer"]},"request_id":{"type":["string","null"]},"marketoGUID":{"type":["null","string"]},"activityDate":{"type":["null","string"],"format":"date-time"},"activityTypeId":{"type":["null","integer"]},"modifying_user":{"type":["string","null"]},"api_method_name":{"type":["string","null"]},"primaryAttributeValue":{"type":["null","string"]},"primaryAttributeValueId":{"type":["null","string"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[activityDate],sourceDefinedPrimaryKey=[[marketoGUID]],namespace=MARKETO,additionalProperties={}],syncMode=full_refresh,cursorField=[activityDate],destinationSyncMode=overwrite,primaryKey=[[marketoGUID]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3660f317[stream=io.airbyte.protocol.models.AirbyteStream@7d81caa8[name=activity_types,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"attributes":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"dataType":{"type":["null","string"]}}}},"description":{"type":["null","string"]},"primaryAttribute":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"dataType":{"type":["null","string"]}}}},"additionalProperties":false},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=MARKETO,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4611107c[stream=io.airbyte.protocol.models.AirbyteStream@7967b185[name=campaigns,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"type":{"type":["null","string"]},"active":{"type":["null","boolean"]},"createdAt":{"type":["null","string"],"format":"date-time"},"programId":{"type":["null","integer"]},"updatedAt":{"type":["null","string"],"format":"date-time"},"description":{"type":["null","string"]},"programName":{"type":["null","string"]},"workspaceName":{"type":["null","string"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[createdAt],sourceDefinedPrimaryKey=[[id]],namespace=MARKETO,additionalProperties={}],syncMode=full_refresh,cursorField=[createdAt],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@48ae0df5[stream=io.airbyte.protocol.models.AirbyteStream@3b095ac2[name=leads,jsonSchema={"type":["object","null"],"properties":{"id":{"type":["integer","null"]},"fax":{"type":["string","null"]},"city":{"type":["string","null"]},"site":{"type":["string","null"]},"email":{"type":["string","null"]},"phone":{"type":["string","null"]},"state":{"type":["string","null"]},"title":{"type":["string","null"]},"isLead":{"type":["boolean","null"]},"rating":{"type":["string","null"]},"address":{"type":["string","null"]},"company":{"type":["string","null"]},"cookies":{"type":["string","null"]},"country":{"type":["string","null"]},"sicCode":{"type":["string","null"]},"urgency":{"type":["number","null"]},"website":{"type":["string","null"]},"industry":{"type":["string","null"]},"lastName":{"type":["string","null"]},"leadRole":{"type":["string","null"]},"mktoName":{"type":["string","null"]},"priority":{"type":["integer","null"]},"createdAt":{"type":["string","null"],"format":"date-time"},"doNotCall":{"type":["boolean","null"]},"firstName":{"type":["string","null"]},"leadScore":{"type":["integer","null"]},"mainPhone":{"type":["string","null"]},"updatedAt":{"type":["string","null"],"format":"date-time"},"department":{"type":["string","null"]},"leadPerson":{"type":["string","null"]},"leadSource":{"type":["string","null"]},"leadStatus":{"type":["string","null"]},"middleName":{"type":["string","null"]},"personType":{"type":["string","null"]},"postalCode":{"type":["string","null"]},"salutation":{"type":["string","null"]},"anonymousIP":{"type":["string","null"]},"billingCity":{"type":["string","null"]},"blackListed":{"type":["boolean","null"]},"dateOfBirth":{"type":["string","null"],"format":"date-time"},"isAnonymous":{"type":["boolean","null"]},"mobilePhone":{"type":["string","null"]},"billingState":{"type":["string","null"]},"emailInvalid":{"type":["boolean","null"]},"inferredCity":{"type":["string","null"]},"unsubscribed":{"type":["boolean","null"]},"annualRevenue":{"type":["number","null"]},"billingStreet":{"type":["string","null"]},"mktoIsPartner":{"type":["boolean","null"]},"relativeScore":{"type":["integer","null"]},"billingCountry":{"type":["string","null"]},"contactCompany":{"type":["string","null"]},"emailSuspended":{"type":["boolean","null"]},"mktoIsCustomer":{"type":["boolean","null"]},"personTimeZone":{"type":["string","null"]},"doNotCallReason":{"type":["string","null"]},"inferredCompany":{"type":["string","null"]},"inferredCountry":{"type":["string","null"]},"leadPartitionId":{"type":["string","null"]},"mktoPersonNotes":{"type":["string","null"]},"relativeUrgency":{"type":["integer","null"]},"blackListedCause":{"type":["string","null"]},"emailSuspendedAt":{"type":["string","null"],"format":"date-time"},"mktoCompanyNotes":{"type":["string","null"]},"originalReferrer":{"type":["string","null"]},"billingPostalCode":{"type":["string","null"]},"emailInvalidCause":{"type":["string","null"]},"externalCompanyId":{"type":["string","null"]},"numberOfEmployees":{"type":["integer","null"]},"inferredPostalCode":{"type":["string","null"]},"leadRevenueStageId":{"type":["string","null"]},"marketingSuspended":{"type":["boolean","null"]},"mktoDoNotCallCause":{"type":["string","null"]},"originalSourceInfo":{"type":["string","null"]},"originalSourceType":{"type":["string","null"]},"unsubscribedReason":{"type":["string","null"]},"emailSuspendedCause":{"type":["string","null"]},"inferredStateRegion":{"type":["string","null"]},"mktoAcquisitionDate":{"type":["string","null"],"format":"date-time"},"acquisitionProgramId":{"type":["string","null"]},"originalSearchEngine":{"type":["string","null"]},"originalSearchPhrase":{"type":["string","null"]},"externalSalesPersonId":{"type":["string","null"]},"inferredPhoneAreaCode":{"type":["string","null"]},"registrationSourceInfo":{"type":["string","null"]},"registrationSourceType":{"type":["string","null"]},"leadRevenueCycleModelId":{"type":["string","null"]},"marketingSuspendedCause":{"type":["string","null"]},"inferredMetropolitanArea":{"type":["string","null"]},"personPrimaryLeadInterest":{"type":["string","null"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updatedAt],sourceDefinedPrimaryKey=[[id]],namespace=MARKETO,additionalProperties={}],syncMode=full_refresh,cursorField=[updatedAt],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@75d53f2f[stream=io.airbyte.protocol.models.AirbyteStream@317a4389[name=programs,jsonSchema={"type":["object","null"],"properties":{"id":{"type":["integer","null"]},"url":{"type":["null","string"]},"name":{"type":["string","null"]},"type":{"type":["null","string"]},"folder":{"type":["object","null"],"properties":{"type":{"type":["null","string"]},"value":{"type":["null","integer"]},"folderName":{"type":["null","string"]}}},"status":{"type":["null","string"]},"channel":{"type":["null","string"]},"createdAt":{"type":["string","null"],"format":"date-time"},"updatedAt":{"type":["string","null"],"format":"date-time"},"workspace":{"type":["null","string"]},"description":{"type":["null","string"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[updatedAt],sourceDefinedPrimaryKey=[[id]],namespace=MARKETO,additionalProperties={}],syncMode=full_refresh,cursorField=[updatedAt],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-05-07 01:10:36 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-05-07 01:10:36 INFO i.a.c.p.ConfigRepository(updateConnectionState):731 - Updating connection 954e7537-5ebe-4677-81f8-23a7fb299e5f state: io.airbyte.config.State@24ddd123[state={}] 2022-05-07 01:10:36 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/7696/0/logs.log 2022-05-07 01:10:36 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha 2022-05-07 01:10:36 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization. 2022-05-07 01:10:36 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.74 2022-05-07 01:10:36 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.74 exists... 2022-05-07 01:10:36 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.74 was found locally. 2022-05-07 01:10:36 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 7696 2022-05-07 01:10:36 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/7696/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha airbyte/normalization-snowflake:0.1.74 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json 2022-05-07 01:10:37 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/7696/0/normalize 2022-05-07 01:10:37 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/7696/0/normalize') 2022-05-07 01:10:37 normalization > transform_snowflake 2022-05-07 01:10:37 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/7696/0/normalize --catalog destination_catalog.json --out /data/7696/0/normalize/models/generated/ --json-column _airbyte_data 2022-05-07 01:10:37 normalization > Processing destination_catalog.json... 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_AB1.sql from activities_change_data_value 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_AB2.sql from activities_change_data_value 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE_AB3.sql from activities_change_data_value 2022-05-07 01:10:37 normalization > Generating airbyte_tables/MARKETO/ACTIVITIES_CHANGE_DATA_VALUE.sql from activities_change_data_value 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_AB1.sql from activity_types 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_AB2.sql from activity_types 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_AB3.sql from activity_types 2022-05-07 01:10:37 normalization > Generating airbyte_tables/MARKETO/ACTIVITY_TYPES.sql from activity_types 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/CAMPAIGNS_AB1.sql from campaigns 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/CAMPAIGNS_AB2.sql from campaigns 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/CAMPAIGNS_AB3.sql from campaigns 2022-05-07 01:10:37 normalization > Generating airbyte_tables/MARKETO/CAMPAIGNS.sql from campaigns 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/LEADS_AB1.sql from leads 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/LEADS_AB2.sql from leads 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/LEADS_AB3.sql from leads 2022-05-07 01:10:37 normalization > Generating airbyte_tables/MARKETO/LEADS.sql from leads 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/PROGRAMS_AB1.sql from programs 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/PROGRAMS_AB2.sql from programs 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/PROGRAMS_AB3.sql from programs 2022-05-07 01:10:37 normalization > Generating airbyte_tables/MARKETO/PROGRAMS.sql from programs 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_ATTRIBUTES_AB1.sql from activity_types/attributes 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_ATTRIBUTES_AB2.sql from activity_types/attributes 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_ATTRIBUTES_AB3.sql from activity_types/attributes 2022-05-07 01:10:37 normalization > Generating airbyte_tables/MARKETO/ACTIVITY_TYPES_ATTRIBUTES.sql from activity_types/attributes 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE_AB1.sql from activity_types/primaryAttribute 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE_AB2.sql from activity_types/primaryAttribute 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE_AB3.sql from activity_types/primaryAttribute 2022-05-07 01:10:37 normalization > Generating airbyte_tables/MARKETO/ACTIVITY_TYPES_PRIMARYATTRIBUTE.sql from activity_types/primaryAttribute 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/PROGRAMS_FOLDER_AB1.sql from programs/folder 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/PROGRAMS_FOLDER_AB2.sql from programs/folder 2022-05-07 01:10:37 normalization > Generating airbyte_ctes/MARKETO/PROGRAMS_FOLDER_AB3.sql from programs/folder 2022-05-07 01:10:37 normalization > Generating airbyte_tables/MARKETO/PROGRAMS_FOLDER.sql from programs/folder 2022-05-07 01:10:37 normalization > detected no config file for ssh, assuming ssh is off. 2022-05-07 01:10:40 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-05-07 01:10:40 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-05-07 01:10:40 normalization > 2022-05-07 01:10:40 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-05-07 01:10:40 normalization > 2022-05-07 01:10:43 normalization > 01:10:43 Running with dbt=1.0.0 2022-05-07 01:10:43 normalization > 01:10:43 Partial parse save file not found. Starting full parse. 2022-05-07 01:10:44 normalization > 01:10:44 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-05-07 01:10:44 normalization > There are 2 unused configuration paths: 2022-05-07 01:10:44 normalization > - models.airbyte_utils.generated.airbyte_views 2022-05-07 01:10:44 normalization > - models.airbyte_utils.generated.airbyte_incremental 2022-05-07 01:10:44 normalization > 2022-05-07 01:10:44 normalization > 01:10:44 Found 32 models, 0 tests, 0 snapshots, 0 analyses, 528 macros, 0 operations, 0 seed files, 5 sources, 0 exposures, 0 metrics 2022-05-07 01:10:44 normalization > 01:10:44 2022-05-07 01:10:46 normalization > 01:10:46 Concurrency: 5 threads (target='prod') 2022-05-07 01:10:46 normalization > 01:10:46 2022-05-07 01:10:47 normalization > 01:10:47 1 of 8 START table model MARKETO.ACTIVITIES_CHANGE_DATA_VALUE........................................................... [RUN] 2022-05-07 01:10:47 normalization > 01:10:47 2 of 8 START table model MARKETO.CAMPAIGNS.............................................................................. [RUN] 2022-05-07 01:10:47 normalization > 01:10:47 3 of 8 START table model MARKETO.ACTIVITY_TYPES......................................................................... [RUN] 2022-05-07 01:10:47 normalization > 01:10:47 4 of 8 START table model MARKETO.PROGRAMS............................................................................... [RUN] 2022-05-07 01:10:48 normalization > 01:10:48 5 of 8 START table model MARKETO.LEADS.................................................................................. [RUN] 2022-05-07 01:10:50 normalization > 01:10:50 4 of 8 OK created table model MARKETO.PROGRAMS.......................................................................... [SUCCESS 1 in 3.48s] 2022-05-07 01:10:50 normalization > 01:10:50 6 of 8 START table model MARKETO.PROGRAMS_FOLDER........................................................................ [RUN] 2022-05-07 01:10:50 normalization > 01:10:50 2 of 8 OK created table model MARKETO.CAMPAIGNS......................................................................... [SUCCESS 1 in 3.68s] 2022-05-07 01:10:51 normalization > 01:10:51 1 of 8 OK created table model MARKETO.ACTIVITIES_CHANGE_DATA_VALUE...................................................... [SUCCESS 1 in 4.15s] 2022-05-07 01:10:51 normalization > 01:10:51 3 of 8 OK created table model MARKETO.ACTIVITY_TYPES.................................................................... [SUCCESS 1 in 4.04s] 2022-05-07 01:10:51 normalization > 01:10:51 7 of 8 START table model MARKETO.ACTIVITY_TYPES_PRIMARYATTRIBUTE........................................................ [RUN] 2022-05-07 01:10:51 normalization > 01:10:51 8 of 8 START table model MARKETO.ACTIVITY_TYPES_ATTRIBUTES.............................................................. [RUN] 2022-05-07 01:10:51 normalization > 01:10:51 5 of 8 OK created table model MARKETO.LEADS............................................................................. [SUCCESS 1 in 3.57s] 2022-05-07 01:10:51 normalization > 01:10:51 6 of 8 OK created table model MARKETO.PROGRAMS_FOLDER................................................................... [SUCCESS 1 in 1.10s] 2022-05-07 01:10:52 normalization > 01:10:52 8 of 8 OK created table model MARKETO.ACTIVITY_TYPES_ATTRIBUTES......................................................... [SUCCESS 1 in 1.47s] 2022-05-07 01:10:52 normalization > 01:10:52 7 of 8 OK created table model MARKETO.ACTIVITY_TYPES_PRIMARYATTRIBUTE................................................... [SUCCESS 1 in 1.53s] 2022-05-07 01:10:52 normalization > 01:10:52 2022-05-07 01:10:52 normalization > 01:10:52 Finished running 8 table models in 8.17s. 2022-05-07 01:10:53 normalization > 01:10:53 2022-05-07 01:10:53 normalization > 01:10:53 Completed successfully 2022-05-07 01:10:53 normalization > 01:10:53 2022-05-07 01:10:53 normalization > 01:10:53 Done. PASS=8 WARN=0 ERROR=0 SKIP=0 TOTAL=8 2022-05-07 01:10:53 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 16 seconds. 2022-05-07 01:10:53 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-05-07 01:10:53 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...