2022-04-04 07:44:41 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: dev
2022-04-04 07:44:41 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/16/0/logs.log
2022-04-04 07:44:41 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: dev
2022-04-04 07:44:41 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 16 attempt id: 0
2022-04-04 07:44:41 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {metapolis.GuestModel=full_refresh - overwrite, metapolis.ClientVersion=full_refresh - overwrite, metapolis.InvitationModel=full_refresh - overwrite, metapolis.PlayerModel=full_refresh - overwrite, metapolis.BuildingModel=full_refresh - overwrite, metapolis.ClientVersionModel=full_refresh - overwrite, metapolis.ServerSettingModel=full_refresh - overwrite, metapolis.OfficeModel=full_refresh - overwrite}
2022-04-04 07:44:41 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-04 07:44:41 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-s3:0.2.13 exists...
2022-04-04 07:44:41 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-s3:0.2.13 was found locally.
2022-04-04 07:44:41 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 16
2022-04-04 07:44:41 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/16/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-s3:0.2.13 -e WORKER_JOB_ATTEMPT=0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=dev -e WORKER_JOB_ID=16 airbyte/destination-s3:0.2.13 write --config destination_config.json --catalog destination_catalog.json
2022-04-04 07:44:41 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mongodb-v2:dev exists...
2022-04-04 07:44:42 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mongodb-v2:dev was found locally.
2022-04-04 07:44:42 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 16
2022-04-04 07:44:42 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/16/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:dev -e WORKER_JOB_ATTEMPT=0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=dev -e WORKER_JOB_ID=16 airbyte/source-mongodb-v2:dev read --config source_config.json --catalog source_catalog.json
2022-04-04 07:44:42 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-04 07:44:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-04 07:44:42 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-04 07:44:42 destination > WARNING: The requested image's platform (linux/amd64) does not match the detected host platform (linux/arm64/v8) and no specific platform was requested
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.s.m.MongoDbSource(main):65 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, config=source_config.json}
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: READ
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='null'}
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='BuildingModel', namespace='metapolis'}, New Cursor Field: null. Resetting cursor value
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='PlayerModel', namespace='metapolis'}, New Cursor Field: null. Resetting cursor value
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='ClientVersion', namespace='metapolis'}, New Cursor Field: null. Resetting cursor value
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='ClientVersionModel', namespace='metapolis'}, New Cursor Field: null. Resetting cursor value
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='ServerSettingModel', namespace='metapolis'}, New Cursor Field: null. Resetting cursor value
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='OfficeModel', namespace='metapolis'}, New Cursor Field: null. Resetting cursor value
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='InvitationModel', namespace='metapolis'}, New Cursor Field: null. Resetting cursor value
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='GuestModel', namespace='metapolis'}, New Cursor Field: null. Resetting cursor value
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017], mode=MULTIPLE, requiredClusterType=REPLICA_SET, serverSelectionTimeout='30000 ms', requiredReplicaSetName='rs0'}
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017 to client view of cluster
2022-04-04 07:44:42 source > 2022-04-04 07:44:42 INFO c.m.d.l.SLF4JLogger(info):71 - No server chosen by com.mongodb.client.internal.MongoClientDelegate$1@1b70203f from cluster description ClusterDescription{type=REPLICA_SET, connectionMode=MULTIPLE, serverDescriptions=[ServerDescription{address=metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out
2022-04-04 07:44:43 source > 2022-04-04 07:44:43 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1}] to metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017
2022-04-04 07:44:43 source > 2022-04-04 07:44:43 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2}] to metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017
2022-04-04 07:44:43 source > 2022-04-04 07:44:43 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=7, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=313611042, setName='rs0', canonicalAddress=metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017, hosts=[metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017], passives=[], arbiters=[], primary='metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000005, setVersion=null, topologyVersion=null, lastWriteDate=Mon Apr 04 07:44:43 UTC 2022, lastUpdateTimeNanos=713218097074}
2022-04-04 07:44:43 source > 2022-04-04 07:44:43 INFO c.m.d.l.SLF4JLogger(info):71 - Discovered replica set primary metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017
2022-04-04 07:44:44 source > 2022-04-04 07:44:44 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3}] to metapolis-prod.c3svvjp5iqfn.ap-northeast-1.docdb.amazonaws.com:27017
2022-04-04 07:44:44 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-04 07:44:44 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-04 07:44:44 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-04 07:44:44 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-04 07:44:44 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-04 07:44:48 destination > 2022-04-04 07:44:48 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-04 07:44:48 destination > 2022-04-04 07:44:48 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.s3.S3Destination
2022-04-04 07:44:48 destination > 2022-04-04 07:44:48 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-04-04 07:44:48 destination > 2022-04-04 07:44:48 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-04 07:44:49 destination > 2022-04-04 07:44:49 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-04 07:44:49 destination > 2022-04-04 07:44:49 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-04 07:44:49 destination > 2022-04-04 07:44:49 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-04 07:44:49 destination > 2022-04-04 07:44:49 INFO i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - S3 format config: {"format_type":"Parquet","page_size_kb":2048,"block_size_mb":256,"compression_codec":"SNAPPY","dictionary_encoding":true,"max_padding_size_mb":20,"dictionary_page_size_kb":4000}
2022-04-04 07:44:49 destination > 2022-04-04 07:44:49 INFO i.a.i.d.s.S3DestinationConfig(createS3Client):169 - Creating S3 client...
2022-04-04 07:44:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (170 KB)
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.SerializedBufferFactory(getCreateFunction):50 - S3 format config: {"format_type":"Parquet","page_size_kb":2048,"block_size_mb":256,"compression_codec":"SNAPPY","dictionary_encoding":true,"max_padding_size_mb":20,"dictionary_page_size_kb":4000}
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - S3 format config: {"format_type":"Parquet","page_size_kb":2048,"block_size_mb":256,"compression_codec":"SNAPPY","dictionary_encoding":true,"max_padding_size_mb":20,"dictionary_page_size_kb":4000}
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):91 - Write config: WriteConfig{streamName=BuildingModel, namespace=metapolis, outputBucketPath=testdb/airbyte_test/metapolis/BuildingModel/, syncMode=overwrite}
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):91 - Write config: WriteConfig{streamName=ClientVersion, namespace=metapolis, outputBucketPath=testdb/airbyte_test/metapolis/ClientVersion/, syncMode=overwrite}
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):91 - Write config: WriteConfig{streamName=ClientVersionModel, namespace=metapolis, outputBucketPath=testdb/airbyte_test/metapolis/ClientVersionModel/, syncMode=overwrite}
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):91 - Write config: WriteConfig{streamName=GuestModel, namespace=metapolis, outputBucketPath=testdb/airbyte_test/metapolis/GuestModel/, syncMode=overwrite}
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):91 - Write config: WriteConfig{streamName=InvitationModel, namespace=metapolis, outputBucketPath=testdb/airbyte_test/metapolis/InvitationModel/, syncMode=overwrite}
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):91 - Write config: WriteConfig{streamName=OfficeModel, namespace=metapolis, outputBucketPath=testdb/airbyte_test/metapolis/OfficeModel/, syncMode=overwrite}
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):91 - Write config: WriteConfig{streamName=PlayerModel, namespace=metapolis, outputBucketPath=testdb/airbyte_test/metapolis/PlayerModel/, syncMode=overwrite}
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3ConsumerFactory(lambda$toWriteConfig$0):91 - Write config: WriteConfig{streamName=ServerSettingModel, namespace=metapolis, outputBucketPath=testdb/airbyte_test/metapolis/ServerSettingModel/, syncMode=overwrite}
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):98 - Preparing bucket in destination started for 8 streams
2022-04-04 07:44:53 destination > 2022-04-04 07:44:53 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):104 - Clearing storage area in destination started for namespace metapolis stream BuildingModel bucketObject testdb/airbyte_test/metapolis/BuildingModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):108 - Clearing storage area in destination completed for namespace metapolis stream BuildingModel bucketObject testdb/airbyte_test/metapolis/BuildingModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):104 - Clearing storage area in destination started for namespace metapolis stream ClientVersion bucketObject testdb/airbyte_test/metapolis/ClientVersion/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):108 - Clearing storage area in destination completed for namespace metapolis stream ClientVersion bucketObject testdb/airbyte_test/metapolis/ClientVersion/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):104 - Clearing storage area in destination started for namespace metapolis stream ClientVersionModel bucketObject testdb/airbyte_test/metapolis/ClientVersionModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):108 - Clearing storage area in destination completed for namespace metapolis stream ClientVersionModel bucketObject testdb/airbyte_test/metapolis/ClientVersionModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):104 - Clearing storage area in destination started for namespace metapolis stream GuestModel bucketObject testdb/airbyte_test/metapolis/GuestModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):108 - Clearing storage area in destination completed for namespace metapolis stream GuestModel bucketObject testdb/airbyte_test/metapolis/GuestModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):104 - Clearing storage area in destination started for namespace metapolis stream InvitationModel bucketObject testdb/airbyte_test/metapolis/InvitationModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):108 - Clearing storage area in destination completed for namespace metapolis stream InvitationModel bucketObject testdb/airbyte_test/metapolis/InvitationModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):104 - Clearing storage area in destination started for namespace metapolis stream OfficeModel bucketObject testdb/airbyte_test/metapolis/OfficeModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):108 - Clearing storage area in destination completed for namespace metapolis stream OfficeModel bucketObject testdb/airbyte_test/metapolis/OfficeModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):104 - Clearing storage area in destination started for namespace metapolis stream PlayerModel bucketObject testdb/airbyte_test/metapolis/PlayerModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):108 - Clearing storage area in destination completed for namespace metapolis stream PlayerModel bucketObject testdb/airbyte_test/metapolis/PlayerModel/
2022-04-04 07:44:56 destination > 2022-04-04 07:44:56 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):104 - Clearing storage area in destination started for namespace metapolis stream ServerSettingModel bucketObject testdb/airbyte_test/metapolis/ServerSettingModel/
2022-04-04 07:44:57 destination > 2022-04-04 07:44:57 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):108 - Clearing storage area in destination completed for namespace metapolis stream ServerSettingModel bucketObject testdb/airbyte_test/metapolis/ServerSettingModel/
2022-04-04 07:44:57 destination > 2022-04-04 07:44:57 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onStartFunction$2):112 - Preparing storage area in destination completed.
2022-04-04 07:44:57 destination > 2022-04-04 07:44:57 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream BuildingModel (current state: 0 bytes in 0 buffers)
2022-04-04 07:44:57 destination > 2022-04-04 07:44:57 WARN i.a.i.d.s.a.JsonToAvroSchemaConverter(parseSingleType):240 - Array field "floors" does not specify the items type. It will default to an array of strings
2022-04-04 07:44:58 destination > 2022-04-04 07:44:58 WARN o.a.h.u.NativeCodeLoader(<clinit>):60 - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2022-04-04 07:44:59 destination > 2022-04-04 07:44:59 ERROR i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):62 - Failed to create a new buffer for stream BuildingModel
2022-04-04 07:44:59 destination > java.io.IOException: Cannot run program "chmod": error=0, Failed to exec spawn helper: pid: 79, exit value: 1
2022-04-04 07:44:59 destination > 	at java.lang.ProcessBuilder.start(ProcessBuilder.java:1143) ~[?:?]
2022-04-04 07:44:59 destination > 	at java.lang.ProcessBuilder.start(ProcessBuilder.java:1073) ~[?:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.runCommand(Shell.java:938) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.run(Shell.java:901) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell$ShellCommandExecutor.execute(Shell.java:1213) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.execCommand(Shell.java:1307) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.execCommand(Shell.java:1289) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.setPermission(RawLocalFileSystem.java:867) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileOutputStream.<init>(RawLocalFileSystem.java:254) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileOutputStream.<init>(RawLocalFileSystem.java:234) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.createOutputStreamWithMode(RawLocalFileSystem.java:333) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:322) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:353) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem$ChecksumFSOutputSummer.<init>(ChecksumFileSystem.java:416) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:479) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:458) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1164) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1144) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.util.HadoopOutputFile.create(HadoopOutputFile.java:74) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.ParquetFileWriter.<init>(ParquetFileWriter.java:329) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.ParquetWriter.<init>(ParquetWriter.java:292) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.ParquetWriter$Builder.build(ParquetWriter.java:641) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.<init>(ParquetSerializedBuffer.java:83) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.lambda$createFunction$2(ParquetSerializedBuffer.java:161) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.lambda$addRecord$0(SerializedBufferingStrategy.java:60) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at java.util.HashMap.computeIfAbsent(HashMap.java:1220) ~[?:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.addRecord(SerializedBufferingStrategy.java:54) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:137) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:50) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:182) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:191) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:220) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) [io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163) [io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) [io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.s3.S3Destination.main(S3Destination.java:51) [io.airbyte.airbyte-integrations.connectors-destination-s3-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > Caused by: java.io.IOException: error=0, Failed to exec spawn helper: pid: 79, exit value: 1
2022-04-04 07:44:59 destination > 	at java.lang.ProcessImpl.forkAndExec(Native Method) ~[?:?]
2022-04-04 07:44:59 destination > 	at java.lang.ProcessImpl.<init>(ProcessImpl.java:314) ~[?:?]
2022-04-04 07:44:59 destination > 	at java.lang.ProcessImpl.start(ProcessImpl.java:244) ~[?:?]
2022-04-04 07:44:59 destination > 	at java.lang.ProcessBuilder.start(ProcessBuilder.java:1110) ~[?:?]
2022-04-04 07:44:59 destination > 	... 38 more
2022-04-04 07:44:59 destination > 2022-04-04 07:44:59 ERROR i.a.i.b.FailureTrackingAirbyteMessageConsumer(accept):52 - Exception while accepting message
2022-04-04 07:44:59 destination > java.lang.RuntimeException: java.io.IOException: Cannot run program "chmod": error=0, Failed to exec spawn helper: pid: 79, exit value: 1
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.lambda$addRecord$0(SerializedBufferingStrategy.java:63) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at java.util.HashMap.computeIfAbsent(HashMap.java:1220) ~[?:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.addRecord(SerializedBufferingStrategy.java:54) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:137) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:50) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:182) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:191) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:220) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38) [io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163) [io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) [io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.s3.S3Destination.main(S3Destination.java:51) [io.airbyte.airbyte-integrations.connectors-destination-s3-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > Caused by: java.io.IOException: Cannot run program "chmod": error=0, Failed to exec spawn helper: pid: 79, exit value: 1
2022-04-04 07:44:59 destination > 	at java.lang.ProcessBuilder.start(ProcessBuilder.java:1143) ~[?:?]
2022-04-04 07:44:59 destination > 	at java.lang.ProcessBuilder.start(ProcessBuilder.java:1073) ~[?:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.runCommand(Shell.java:938) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.run(Shell.java:901) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell$ShellCommandExecutor.execute(Shell.java:1213) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.execCommand(Shell.java:1307) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.execCommand(Shell.java:1289) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.setPermission(RawLocalFileSystem.java:867) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileOutputStream.<init>(RawLocalFileSystem.java:254) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileOutputStream.<init>(RawLocalFileSystem.java:234) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.createOutputStreamWithMode(RawLocalFileSystem.java:333) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:322) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:353) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem$ChecksumFSOutputSummer.<init>(ChecksumFileSystem.java:416) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:479) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:458) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1164) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1144) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.util.HadoopOutputFile.create(HadoopOutputFile.java:74) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.ParquetFileWriter.<init>(ParquetFileWriter.java:329) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.ParquetWriter.<init>(ParquetWriter.java:292) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.ParquetWriter$Builder.build(ParquetWriter.java:641) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.<init>(ParquetSerializedBuffer.java:83) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.lambda$createFunction$2(ParquetSerializedBuffer.java:161) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.lambda$addRecord$0(SerializedBufferingStrategy.java:60) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	... 14 more
2022-04-04 07:44:59 destination > Caused by: java.io.IOException: error=0, Failed to exec spawn helper: pid: 79, exit value: 1
2022-04-04 07:44:59 destination > 	at java.lang.ProcessImpl.forkAndExec(Native Method) ~[?:?]
2022-04-04 07:44:59 destination > 	at java.lang.ProcessImpl.<init>(ProcessImpl.java:314) ~[?:?]
2022-04-04 07:44:59 destination > 	at java.lang.ProcessImpl.start(ProcessImpl.java:244) ~[?:?]
2022-04-04 07:44:59 destination > 	at java.lang.ProcessBuilder.start(ProcessBuilder.java:1110) ~[?:?]
2022-04-04 07:44:59 destination > 	at java.lang.ProcessBuilder.start(ProcessBuilder.java:1073) ~[?:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.runCommand(Shell.java:938) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.run(Shell.java:901) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell$ShellCommandExecutor.execute(Shell.java:1213) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.execCommand(Shell.java:1307) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.util.Shell.execCommand(Shell.java:1289) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.setPermission(RawLocalFileSystem.java:867) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileOutputStream.<init>(RawLocalFileSystem.java:254) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileOutputStream.<init>(RawLocalFileSystem.java:234) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.createOutputStreamWithMode(RawLocalFileSystem.java:333) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:322) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:353) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem$ChecksumFSOutputSummer.<init>(ChecksumFileSystem.java:416) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:479) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:458) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1164) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1144) ~[hadoop-common-3.3.0.jar:?]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.util.HadoopOutputFile.create(HadoopOutputFile.java:74) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.ParquetFileWriter.<init>(ParquetFileWriter.java:329) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.ParquetWriter.<init>(ParquetWriter.java:292) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at org.apache.parquet.hadoop.ParquetWriter$Builder.build(ParquetWriter.java:641) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.<init>(ParquetSerializedBuffer.java:83) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.lambda$createFunction$2(ParquetSerializedBuffer.java:161) ~[io.airbyte.airbyte-integrations.connectors-destination-s3-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.lambda$addRecord$0(SerializedBufferingStrategy.java:60) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.61-alpha.jar:?]
2022-04-04 07:44:59 destination > 	... 14 more
2022-04-04 07:44:59 destination > 2022-04-04 07:44:59 WARN i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):63 - Airbyte message consumer: failed.
2022-04-04 07:44:59 destination > 2022-04-04 07:44:59 ERROR i.a.i.d.b.BufferedStreamConsumer(close):168 - executing on failed close procedure.
2022-04-04 07:44:59 destination > 2022-04-04 07:44:59 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onCloseFunction$4):154 - Cleaning up destination started for 8 streams
2022-04-04 07:45:00 destination > 2022-04-04 07:45:00 INFO i.a.i.d.s.S3ConsumerFactory(lambda$onCloseFunction$4):159 - Cleaning up destination completed.
2022-04-04 07:45:00 destination > Exception in thread "main" java.lang.RuntimeException: java.io.IOException: Cannot run program "chmod": error=0, Failed to exec spawn helper: pid: 79, exit value: 1
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.lambda$addRecord$0(SerializedBufferingStrategy.java:63)
2022-04-04 07:45:00 destination > 	at java.base/java.util.HashMap.computeIfAbsent(HashMap.java:1220)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.addRecord(SerializedBufferingStrategy.java:54)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:137)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:50)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:182)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:191)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:220)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:190)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runInternal$1(IntegrationRunner.java:163)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:38)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:163)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.destination.s3.S3Destination.main(S3Destination.java:51)
2022-04-04 07:45:00 destination > Caused by: java.io.IOException: Cannot run program "chmod": error=0, Failed to exec spawn helper: pid: 79, exit value: 1
2022-04-04 07:45:00 destination > 	at java.base/java.lang.ProcessBuilder.start(ProcessBuilder.java:1143)
2022-04-04 07:45:00 destination > 	at java.base/java.lang.ProcessBuilder.start(ProcessBuilder.java:1073)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.util.Shell.runCommand(Shell.java:938)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.util.Shell.run(Shell.java:901)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.util.Shell$ShellCommandExecutor.execute(Shell.java:1213)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.util.Shell.execCommand(Shell.java:1307)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.util.Shell.execCommand(Shell.java:1289)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.setPermission(RawLocalFileSystem.java:867)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileOutputStream.<init>(RawLocalFileSystem.java:254)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileOutputStream.<init>(RawLocalFileSystem.java:234)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.createOutputStreamWithMode(RawLocalFileSystem.java:333)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:322)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.RawLocalFileSystem.create(RawLocalFileSystem.java:353)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem$ChecksumFSOutputSummer.<init>(ChecksumFileSystem.java:416)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:479)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:458)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1164)
2022-04-04 07:45:00 destination > 	at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1144)
2022-04-04 07:45:00 destination > 	at org.apache.parquet.hadoop.util.HadoopOutputFile.create(HadoopOutputFile.java:74)
2022-04-04 07:45:00 destination > 	at org.apache.parquet.hadoop.ParquetFileWriter.<init>(ParquetFileWriter.java:329)
2022-04-04 07:45:00 destination > 	at org.apache.parquet.hadoop.ParquetWriter.<init>(ParquetWriter.java:292)
2022-04-04 07:45:00 destination > 	at org.apache.parquet.hadoop.ParquetWriter$Builder.build(ParquetWriter.java:641)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.<init>(ParquetSerializedBuffer.java:83)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.destination.s3.parquet.ParquetSerializedBuffer.lambda$createFunction$2(ParquetSerializedBuffer.java:161)
2022-04-04 07:45:00 destination > 	at io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy.lambda$addRecord$0(SerializedBufferingStrategy.java:60)
2022-04-04 07:45:00 destination > 	... 14 more
2022-04-04 07:45:00 destination > Caused by: java.io.IOException: error=0, Failed to exec spawn helper: pid: 79, exit value: 1
2022-04-04 07:45:00 destination > 	at java.base/java.lang.ProcessImpl.forkAndExec(Native Method)
2022-04-04 07:45:00 destination > 	at java.base/java.lang.ProcessImpl.<init>(ProcessImpl.java:314)
2022-04-04 07:45:00 destination > 	at java.base/java.lang.ProcessImpl.start(ProcessImpl.java:244)
2022-04-04 07:45:00 destination > 	at java.base/java.lang.ProcessBuilder.start(ProcessBuilder.java:1110)
2022-04-04 07:45:00 destination > 	... 38 more
2022-04-04 07:46:01 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job.
2022-04-04 07:46:01 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: java.io.IOException: Stream closed
		at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?]
		at java.io.OutputStream.write(OutputStream.java:162) ~[?:?]
		at java.io.BufferedOutputStream.write(BufferedOutputStream.java:123) ~[?:?]
		at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?]
		at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304) ~[?:?]
		at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282) ~[?:?]
		at sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132) ~[?:?]
		at java.io.OutputStreamWriter.write(OutputStreamWriter.java:205) ~[?:?]
		at java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120) ~[?:?]
		at java.io.BufferedWriter.flush(BufferedWriter.java:256) ~[?:?]
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.notifyEndOfStream(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) ~[io.airbyte-airbyte-workers-0.35.62-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
2022-04-04 07:46:01 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@496be21d[status=failed,recordsSynced=1636,bytesSynced=619136,startTime=1649058281928,endTime=1649058361318,totalStats=io.airbyte.config.SyncStats@4fe1fb4a[recordsEmitted=1636,bytesEmitted=619136,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@7815844e[streamName=OfficeModel,stats=io.airbyte.config.SyncStats@2c906f71[recordsEmitted=105,bytesEmitted=55041,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@3a7d0bf4[streamName=PlayerModel,stats=io.airbyte.config.SyncStats@7a869c5a[recordsEmitted=600,bytesEmitted=413541,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@2e6540b0[streamName=GuestModel,stats=io.airbyte.config.SyncStats@1a149ea[recordsEmitted=873,bytesEmitted=135083,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@5351c081[streamName=ClientVersionModel,stats=io.airbyte.config.SyncStats@1dfbf2fd[recordsEmitted=50,bytesEmitted=11496,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@199f5132[streamName=BuildingModel,stats=io.airbyte.config.SyncStats@127aa5f2[recordsEmitted=5,bytesEmitted=3251,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@4f723af4[streamName=ClientVersion,stats=io.airbyte.config.SyncStats@ddc45fd[recordsEmitted=1,bytesEmitted=326,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@6e2983b5[streamName=InvitationModel,stats=io.airbyte.config.SyncStats@29bbeeb7[recordsEmitted=2,bytesEmitted=398,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-04-04 07:46:01 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-04-04 07:46:01 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained.
2022-04-04 07:46:01 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-04 07:46:01 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@61034dc2[standardSyncSummary=io.airbyte.config.StandardSyncSummary@6de94c92[status=failed,recordsSynced=1636,bytesSynced=619136,startTime=1649058281928,endTime=1649058361318,totalStats=io.airbyte.config.SyncStats@4fe1fb4a[recordsEmitted=1636,bytesEmitted=619136,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@7815844e[streamName=OfficeModel,stats=io.airbyte.config.SyncStats@2c906f71[recordsEmitted=105,bytesEmitted=55041,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@3a7d0bf4[streamName=PlayerModel,stats=io.airbyte.config.SyncStats@7a869c5a[recordsEmitted=600,bytesEmitted=413541,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@2e6540b0[streamName=GuestModel,stats=io.airbyte.config.SyncStats@1a149ea[recordsEmitted=873,bytesEmitted=135083,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@5351c081[streamName=ClientVersionModel,stats=io.airbyte.config.SyncStats@1dfbf2fd[recordsEmitted=50,bytesEmitted=11496,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@199f5132[streamName=BuildingModel,stats=io.airbyte.config.SyncStats@127aa5f2[recordsEmitted=5,bytesEmitted=3251,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@4f723af4[streamName=ClientVersion,stats=io.airbyte.config.SyncStats@ddc45fd[recordsEmitted=1,bytesEmitted=326,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@6e2983b5[streamName=InvitationModel,stats=io.airbyte.config.SyncStats@29bbeeb7[recordsEmitted=2,bytesEmitted=398,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@62818615[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@1edbf324[stream=io.airbyte.protocol.models.AirbyteStream@654dd060[name=BuildingModel,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"key":{"type":"string"},"seq":{"type":"number"},"name":{"type":"string"},"floors":{"type":"array"},"defaultAreaSize":{"type":"number"},"_id_aibyte_transform":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=metapolis,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@42e78d87[stream=io.airbyte.protocol.models.AirbyteStream@2cb81ae0[name=ClientVersion,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"ios":{"type":"string"},"key":{"type":"string"},"osx":{"type":"string"},"win":{"type":"string"},"android":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=metapolis,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@6dbb9e80[stream=io.airbyte.protocol.models.AirbyteStream@667e9d87[name=ClientVersionModel,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"ios":{"type":"string"},"key":{"type":"string"},"osx":{"type":"string"},"win":{"type":"string"},"memo":{"type":"string"},"size":{"type":"number"},"android":{"type":"string"},"version":{"type":"string"},"disabled":{"type":"boolean"},"fileName":{"type":"string"},"platform":{"type":"string"},"createdAt":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=metapolis,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@188bbf7a[stream=io.airbyte.protocol.models.AirbyteStream@7488d991[name=GuestModel,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"key":{"type":"string"},"seq":{"type":"number"},"email":{"type":"string"},"_id_aibyte_transform":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=metapolis,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@45f6161e[stream=io.airbyte.protocol.models.AirbyteStream@57763982[name=InvitationModel,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"key":{"type":"string"},"seq":{"type":"number"},"email":{"type":"string"},"status":{"type":"number"},"createdAt":{"type":"number"},"expiredAt":{"type":"number"},"updatedAt":{"type":"number"},"retryCount":{"type":"number"},"hostPlayerId":{"type":"number"},"invitationKey":{"type":"string"},"invitationPhrase":{"type":"string"},"statusDescription":{"type":"string"},"_id_aibyte_transform":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=metapolis,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@12c33c79[stream=io.airbyte.protocol.models.AirbyteStream@20352be1[name=OfficeModel,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"key":{"type":"string"},"seq":{"type":"number"},"name":{"type":"string"},"ciUrl":{"type":"string"},"color":{"type":"string"},"floor":{"type":"number"},"events":{"type":"array"},"areaSize":{"type":"number"},"password":{"type":"string"},"sceneName":{"type":"string"},"buildingId":{"type":"number"},"allowedEmails":{"type":"array"},"organizationId":{"type":"number"},"_id_aibyte_transform":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=metapolis,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@55069f1f[stream=io.airbyte.protocol.models.AirbyteStream@33da1614[name=PlayerModel,jsonSchema={"type":"object","properties":{"key":{"type":"string"},"seq":{"type":"number"},"name":{"type":"string"},"email":{"type":"string"},"phone":{"type":"string"},"roles":{"type":"array"},"enabled":{"type":"boolean"},"isGuest":{"type":"boolean"},"password":{"type":"string"},"createdAt":{"type":"number"},"updatedAt":{"type":"number"},"isLoggedIn":{"type":"boolean"},"accessToken":{"type":"string"},"description":{"type":"string"},"characterKey":{"type":"number"},"joinedOffice":{"type":"array"},"allowNewGroup":{"type":"boolean"},"emailVerified":{"type":"boolean"},"passwordVersion":{"type":"number"},"passwordResetToken":{"type":"string"},"id_aibyte_transform":{"type":"string"},"_id_aibyte_transform":{"type":"string"},"emailVerificationToken":{"type":"string"},"latestOfficeId_aibyte_transform":{"type":"string"},"latestLeaveOfficeTime_aibyte_transform":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=metapolis,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@38f1d4e2[stream=io.airbyte.protocol.models.AirbyteStream@31928a3e[name=ServerSettingModel,jsonSchema={"type":"object","properties":{"_id":{"type":"string"},"key":{"type":"string"},"cameraSettings":{"type":"array"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=metapolis,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@508d0574[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@3384d3c7[additionalProperties={attemptNumber=0, jobId=16}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:296)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
Caused by: java.io.IOException: Broken pipe
	at java.base/java.io.FileOutputStream.writeBytes(Native Method)
	at java.base/java.io.FileOutputStream.write(FileOutputStream.java:349)
	at java.base/java.io.BufferedOutputStream.write(BufferedOutputStream.java:123)
	at java.base/sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234)
	at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304)
	at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282)
	at java.base/sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132)
	at java.base/java.io.OutputStreamWriter.write(OutputStreamWriter.java:205)
	at java.base/java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120)
	at java.base/java.io.BufferedWriter.write(BufferedWriter.java:233)
	at java.base/java.io.Writer.write(Writer.java:249)
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.accept(DefaultAirbyteDestination.java:90)
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:294)
	... 4 more
,retryable=<null>,timestamp=1649058301243], io.airbyte.config.FailureReason@5e44791[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@2002fe69[additionalProperties={attemptNumber=0, jobId=16}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1649058301242]]]
2022-04-04 07:46:01 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-04 07:46:01 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.instance: does not have a value in the enumeration [standalone]
2022-04-04 07:46:01 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.server_addresses: is missing but it is required, $.instance: does not have a value in the enumeration [replica]
2022-04-04 07:46:01 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.cluster_url: is missing but it is required, $.tls: is not defined in the schema and the schema does not allow additional properties, $.host: is not defined in the schema and the schema does not allow additional properties, $.port: is not defined in the schema and the schema does not allow additional properties, $.instance: does not have a value in the enumeration [atlas]
2022-04-04 07:46:01 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.format_type: does not have a value in the enumeration [Avro], $.compression_codec: string found, object expected, $.compression_codec: should be valid to one and only one of the schemas 
2022-04-04 07:46:01 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.flattening: is missing but it is required, $.format_type: does not have a value in the enumeration [CSV]
2022-04-04 07:46:01 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.format_type: does not have a value in the enumeration [JSONL]