2022-08-10 02:50: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 2022-08-10 02:50:15 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/0/logs.log 2022-08-10 02:50:15 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-08-10 02:50:15 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.18 exists... 2022-08-10 02:50:15 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.18 was found locally. 2022-08-10 02:50:15 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:50:15 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/0 --log-driver none --name source-mixpanel-check-82-0-qyzaq --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.18 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/source-mixpanel:0.1.18 check --config source_config.json 2022-08-10 02:50:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):99 - Check succeeded 2022-08-10 02:50:18 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-08-10 02:50:18 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/0/logs.log 2022-08-10 02:50:18 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-08-10 02:50:18 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.21 exists... 2022-08-10 02:50:18 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.21 was found locally. 2022-08-10 02:50:18 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:50:18 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/0 --log-driver none --name destination-postgres-check-82-0-afzfa --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.21 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/destination-postgres:0.3.21 check --config source_config.json 2022-08-10 02:50:20 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-08-10 02:50:20 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:50:20 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:50:20 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:50:20 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:50:20 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-08-10 02:50:20 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 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-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 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-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 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-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 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-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-08-10 02:50:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:21 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-08-10 02:50:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:22 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-08-10 02:50:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:22 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-08-10 02:50:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:22 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-08-10 02:50:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:22 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-08-10 02:50:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:50:22 INFO i.a.i.d.p.PostgresDestination(main):92 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-08-10 02:50:22 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-08-10 02:50:22 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/0/logs.log 2022-08-10 02:50:22 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-08-10 02:50:22 INFO i.a.w.g.DefaultReplicationWorker(run):116 - start sync worker. job id: 82 attempt id: 0 2022-08-10 02:50:22 INFO i.a.w.g.DefaultReplicationWorker(run):128 - configured sync modes: {null.export=incremental - append} 2022-08-10 02:50:22 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-08-10 02:50:22 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.21 exists... 2022-08-10 02:50:22 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.21 was found locally. 2022-08-10 02:50:22 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:50:22 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/0 --log-driver none --name destination-postgres-write-82-0-bupzh --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.21 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/destination-postgres:0.3.21 write --config destination_config.json --catalog destination_catalog.json 2022-08-10 02:50:22 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.18 exists... 2022-08-10 02:50:22 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.18 was found locally. 2022-08-10 02:50:22 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:50:22 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/0 --log-driver none --name source-mixpanel-read-82-0-ohygc --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.18 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/source-mixpanel:0.1.18 read --config source_config.json --catalog source_catalog.json 2022-08-10 02:50:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):406 - Destination output thread started. 2022-08-10 02:50:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):299 - Replication thread started. 2022-08-10 02:50:22 INFO i.a.w.g.DefaultReplicationWorker(run):170 - Waiting for source and destination threads to complete. 2022-08-10 02:50:23 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-08-10 02:50:23 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:50:23 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:50:23 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:50:23 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:50:23 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-08-10 02:50:23 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-08-10 02:50:23 source > Starting syncing SourceMixpanel 2022-08-10 02:50:23 source > Using start_date: 2022-08-09, end_date: 2022-08-09 2022-08-10 02:50:23 source > Syncing stream: export 2022-08-10 02:50:24 destination > 2022-08-10 02:50:24 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-08-10 02:50:24 destination > 2022-08-10 02:50:24 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-08-10 02:50:24 destination > 2022-08-10 02:50:24 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-08-10 02:50:24 destination > 2022-08-10 02:50:24 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE 2022-08-10 02:50:24 destination > 2022-08-10 02:50:24 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-08-10 02:50:24 destination > 2022-08-10 02:50: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-08-10 02:50:24 destination > 2022-08-10 02:50: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-08-10 02:50:24 destination > 2022-08-10 02:50: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-08-10 02:50:24 destination > 2022-08-10 02:50: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-08-10 02:50:25 destination > 2022-08-10 02:50:25 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-08-10 02:50:25 destination > 2022-08-10 02:50:25 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-08-10 02:50:25 destination > 2022-08-10 02:50:25 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-08-10 02:50:25 destination > 2022-08-10 02:50:25 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):97 - Write config: WriteConfig{streamName=export, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_sau_export, outputTableName=_airbyte_raw_export, syncMode=append} 2022-08-10 02:50:25 destination > 2022-08-10 02:50:25 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-08-10 02:50:25 destination > 2022-08-10 02:50:25 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):122 - Preparing tmp tables in destination started for 1 streams 2022-08-10 02:50:25 destination > 2022-08-10 02:50:25 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):126 - Preparing tmp table in destination started for stream export. schema: public, tmp table name: _airbyte_tmp_sau_export 2022-08-10 02:50:25 destination > 2022-08-10 02:50:25 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):132 - Preparing tables in destination completed. 2022-08-10 02:51:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 1000 (878 KB) 2022-08-10 02:51:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 2000 (1 MB) 2022-08-10 02:51:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 3000 (2 MB) 2022-08-10 02:51:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 4000 (3 MB) 2022-08-10 02:51:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 5000 (4 MB) 2022-08-10 02:51:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 6000 (5 MB) 2022-08-10 02:51:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 7000 (6 MB) 2022-08-10 02:51:07 destination > 2022-08-10 02:51:07 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing export: 7369 records (24 MB) 2022-08-10 02:51:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 8000 (6 MB) 2022-08-10 02:51:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 9000 (7 MB) 2022-08-10 02:51:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 10000 (8 MB) 2022-08-10 02:51:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 11000 (9 MB) 2022-08-10 02:51:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 12000 (10 MB) 2022-08-10 02:51:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 13000 (11 MB) 2022-08-10 02:51:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 14000 (12 MB) 2022-08-10 02:51:11 destination > 2022-08-10 02:51:11 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing export: 7029 records (24 MB) 2022-08-10 02:51:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 15000 (13 MB) 2022-08-10 02:51:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 16000 (13 MB) 2022-08-10 02:51:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 17000 (14 MB) 2022-08-10 02:51:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 18000 (15 MB) 2022-08-10 02:51:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 19000 (16 MB) 2022-08-10 02:51:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 20000 (17 MB) 2022-08-10 02:51:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 21000 (18 MB) 2022-08-10 02:51:16 destination > 2022-08-10 02:51:16 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing export: 7091 records (24 MB) 2022-08-10 02:51:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 22000 (19 MB) 2022-08-10 02:51:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 23000 (20 MB) 2022-08-10 02:51:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 24000 (21 MB) 2022-08-10 02:51:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 25000 (21 MB) 2022-08-10 02:51:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 26000 (22 MB) 2022-08-10 02:51:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 27000 (23 MB) 2022-08-10 02:51:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 28000 (24 MB) 2022-08-10 02:51:21 destination > 2022-08-10 02:51:21 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing export: 7069 records (24 MB) 2022-08-10 02:51:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 29000 (25 MB) 2022-08-10 02:51:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 30000 (26 MB) 2022-08-10 02:51:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 31000 (27 MB) 2022-08-10 02:51:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 32000 (28 MB) 2022-08-10 02:51:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 33000 (29 MB) 2022-08-10 02:51:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 34000 (29 MB) 2022-08-10 02:51:25 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation... 2022-08-10 02:51:25 INFO i.a.w.g.DefaultReplicationWorker(cancel):444 - Cancelling replication worker... 2022-08-10 02:51:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 35000 (30 MB) 2022-08-10 02:51:26 destination > 2022-08-10 02:51:26 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing export: 6936 records (24 MB) 2022-08-10 02:51:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 36000 (31 MB) 2022-08-10 02:51:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 37000 (32 MB) 2022-08-10 02:51:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 38000 (33 MB) 2022-08-10 02:51:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 39000 (34 MB) 2022-08-10 02:51:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 40000 (35 MB) 2022-08-10 02:51:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 41000 (36 MB) 2022-08-10 02:51:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 42000 (37 MB) 2022-08-10 02:51:35 destination > 2022-08-10 02:51:35 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing export: 7006 records (24 MB) 2022-08-10 02:51:35 INFO i.a.w.g.DefaultReplicationWorker(cancel):452 - Cancelling destination... 2022-08-10 02:51:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):336 - Total records read: 42977 (37 MB) 2022-08-10 02:51:35 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process... 2022-08-10 02:51:35 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling... 2022-08-10 02:51:35 INFO i.a.w.g.DefaultReplicationWorker(run):175 - One of source or destination thread complete. Waiting on the other. 2022-08-10 02:51:36 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Source and destination threads complete. 2022-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process! 2022-08-10 02:51:36 INFO i.a.w.g.DefaultReplicationWorker(cancel):459 - Cancelling source... 2022-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process... 2022-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling... 2022-08-10 02:51:36 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process! 2022-08-10 02:51:36 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread... 2022-08-10 02:51:36 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future... 2022-08-10 02:51:36 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-08-10 02:51:36 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-08-10 02:51:36 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating... 2022-08-10 02:51:36 ERROR i.a.w.g.DefaultReplicationWorker(run):181 - Sync worker failed. io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:179) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 143. This warning is normal if the job was cancelled. at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:138) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2022-08-10 02:51:36 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=7c764a72-fee2-3149-b9d4-1d297b8de495, activityType=Replicate, attempt=1 java.lang.RuntimeException: java.util.concurrent.CancellationException at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:289) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:115) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] Caused by: java.util.concurrent.CancellationException at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:201) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?] ... 3 more 2022-08-10 02:51:36 INFO i.a.w.g.DefaultReplicationWorker(run):240 - sync summary: io.airbyte.config.ReplicationAttemptSummary@97dd033[status=cancelled,recordsSynced=42977,bytesSynced=39841204,startTime=1660099822821,endTime=1660099896202,totalStats=io.airbyte.config.SyncStats@6210ee1b[recordsEmitted=42977,bytesEmitted=39841204,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@b27a105[streamName=export,stats=io.airbyte.config.SyncStats@612307d5[recordsEmitted=42977,bytesEmitted=39841204,stateMessagesEmitted=,recordsCommitted=]]]] 2022-08-10 02:51:36 INFO i.a.w.g.DefaultReplicationWorker(run):269 - Source did not output any state messages 2022-08-10 02:51:36 WARN i.a.w.g.DefaultReplicationWorker(run):280 - State capture: No state retained. 2022-08-10 02:51:26 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/1/logs.log 2022-08-10 02:51:26 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-08-10 02:51:26 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.18 exists... 2022-08-10 02:51:26 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.18 was found locally. 2022-08-10 02:51:26 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:51:26 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/1 --log-driver none --name source-mixpanel-check-82-1-ccgpn --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.18 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/source-mixpanel:0.1.18 check --config source_config.json 2022-08-10 02:51:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):99 - Check succeeded 2022-08-10 02:51:31 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-08-10 02:51:31 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/1/logs.log 2022-08-10 02:51:31 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-08-10 02:51:31 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.21 exists... 2022-08-10 02:51:31 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.21 was found locally. 2022-08-10 02:51:31 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:51:31 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/1 --log-driver none --name destination-postgres-check-82-1-nauql --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.21 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/destination-postgres:0.3.21 check --config source_config.json 2022-08-10 02:51:33 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-08-10 02:51:33 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:51:33 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:51:33 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:51:33 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:51:33 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-08-10 02:51:33 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-08-10 02:51:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:35 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:36 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:36 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:36 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:36 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:36 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-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:36 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-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:36 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-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:36 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-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:36 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-08-10 02:51:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:36 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-08-10 02:51:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:37 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-08-10 02:51:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:37 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-08-10 02:51:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:37 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-08-10 02:51:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:37 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-08-10 02:51:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:51:37 INFO i.a.i.d.p.PostgresDestination(main):92 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-08-10 02:51:37 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-08-10 02:51:37 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/1/logs.log 2022-08-10 02:51:37 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-08-10 02:51:37 INFO i.a.w.g.DefaultReplicationWorker(run):116 - start sync worker. job id: 82 attempt id: 1 2022-08-10 02:51:37 INFO i.a.w.g.DefaultReplicationWorker(run):128 - configured sync modes: {null.export=incremental - append} 2022-08-10 02:51:37 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-08-10 02:51:37 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.21 exists... 2022-08-10 02:51:38 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.21 was found locally. 2022-08-10 02:51:38 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:51:38 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/1 --log-driver none --name destination-postgres-write-82-1-hbtdl --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.21 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/destination-postgres:0.3.21 write --config destination_config.json --catalog destination_catalog.json 2022-08-10 02:51:38 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.18 exists... 2022-08-10 02:51:38 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.18 was found locally. 2022-08-10 02:51:38 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:51:38 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/1 --log-driver none --name source-mixpanel-read-82-1-bdady --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.18 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/source-mixpanel:0.1.18 read --config source_config.json --catalog source_catalog.json 2022-08-10 02:51:38 INFO i.a.w.g.DefaultReplicationWorker(run):170 - Waiting for source and destination threads to complete. 2022-08-10 02:51:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):406 - Destination output thread started. 2022-08-10 02:51:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):299 - Replication thread started. 2022-08-10 02:51:39 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-08-10 02:51:39 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:51:39 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:51:39 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:51:39 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:51:39 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-08-10 02:51:39 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-08-10 02:51:40 source > Starting syncing SourceMixpanel 2022-08-10 02:51:40 source > Using start_date: 2022-08-09, end_date: 2022-08-09 2022-08-10 02:51:40 source > Syncing stream: export 2022-08-10 02:51:40 destination > 2022-08-10 02:51:40 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-08-10 02:51:40 destination > 2022-08-10 02:51:40 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-08-10 02:51:40 destination > 2022-08-10 02:51:40 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-08-10 02:51:40 destination > 2022-08-10 02:51:40 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE 2022-08-10 02:51:40 destination > 2022-08-10 02:51:40 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-08-10 02:51:40 destination > 2022-08-10 02:51:40 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-08-10 02:51:40 destination > 2022-08-10 02:51:40 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-08-10 02:51:40 destination > 2022-08-10 02:51:40 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-08-10 02:51:40 destination > 2022-08-10 02:51:40 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-08-10 02:51:41 destination > 2022-08-10 02:51:41 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-08-10 02:51:41 destination > 2022-08-10 02:51:41 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-08-10 02:51:41 destination > 2022-08-10 02:51:41 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-08-10 02:51:41 destination > 2022-08-10 02:51:41 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):97 - Write config: WriteConfig{streamName=export, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_kjp_export, outputTableName=_airbyte_raw_export, syncMode=append} 2022-08-10 02:51:41 destination > 2022-08-10 02:51:41 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-08-10 02:51:41 destination > 2022-08-10 02:51:41 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):122 - Preparing tmp tables in destination started for 1 streams 2022-08-10 02:51:41 destination > 2022-08-10 02:51:41 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):126 - Preparing tmp table in destination started for stream export. schema: public, tmp table name: _airbyte_tmp_kjp_export 2022-08-10 02:51:41 destination > 2022-08-10 02:51:41 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):132 - Preparing tables in destination completed. 2022-08-10 02:52:10 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation... 2022-08-10 02:52:10 INFO i.a.w.g.DefaultReplicationWorker(cancel):444 - Cancelling replication worker... 2022-08-10 02:52:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 1000 (832 KB) 2022-08-10 02:52:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 2000 (1 MB) 2022-08-10 02:52:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 3000 (2 MB) 2022-08-10 02:52:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 4000 (3 MB) 2022-08-10 02:52:20 INFO i.a.w.g.DefaultReplicationWorker(cancel):452 - Cancelling destination... 2022-08-10 02:52:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):336 - Total records read: 4562 (3 MB) 2022-08-10 02:52:20 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process... 2022-08-10 02:52:20 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling... 2022-08-10 02:52:20 INFO i.a.w.g.DefaultReplicationWorker(run):175 - One of source or destination thread complete. Waiting on the other. 2022-08-10 02:52:20 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Source and destination threads complete. 2022-08-10 02:52:20 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-08-10 02:52:20 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process! 2022-08-10 02:52:20 INFO i.a.w.g.DefaultReplicationWorker(cancel):459 - Cancelling source... 2022-08-10 02:52:20 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process... 2022-08-10 02:52:20 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling... 2022-08-10 02:52:20 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-08-10 02:52:20 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process! 2022-08-10 02:52:20 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread... 2022-08-10 02:52:20 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future... 2022-08-10 02:52:20 ERROR i.a.w.g.DefaultReplicationWorker(run):181 - Sync worker failed. io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:179) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:138) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2022-08-10 02:52:20 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-08-10 02:52:20 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating... 2022-08-10 02:52:20 INFO i.a.w.g.DefaultReplicationWorker(run):240 - sync summary: io.airbyte.config.ReplicationAttemptSummary@fd90ea1[status=cancelled,recordsSynced=4562,bytesSynced=4158808,startTime=1660099897908,endTime=1660099940445,totalStats=io.airbyte.config.SyncStats@7d2420ee[recordsEmitted=4562,bytesEmitted=4158808,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@11a2be0f[streamName=export,stats=io.airbyte.config.SyncStats@3a88ce85[recordsEmitted=4562,bytesEmitted=4158808,stateMessagesEmitted=,recordsCommitted=]]]] 2022-08-10 02:52:20 INFO i.a.w.g.DefaultReplicationWorker(run):269 - Source did not output any state messages 2022-08-10 02:52:20 WARN i.a.w.g.DefaultReplicationWorker(run):280 - State capture: No state retained. 2022-08-10 02:52:20 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=2c54d902-e4f4-3d87-b6d9-483292f535ac, activityType=Replicate, attempt=1 java.lang.RuntimeException: java.util.concurrent.CancellationException at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:289) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:115) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?] 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:1144) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?] at java.lang.Thread.run(Thread.java:1589) [?:?] Caused by: java.util.concurrent.CancellationException at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:201) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?] ... 3 more 2022-08-10 02:52:20 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-08-10 02:52:10 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/2/logs.log 2022-08-10 02:52:10 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-08-10 02:52:10 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.18 exists... 2022-08-10 02:52:10 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.18 was found locally. 2022-08-10 02:52:10 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:52:10 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/2 --log-driver none --name source-mixpanel-check-82-2-uessb --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.18 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/source-mixpanel:0.1.18 check --config source_config.json 2022-08-10 02:52:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):99 - Check succeeded 2022-08-10 02:52:13 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-08-10 02:52:13 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/2/logs.log 2022-08-10 02:52:13 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-08-10 02:52:13 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.21 exists... 2022-08-10 02:52:13 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.21 was found locally. 2022-08-10 02:52:13 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:52:13 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/2 --log-driver none --name destination-postgres-check-82-2-lvmev --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.21 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/destination-postgres:0.3.21 check --config source_config.json 2022-08-10 02:52:15 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings. 2022-08-10 02:52:15 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:52:15 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:52:15 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:52:15 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:52:15 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-08-10 02:52:15 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-08-10 02:52:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:17 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-08-10 02:52:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:17 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-08-10 02:52:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:17 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-08-10 02:52:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:17 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-08-10 02:52:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:17 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-08-10 02:52:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:17 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-08-10 02:52:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:17 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-08-10 02:52:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:17 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-08-10 02:52:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:17 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-08-10 02:52:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:18 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-08-10 02:52:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:18 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-08-10 02:52:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:18 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-08-10 02:52:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:18 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated... 2022-08-10 02:52:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:18 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed. 2022-08-10 02:52:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:18 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-08-10 02:52:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-10 02:52:18 INFO i.a.i.d.p.PostgresDestination(main):92 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-08-10 02:52:19 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-08-10 02:52:19 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/82/2/logs.log 2022-08-10 02:52:19 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha 2022-08-10 02:52:19 INFO i.a.w.g.DefaultReplicationWorker(run):116 - start sync worker. job id: 82 attempt id: 2 2022-08-10 02:52:19 INFO i.a.w.g.DefaultReplicationWorker(run):128 - configured sync modes: {null.export=incremental - append} 2022-08-10 02:52:19 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination... 2022-08-10 02:52:19 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.21 exists... 2022-08-10 02:52:19 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.21 was found locally. 2022-08-10 02:52:19 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:52:19 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/2 --log-driver none --name destination-postgres-write-82-2-lkfws --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.21 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/destination-postgres:0.3.21 write --config destination_config.json --catalog destination_catalog.json 2022-08-10 02:52:19 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.18 exists... 2022-08-10 02:52:19 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.18 was found locally. 2022-08-10 02:52:19 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 82 2022-08-10 02:52:19 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/82/2 --log-driver none --name source-mixpanel-read-82-2-gzino --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.18 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=82 airbyte/source-mixpanel:0.1.18 read --config source_config.json --catalog source_catalog.json 2022-08-10 02:52:19 INFO i.a.w.g.DefaultReplicationWorker(run):170 - Waiting for source and destination threads to complete. 2022-08-10 02:52:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):299 - Replication thread started. 2022-08-10 02:52:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):406 - Destination output thread started. 2022-08-10 02:52:20 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-08-10 02:52:20 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:52:20 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:52:20 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:52:20 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-08-10 02:52:20 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-08-10 02:52:20 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-08-10 02:52:21 source > Starting syncing SourceMixpanel 2022-08-10 02:52:21 source > Using start_date: 2022-08-09, end_date: 2022-08-09 2022-08-10 02:52:21 source > Syncing stream: export 2022-08-10 02:52:21 destination > 2022-08-10 02:52:21 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 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-08-10 02:52:22 destination > 2022-08-10 02:52:22 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-08-10 02:52:22 destination > 2022-08-10 02:52:22 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-08-10 02:52:22 destination > 2022-08-10 02:52:22 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-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO c.z.h.HikariDataSource():80 - HikariPool-1 - Starting... 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO c.z.h.HikariDataSource():82 - HikariPool-1 - Start completed. 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):97 - Write config: WriteConfig{streamName=export, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_bvc_export, outputTableName=_airbyte_raw_export, syncMode=append} 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):122 - Preparing tmp tables in destination started for 1 streams 2022-08-10 02:52:22 destination > 2022-08-10 02:52:22 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):126 - Preparing tmp table in destination started for stream export. schema: public, tmp table name: _airbyte_tmp_bvc_export 2022-08-10 02:52:23 destination > 2022-08-10 02:52:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):132 - Preparing tables in destination completed. 2022-08-10 02:53:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 1000 (872 KB) 2022-08-10 02:53:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 2000 (1 MB) 2022-08-10 02:53:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 3000 (2 MB) 2022-08-10 02:53:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 4000 (3 MB) 2022-08-10 02:53:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 5000 (4 MB) 2022-08-10 02:53:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 6000 (5 MB) 2022-08-10 02:53:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 7000 (6 MB) 2022-08-10 02:53:11 destination > 2022-08-10 02:53:11 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing export: 7021 records (24 MB) 2022-08-10 02:53:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 8000 (7 MB) 2022-08-10 02:53:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 9000 (8 MB) 2022-08-10 02:53:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 10000 (8 MB) 2022-08-10 02:53:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 11000 (9 MB) 2022-08-10 02:53:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 12000 (10 MB) 2022-08-10 02:53:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 13000 (11 MB) 2022-08-10 02:53:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 14000 (12 MB) 2022-08-10 02:53:17 destination > 2022-08-10 02:53:17 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing export: 7017 records (24 MB) 2022-08-10 02:53:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 15000 (13 MB) 2022-08-10 02:53:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 16000 (14 MB) 2022-08-10 02:53:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 17000 (15 MB) 2022-08-10 02:53:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 18000 (16 MB) 2022-08-10 02:53:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 19000 (16 MB) 2022-08-10 02:53:22 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation... 2022-08-10 02:53:22 INFO i.a.w.g.DefaultReplicationWorker(cancel):444 - Cancelling replication worker... 2022-08-10 02:53:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 20000 (17 MB) 2022-08-10 02:53:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 21000 (18 MB) 2022-08-10 02:53:23 destination > 2022-08-10 02:53:23 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing export: 7048 records (24 MB) 2022-08-10 02:53:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 22000 (19 MB) 2022-08-10 02:53:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 23000 (20 MB) 2022-08-10 02:53:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 24000 (21 MB) 2022-08-10 02:53:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 25000 (22 MB) 2022-08-10 02:53:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 26000 (23 MB) 2022-08-10 02:53:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 27000 (24 MB) 2022-08-10 02:53:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 28000 (24 MB) 2022-08-10 02:53:29 destination > 2022-08-10 02:53:29 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing export: 6954 records (24 MB) 2022-08-10 02:53:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 29000 (25 MB) 2022-08-10 02:53:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 30000 (26 MB) 2022-08-10 02:53:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 31000 (27 MB) 2022-08-10 02:53:32 INFO i.a.w.g.DefaultReplicationWorker(cancel):452 - Cancelling destination... 2022-08-10 02:53:32 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process... 2022-08-10 02:53:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):336 - Total records read: 31481 (28 MB) 2022-08-10 02:53:32 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling... 2022-08-10 02:53:32 INFO i.a.w.g.DefaultReplicationWorker(run):175 - One of source or destination thread complete. Waiting on the other. 2022-08-10 02:53:32 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Source and destination threads complete. 2022-08-10 02:53:32 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-08-10 02:53:32 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process! 2022-08-10 02:53:32 INFO i.a.w.g.DefaultReplicationWorker(cancel):459 - Cancelling source... 2022-08-10 02:53:32 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process... 2022-08-10 02:53:32 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling... 2022-08-10 02:53:32 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job. 2022-08-10 02:53:32 ERROR i.a.w.g.DefaultReplicationWorker(run):181 - Sync worker failed. io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:179) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:138) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?] at java.lang.Thread.run(Thread.java:1589) [?:?] 2022-08-10 02:53:32 INFO i.a.w.g.DefaultReplicationWorker(run):240 - sync summary: io.airbyte.config.ReplicationAttemptSummary@1b1be726[status=cancelled,recordsSynced=31481,bytesSynced=29368589,startTime=1660099939357,endTime=1660100012356,totalStats=io.airbyte.config.SyncStats@7750786f[recordsEmitted=31481,bytesEmitted=29368589,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@6f58f367[streamName=export,stats=io.airbyte.config.SyncStats@2cf8199d[recordsEmitted=31481,bytesEmitted=29368589,stateMessagesEmitted=,recordsCommitted=]]]] 2022-08-10 02:53:32 INFO i.a.w.g.DefaultReplicationWorker(run):269 - Source did not output any state messages 2022-08-10 02:53:32 WARN i.a.w.g.DefaultReplicationWorker(run):280 - State capture: No state retained. 2022-08-10 02:53:32 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-08-10 02:53:32 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process! 2022-08-10 02:53:32 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread... 2022-08-10 02:53:32 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future... 2022-08-10 02:53:32 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled. 2022-08-10 02:53:32 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):161 - sync summary: io.airbyte.config.StandardSyncOutput@e664f5e[standardSyncSummary=io.airbyte.config.StandardSyncSummary@12f3be93[status=cancelled,recordsSynced=31481,bytesSynced=29368589,startTime=1660099939357,endTime=1660100012356,totalStats=io.airbyte.config.SyncStats@7750786f[recordsEmitted=31481,bytesEmitted=29368589,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@6f58f367[streamName=export,stats=io.airbyte.config.SyncStats@2cf8199d[recordsEmitted=31481,bytesEmitted=29368589,stateMessagesEmitted=,recordsCommitted=]]]],normalizationSummary=,state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@7d255e9b[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@5cd10579[stream=io.airbyte.protocol.models.AirbyteStream@60f1bd02[name=export,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"os":{"type":["null","string"]},"Day":{"type":["null","string"]},"esp":{"type":["null","string"]},"url":{"type":["null","string"]},"Tags":{"type":["null","string"]},"Time":{"type":["null","string"]},"Type":{"type":["null","string"]},"city":{"type":["null","string"]},"goal":{"type":["null","string"]},"role":{"type":["null","string"]},"time":{"type":["null","string"],"format":"date-time"},"wifi":{"type":["null","string"]},"Focus":{"type":["null","string"]},"Goals":{"type":["null","string"]},"Hosts":{"type":["null","string"]},"State":{"type":["null","string"]},"brand":{"type":["null","string"]},"event":{"type":["null","string"]},"model":{"type":["null","string"]},"radio":{"type":["null","string"]},"Author":{"type":["null","string"]},"Day ID":{"type":["null","string"]},"Rating":{"type":["null","string"]},"Review":{"type":["null","string"]},"Screen":{"type":["null","string"]},"app_id":{"type":["null","string"]},"device":{"type":["null","string"]},"import":{"type":["null","string"]},"is_amp":{"type":["null","string"]},"labels":{"type":["null","array"],"items":{"type":["null","string"]}},"mp_lib":{"type":["null","string"]},"region":{"type":["null","string"]},"Context":{"type":["null","string"]},"Fitness":{"type":["null","string"]},"Post By":{"type":["null","string"]},"Post ID":{"type":["null","string"]},"Purpose":{"type":["null","string"]},"Sign In":{"type":["null","string"]},"Sign Up":{"type":["null","string"]},"Sort By":{"type":["null","string"]},"Teacher":{"type":["null","string"]},"User ID":{"type":["null","string"]},"browser":{"type":["null","string"]},"carrier":{"type":["null","string"]},"dataset":{"type":["null","string"]},"has_nfc":{"type":["null","string"]},"ip_pool":{"type":["null","string"]},"link_id":{"type":["null","string"]},"user_id":{"type":["null","string"]},"Category":{"type":["null","string"]},"Duration":{"type":["null","string"]},"Interval":{"type":["null","string"]},"Liked By":{"type":["null","string"]},"Location":{"type":["null","string"]},"Scenario":{"type":["null","string"]},"Timezone":{"type":["null","string"]},"Track ID":{"type":["null","string"]},"_User Id":{"type":["null","string"]},"original":{"type":["null","string"]},"platform":{"type":["null","string"]},"referrer":{"type":["null","string"]},"utm_term":{"type":["null","string"]},"Entity ID":{"type":["null","string"]},"Item Name":{"type":["null","string"]},"Item Type":{"type":["null","string"]},"Post Text":{"type":["null","string"]},"Specialty":{"type":["null","string"]},"URL Added":{"type":["null","string"]},"User Name":{"type":["null","string"]},"User Type":{"type":["null","string"]},"button_id":{"type":["null","string"]},"canvas_id":{"type":["null","string"]},"device_id":{"type":["null","string"]},"Comment By":{"type":["null","string"]},"Event Name":{"type":["null","string"]},"Event Type":{"type":["null","string"]},"Ingredient":{"type":["null","string"]},"Item Price":{"type":["null","string"]},"Track Name":{"type":["null","string"]},"_Entity Id":{"type":["null","string"]},"_device_id":{"type":["null","string"]},"duration_s":{"type":["null","string"]},"event_name":{"type":["null","string"]},"link_alias":{"type":["null","string"]},"origin_end":{"type":["null","string"]},"os_version":{"type":["null","string"]},"partner_id":{"type":["null","string"]},"screen_dpi":{"type":["null","string"]},"searchText":{"type":["null","string"]},"utm_medium":{"type":["null","string"]},"utm_source":{"type":["null","string"]},"Action Type":{"type":["null","string"]},"Author Name":{"type":["null","string"]},"Banner Type":{"type":["null","string"]},"Ending Bell":{"type":["null","string"]},"Final Price":{"type":["null","string"]},"Image Added":{"type":["null","string"]},"Image Count":{"type":["null","string"]},"Player Type":{"type":["null","string"]},"Screen Name":{"type":["null","string"]},"Screen Type":{"type":["null","string"]},"Search Text":{"type":["null","string"]},"User Tagged":{"type":["null","string"]},"Video Added":{"type":["null","string"]},"Video Count":{"type":["null","string"]},"app_release":{"type":["null","string"]},"campaign_id":{"type":["null","string"]},"canvas_name":{"type":["null","string"]},"current_url":{"type":["null","string"]},"dispatch_id":{"type":["null","string"]},"distinct_id":{"type":["null","string"]},"event_count":{"type":["null","string"]},"from_domain":{"type":["null","string"]},"lib_version":{"type":["null","string"]},"utm_content":{"type":["null","string"]},"Account Type":{"type":["null","string"]},"Comment Text":{"type":["null","string"]},"Commented By":{"type":["null","string"]},"Content Type":{"type":["null","string"]},"Feature Used":{"type":["null","string"]},"Martial Arts":{"type":["null","string"]},"Program Name":{"type":["null","string"]},"Program Type":{"type":["null","string"]},"Result Found":{"type":["null","string"]},"Screen Title":{"type":["null","string"]},"Scroll Depth":{"type":["null","string"]},"Section Name":{"type":["null","string"]},"Share Option":{"type":["null","string"]},"Teacher Name":{"type":["null","string"]},"Track Number":{"type":["null","string"]},"machine_open":{"type":["null","string"]},"manufacturer":{"type":["null","string"]},"origin_start":{"type":["null","string"]},"resultsFound":{"type":["null","string"]},"screen_width":{"type":["null","string"]},"utm_campaign":{"type":["null","string"]},"Ambient Sound":{"type":["null","string"]},"Campaign Name":{"type":["null","string"]},"Date Selected":{"type":["null","string"]},"Interval Bell":{"type":["null","string"]},"Item Category":{"type":["null","string"]},"Item Currency":{"type":["null","string"]},"Photo Present":{"type":["null","string"]},"Results Found":{"type":["null","string"]},"Screen Number":{"type":["null","string"]},"Starting Bell":{"type":["null","string"]},"Time Selected":{"type":["null","string"]},"Time to Start":{"type":["null","string"]},"Type of video":{"type":["null","string"]},"User Category":{"type":["null","string"]},"Way of Eating":{"type":["null","string"]},"campaign_name":{"type":["null","string"]},"email_address":{"type":["null","string"]},"has_telephone":{"type":["null","string"]},"screen_height":{"type":["null","string"]},"search_engine":{"type":["null","string"]},"Banner CTA Url":{"type":["null","string"]},"Filter Applied":{"type":["null","string"]},"Filter by Type":{"type":["null","string"]},"Listing Number":{"type":["null","string"]},"Navigation URL":{"type":["null","string"]},"Payment Method":{"type":["null","string"]},"Sign In Option":{"type":["null","string"]},"Sign up Option":{"type":["null","string"]},"Tempo of music":{"type":["null","string"]},"Theme Selected":{"type":["null","string"]},"Triggered From":{"type":["null","string"]},"canvas_step_id":{"type":["null","string"]},"failure_reason":{"type":["null","string"]},"Banner CTA Text":{"type":["null","string"]},"Calendar Chosen":{"type":["null","string"]},"Meditation Type":{"type":["null","string"]},"Played Track ID":{"type":["null","string"]},"Previous Rating":{"type":["null","string"]},"Previous Review":{"type":["null","string"]},"Promo Code Name":{"type":["null","string"]},"Time From Start":{"type":["null","string"]},"Total Reminders":{"type":["null","string"]},"Yoga Breathwork":{"type":["null","string"]},"browser_version":{"type":["null","string"]},"mp_country_code":{"type":["null","string"]},"sampling_factor":{"type":["null","integer"]},"Comment Added By":{"type":["null","string"]},"Current Track ID":{"type":["null","string"]},"Deeplink Section":{"type":["null","string"]},"Item Access Type":{"type":["null","string"]},"Item Offer Price":{"type":["null","string"]},"Meditation Style":{"type":["null","string"]},"Navigation Title":{"type":["null","string"]},"Practice Pathway":{"type":["null","string"]},"Program Category":{"type":["null","string"]},"Promo Code Title":{"type":["null","string"]},"Time Spent (Sec)":{"type":["null","string"]},"Time of Reminder":{"type":["null","string"]},"_Time from Start":{"type":["null","string"]},"app_build_number":{"type":["null","string"]},"canvas_step_name":{"type":["null","string"]},"initial_referrer":{"type":["null","string"]},"referring_domain":{"type":["null","string"]},"Interval Duration":{"type":["null","string"]},"Notification Text":{"type":["null","string"]},"Positive Emotions":{"type":["null","string"]},"bluetooth_enabled":{"type":["null","string"]},"bluetooth_version":{"type":["null","string"]},"Difficult Emotions":{"type":["null","string"]},"Notification Title":{"type":["null","string"]},"Time To Start(Min)":{"type":["null","string"]},"app_version_string":{"type":["null","string"]},"Notification Action":{"type":["null","string"]},"Time To Start (Min)":{"type":["null","string"]},"canvas_variation_id":{"type":["null","string"]},"failure_description":{"type":["null","string"]},"Meditation Tradition":{"type":["null","string"]},"Name of Users Tagged":{"type":["null","string"]},"Percentage Completed":{"type":["null","string"]},"Time From Start(Min)":{"type":["null","string"]},"google_play_services":{"type":["null","string"]},"message_variation_id":{"type":["null","string"]},"Duration Played (Sec)":{"type":["null","string"]},"External Profile Type":{"type":["null","string"]},"Metered Limit Reached":{"type":["null","string"]},"Percentage Completion":{"type":["null","string"]},"Time From Start (Min)":{"type":["null","string"]},"canvas_variation_name":{"type":["null","string"]},"Collective_Joined_From":{"type":["null","string"]},"Rating Option Selected":{"type":["null","string"]},"_Percentage completion":{"type":["null","string"]},"Rating Optiona Selected":{"type":["null","string"]},"Rating Options Selected":{"type":["null","string"]},"Item Free Trial Duration":{"type":["null","string"]},"initial_referring_domain":{"type":["null","string"]},"_item Free Trial Duration":{"type":["null","string"]},"Time Elapsed From Start(Min)":{"type":["null","string"]},"Metered Paywall Limit Reached":{"type":["null","string"]},"_Time Elapsed from Start(Min)":{"type":["null","string"]},"Date of receiving notification":{"type":["null","string"]},"Previous Rating Options Selected":{"type":["null","string"]}},"additionalProperties":true},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[time],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[time],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-08-10 02:53:32 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...