airbyte-worker | 2022-07-19 10:53:34 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 9a18b250-4e1e-42a0-8c84-3b9e2b1e8d9d airbyte-worker | 2022-07-19 10:53:34 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/9a18b250-4e1e-42a0-8c84-3b9e2b1e8d9d/0 --log-driver none --name source-mongodb-v2-discover-9a18b250-4e1e-42a0-8c84-3b9e2b1e8d9d-0-opasj --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mongodb-v2:0.1.15 -e AIRBYTE_VERSION=0.39.37-alpha -e WORKER_JOB_ID=9a18b250-4e1e-42a0-8c84-3b9e2b1e8d9d airbyte/source-mongodb-v2:0.1.15 discover --config source_config.json airbyte-worker | 2022-07-19 10:53:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:35 INFO i.a.i.s.m.MongoDbSource(main):63 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource airbyte-worker | 2022-07-19 10:53:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:35 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {discover=null, config=source_config.json} airbyte-worker | 2022-07-19 10:53:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:35 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource airbyte-worker | 2022-07-19 10:53:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:35 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: DISCOVER airbyte-worker | 2022-07-19 10:53:35 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:35 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=DISCOVER, configPath='source_config.json', catalogPath='null', statePath='null'} airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53: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 airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53: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 airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53: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 airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[127.0.0.1:27017], srvHost=private-bitcrm-mongodb-f15fde32.mongo.ondigitalocean.com, mode=MULTIPLE, requiredClusterType=REPLICA_SET, serverSelectionTimeout='30000 ms', requiredReplicaSetName='bitcrm-mongodb'} airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server private-bitcrm-mongodb-9774a00e.mongo.ondigitalocean.com:27017 to client view of cluster airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - No server chosen by com.mongodb.client.internal.MongoClientDelegate$1@eadb475 from cluster description ClusterDescription{type=REPLICA_SET, connectionMode=MULTIPLE, serverDescriptions=[ServerDescription{address=private-bitcrm-mongodb-9774a00e.mongo.ondigitalocean.com:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:604398}] to private-bitcrm-mongodb-9774a00e.mongo.ondigitalocean.com:27017 airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:604399}] to private-bitcrm-mongodb-9774a00e.mongo.ondigitalocean.com:27017 airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=private-bitcrm-mongodb-9774a00e.mongo.ondigitalocean.com:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=248164146, setName='bitcrm-mongodb', canonicalAddress=bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017, hosts=[bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017], passives=[], arbiters=[], primary='bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000002, setVersion=11, topologyVersion=TopologyVersion{processId=62d08679c654b1eb33c5f1d7, counter=12}, lastWriteDate=Tue Jul 19 10:53:36 UTC 2022, lastUpdateTimeNanos=19136516451992023} airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017 to client view of cluster airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Server private-bitcrm-mongodb-9774a00e.mongo.ondigitalocean.com:27017 is no longer a member of the replica set. Removing from client view of cluster. airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Setting max election id to 7fffffff0000000000000002 from replica set primary private-bitcrm-mongodb-9774a00e.mongo.ondigitalocean.com:27017 airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Setting max set version to 11 from replica set primary private-bitcrm-mongodb-9774a00e.mongo.ondigitalocean.com:27017 airbyte-worker | 2022-07-19 10:53:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:36 INFO c.m.d.l.SLF4JLogger(info):71 - Discovered replica set primary private-bitcrm-mongodb-9774a00e.mongo.ondigitalocean.com:27017 airbyte-worker | 2022-07-19 10:53:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:37 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:604400}] to bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017 airbyte-worker | 2022-07-19 10:53:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:37 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=50728231, setName='bitcrm-mongodb', canonicalAddress=bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017, hosts=[bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017], passives=[], arbiters=[], primary='bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000002, setVersion=11, topologyVersion=TopologyVersion{processId=62d08679c654b1eb33c5f1d7, counter=12}, lastWriteDate=Tue Jul 19 10:53:36 UTC 2022, lastUpdateTimeNanos=19136516537701613} airbyte-worker | 2022-07-19 10:53:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:37 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:4, serverValue:604401}] to bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017 airbyte-worker | 2022-07-19 10:53:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:37 INFO c.m.d.l.SLF4JLogger(info):71 - Discovered replica set primary bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017 airbyte-worker | 2022-07-19 10:53:37 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:37 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:5, serverValue:604402}] to bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017 airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-19 10:53:45 ERROR i.a.i.b.AirbyteExceptionHandler(uncaughtException):26 - Something went wrong in the connector. See the logs for more details. airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - com.mongodb.MongoCommandException: Command failed with error 16872 (Location16872): 'Invalid $project :: caused by :: '$' by itself is not a valid FieldPath' on server bitcrm-mongodb-e379f160.mongo.ondigitalocean.com:27017. The full response is {"ok": 0.0, "errmsg": "Invalid $project :: caused by :: '$' by itself is not a valid FieldPath", "code": 16872, "codeName": "Location16872", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1658228019, "i": 1}}, "signature": {"hash": {"$binary": {"base64": "gdcXysIC3D7CXRM9jzPfiNo3RmM=", "subType": "00"}}, "keyId": 7114990681650626562}}, "operationTime": {"$timestamp": {"t": 1658228019, "i": 1}}} airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:198) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:418) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:342) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:116) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:647) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:244) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:227) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:127) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:117) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.connection.DefaultServer$OperationCountTrackingConnection.command(DefaultServer.java:348) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.CommandOperationHelper.createReadCommandAndExecute(CommandOperationHelper.java:228) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.CommandOperationHelper.lambda$executeRetryableRead$4(CommandOperationHelper.java:210) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.OperationHelper.lambda$withSourceAndConnection$2(OperationHelper.java:564) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.OperationHelper.withSuppliedResource(OperationHelper.java:589) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.OperationHelper.lambda$withSourceAndConnection$3(OperationHelper.java:563) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.OperationHelper.withSuppliedResource(OperationHelper.java:589) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.OperationHelper.withSourceAndConnection(OperationHelper.java:562) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.CommandOperationHelper.lambda$executeRetryableRead$5(CommandOperationHelper.java:207) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.async.function.RetryingSyncSupplier.get(RetryingSyncSupplier.java:65) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.CommandOperationHelper.executeRetryableRead(CommandOperationHelper.java:213) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.CommandOperationHelper.executeRetryableRead(CommandOperationHelper.java:193) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.AggregateOperationImpl.execute(AggregateOperationImpl.java:195) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.AggregateOperation.execute(AggregateOperation.java:306) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.internal.operation.AggregateOperation.execute(AggregateOperation.java:46) ~[mongodb-driver-core-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:191) ~[mongodb-driver-sync-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.client.internal.MongoIterableImpl.execute(MongoIterableImpl.java:135) ~[mongodb-driver-sync-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.client.internal.MongoIterableImpl.iterator(MongoIterableImpl.java:92) ~[mongodb-driver-sync-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at com.mongodb.client.internal.MongoIterableImpl.cursor(MongoIterableImpl.java:97) ~[mongodb-driver-sync-4.4.0.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.db.mongodb.MongoUtils.getTypes(MongoUtils.java:265) ~[io.airbyte.airbyte-db-db-lib-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.db.mongodb.MongoUtils.lambda$getUniqueFields$0(MongoUtils.java:206) ~[io.airbyte.airbyte-db-db-lib-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1707) ~[?:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575) ~[?:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) ~[?:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616) ~[?:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622) ~[?:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627) ~[?:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.db.mongodb.MongoUtils.getUniqueFields(MongoUtils.java:213) ~[io.airbyte.airbyte-db-db-lib-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.source.mongodb.MongoDbSource.discoverInternal(MongoDbSource.java:118) ~[io.airbyte.airbyte-integrations.connectors-source-mongodb-v2-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.source.mongodb.MongoDbSource.discoverInternal(MongoDbSource.java:40) ~[io.airbyte.airbyte-integrations.connectors-source-mongodb-v2-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.source.relationaldb.AbstractDbSource.discoverWithoutSystemTables(AbstractDbSource.java:138) ~[io.airbyte.airbyte-integrations.connectors-source-relational-db-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.source.relationaldb.AbstractDbSource.getTables(AbstractDbSource.java:328) ~[io.airbyte.airbyte-integrations.connectors-source-relational-db-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.source.relationaldb.AbstractDbSource.discover(AbstractDbSource.java:87) ~[io.airbyte.airbyte-integrations.connectors-source-relational-db-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:107) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.source.mongodb.MongoDbSource.main(MongoDbSource.java:64) ~[io.airbyte.airbyte-integrations.connectors-source-mongodb-v2-0.39.20-alpha.jar:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):161 - Completing future exceptionally... airbyte-worker | io.airbyte.workers.exception.WorkerException: Discover job subprocess finished with exit code 1 airbyte-worker | at io.airbyte.workers.general.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:83) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at io.airbyte.workers.general.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:26) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at java.lang.Thread.run(Thread.java:833) [?:?] airbyte-worker | 2022-07-19 10:53:45 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... airbyte-worker | 2022-07-19 10:53:45 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=2b28c966-61e5-3059-b00c-777470a9df40, activityType=Run, attempt=1 airbyte-worker | java.util.concurrent.ExecutionException: io.airbyte.workers.exception.WorkerException: Discover job subprocess finished with exit code 1 airbyte-worker | at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] airbyte-worker | at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] airbyte-worker | at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:132) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at io.airbyte.workers.temporal.discover.catalog.DiscoverCatalogActivityImpl.run(DiscoverCatalogActivityImpl.java:83) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] airbyte-worker | at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?] airbyte-worker | at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?] airbyte-worker | at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?] airbyte-worker | at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] airbyte-worker | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] airbyte-worker | at java.lang.Thread.run(Thread.java:833) [?:?] airbyte-worker | Caused by: io.airbyte.workers.exception.WorkerException: Discover job subprocess finished with exit code 1 airbyte-worker | at io.airbyte.workers.general.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:83) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at io.airbyte.workers.general.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:26) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | ... 1 more airbyte-worker | 2022-07-19 10:53:45 ERROR i.t.i.s.WorkflowExecuteRunnable(logWorkflowExecutionException):125 - Workflow execution failure WorkflowId=445b86fe-a845-4b04-90c6-ff3391a5b804, RunId=fbda45bb-7632-46db-8ce3-3b9b39a13160, WorkflowType=DiscoverCatalogWorkflow airbyte-worker | io.temporal.failure.ActivityFailure: scheduledEventId=5, startedEventId=6, activityType='Run', activityId='2b28c966-61e5-3059-b00c-777470a9df40', identity='1@4c0c68bb18d0', retryState=RETRY_STATE_MAXIMUM_ATTEMPTS_REACHED airbyte-worker | at java.lang.Thread.getStackTrace(Thread.java:1610) ~[?:?] airbyte-worker | at io.temporal.internal.sync.ActivityStubBase.execute(ActivityStubBase.java:48) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.sync.ActivityInvocationHandler.lambda$getActivityFunc$0(ActivityInvocationHandler.java:77) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.sync.ActivityInvocationHandlerBase.invoke(ActivityInvocationHandlerBase.java:70) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at jdk.proxy2.$Proxy32.run(Unknown Source) ~[?:?] airbyte-worker | at io.airbyte.workers.temporal.discover.catalog.DiscoverCatalogWorkflowImpl.run(DiscoverCatalogWorkflowImpl.java:28) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] airbyte-worker | at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?] airbyte-worker | at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?] airbyte-worker | at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?] airbyte-worker | at io.temporal.internal.sync.POJOWorkflowImplementationFactory$POJOWorkflowImplementation$RootWorkflowInboundCallsInterceptor.execute(POJOWorkflowImplementationFactory.java:317) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.sync.POJOWorkflowImplementationFactory$POJOWorkflowImplementation.execute(POJOWorkflowImplementationFactory.java:292) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.sync.WorkflowExecuteRunnable.run(WorkflowExecuteRunnable.java:72) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.sync.SyncWorkflow.lambda$start$0(SyncWorkflow.java:137) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.sync.CancellationScopeImpl.run(CancellationScopeImpl.java:101) [temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.sync.WorkflowThreadImpl$RunnableWrapper.run(WorkflowThreadImpl.java:111) [temporal-sdk-1.8.1.jar:?] airbyte-worker | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] airbyte-worker | at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] airbyte-worker | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] airbyte-worker | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] airbyte-worker | at java.lang.Thread.run(Thread.java:833) [?:?] airbyte-worker | Caused by: io.temporal.failure.ApplicationFailure: message='io.airbyte.workers.exception.WorkerException: Discover job subprocess finished with exit code 1', type='java.util.concurrent.ExecutionException', nonRetryable=false airbyte-worker | at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] airbyte-worker | at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] airbyte-worker | at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:132) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at io.airbyte.workers.temporal.discover.catalog.DiscoverCatalogActivityImpl.run(DiscoverCatalogActivityImpl.java:83) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method:0) ~[?:?] airbyte-worker | at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?] airbyte-worker | at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?] airbyte-worker | at java.base/java.lang.reflect.Method.invoke(Method.java:568) ~[?:?] airbyte-worker | at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?] airbyte-worker | at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] airbyte-worker | at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] airbyte-worker | at java.base/java.lang.Thread.run(Thread.java:833) ~[?:?] airbyte-worker | Caused by: io.temporal.failure.ApplicationFailure: message='Discover job subprocess finished with exit code 1', type='io.airbyte.workers.exception.WorkerException', nonRetryable=false airbyte-worker | at io.airbyte.workers.general.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:83) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at io.airbyte.workers.general.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:26) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.37-alpha.jar:?] airbyte-worker | at java.base/java.lang.Thread.run(Thread.java:833) ~[?:?]