airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:10 INFO i.a.i.s.m.MongoDbSource(main):64 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:10 INFO i.a.i.s.m.MongoDbSource(main):64 - starting source: class io.airbyte.integrations.source.mongodb.MongoDbSource
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:10 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {discover=null, config=source_config.json}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:10 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {discover=null, config=source_config.json}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:10 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:10 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.source.mongodb.MongoDbSource
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:10 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: DISCOVER
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:10 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: DISCOVER
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:10 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=DISCOVER, configPath='source_config.json', catalogPath='null', statePath='null'}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:10 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=DISCOVER, configPath='source_config.json', catalogPath='null', statePath='null'}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:10 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-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:10 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-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:10 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-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:10 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-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:10 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-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:10 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-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:11 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[127.0.0.1:27017], srvHost=XXX.mongodb.net, mode=MULTIPLE, requiredClusterType=REPLICA_SET, serverSelectionTimeout='30000 ms', requiredReplicaSetName='atlas-nx5rsp-shard-0'}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster created with settings {hosts=[127.0.0.1:27017], srvHost=XXX.mongodb.net, mode=MULTIPLE, requiredClusterType=REPLICA_SET, serverSelectionTimeout='30000 ms', requiredReplicaSetName='atlas-nx5rsp-shard-0'}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:11 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server XXX.mongodb.net:27017 to client view of cluster
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server XXX.mongodb.net:27017 to client view of cluster
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:11 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - Cluster description not yet available. Waiting for 30000 ms before timing out
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:11 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server XXX.mongodb.net:27017 to client view of cluster
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server XXX.mongodb.net:27017 to client view of cluster
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:11 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server XXX.mongodb.net:27017 to client view of cluster
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - Adding discovered server XXX.mongodb.net:27017 to client view of cluster
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:11 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - No server chosen by com.mongodb.client.internal.MongoClientDelegate$1@6a078481 from cluster description ClusterDescription{type=REPLICA_SET, connectionMode=MULTIPLE, serverDescriptions=[ServerDescription{address=XXX.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}, ServerDescription{address=XXX.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}, ServerDescription{address=XXX.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:11 INFO c.m.d.l.SLF4JLogger(info):71 - No server chosen by com.mongodb.client.internal.MongoClientDelegate$1@6a078481 from cluster description ClusterDescription{type=REPLICA_SET, connectionMode=MULTIPLE, serverDescriptions=[ServerDescription{address=XXX.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}, ServerDescription{address=XXX.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}, ServerDescription{address=XXX.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:834105}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:2, serverValue:834105}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:5, serverValue:834104}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:5, serverValue:834104}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:4, serverValue:812177}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:4, serverValue:812177}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:6, serverValue:812176}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:6, serverValue:812176}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:815475}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:3, serverValue:815475}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:815474}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:1, serverValue:815474}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=XXX.mongodb.net:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=593673792, setName='atlas-nx5rsp-shard-0', canonicalAddress=XXX.mongodb.net:27017, hosts=[XXX.mongodb.net:27017, XXX.mongodb.net:27017, XXX.mongodb.net:27017], passives=[], arbiters=[], primary='XXX.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AWS'}, Tag{name='region', value='EU_WEST_1'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=null, setVersion=8, topologyVersion=TopologyVersion{processId=62b08d18ce95cd0dc09b6c82, counter=10}, lastWriteDate=Wed Jul 13 15:31:03 UTC 2022, lastUpdateTimeNanos=961669819337745}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=XXX.mongodb.net:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=593673792, setName='atlas-nx5rsp-shard-0', canonicalAddress=XXX.mongodb.net:27017, hosts=[XXX.mongodb.net:27017, XXX.mongodb.net:27017, XXX.mongodb.net:27017], passives=[], arbiters=[], primary='XXX.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AWS'}, Tag{name='region', value='EU_WEST_1'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=null, setVersion=8, topologyVersion=TopologyVersion{processId=62b08d18ce95cd0dc09b6c82, counter=10}, lastWriteDate=Wed Jul 13 15:31:03 UTC 2022, lastUpdateTimeNanos=961669819337745}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=XXX.mongodb.net:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=595318443, setName='atlas-nx5rsp-shard-0', canonicalAddress=XXX.mongodb.net:27017, hosts=[XXX.mongodb.net:27017, XXX.mongodb.net:27017, XXX.mongodb.net:27017], passives=[], arbiters=[], primary='XXX.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AWS'}, Tag{name='region', value='EU_WEST_1'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=7fffffff0000000000000003, setVersion=8, topologyVersion=TopologyVersion{processId=62b08f16daa08bbd4486840c, counter=12}, lastWriteDate=Wed Jul 13 15:31:03 UTC 2022, lastUpdateTimeNanos=961669822732247}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=XXX.mongodb.net:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=595318443, setName='atlas-nx5rsp-shard-0', canonicalAddress=XXX.mongodb.net:27017, hosts=[XXX.mongodb.net:27017, XXX.mongodb.net:27017, XXX.mongodb.net:27017], passives=[], arbiters=[], primary='XXX.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AWS'}, Tag{name='region', value='EU_WEST_1'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=7fffffff0000000000000003, setVersion=8, topologyVersion=TopologyVersion{processId=62b08f16daa08bbd4486840c, counter=12}, lastWriteDate=Wed Jul 13 15:31:03 UTC 2022, lastUpdateTimeNanos=961669822732247}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=XXX.mongodb.net:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=598620771, setName='atlas-nx5rsp-shard-0', canonicalAddress=XXX.mongodb.net:27017, hosts=[XXX.mongodb.net:27017, XXX.mongodb.net:27017, XXX.mongodb.net:27017], passives=[], arbiters=[], primary='XXX.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AWS'}, Tag{name='region', value='EU_WEST_1'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=null, setVersion=8, topologyVersion=TopologyVersion{processId=62b090f74cdc3f9ba7227c01, counter=9}, lastWriteDate=Wed Jul 13 15:31:03 UTC 2022, lastUpdateTimeNanos=961669824165088}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Monitor thread successfully connected to server with description ServerDescription{address=XXX.mongodb.net:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=598620771, setName='atlas-nx5rsp-shard-0', canonicalAddress=XXX.mongodb.net:27017, hosts=[XXX.mongodb.net:27017, XXX.mongodb.net:27017, XXX.mongodb.net:27017], passives=[], arbiters=[], primary='XXX.mongodb.net:27017', tagSet=TagSet{[Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AWS'}, Tag{name='region', value='EU_WEST_1'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=null, setVersion=8, topologyVersion=TopologyVersion{processId=62b090f74cdc3f9ba7227c01, counter=9}, lastWriteDate=Wed Jul 13 15:31:03 UTC 2022, lastUpdateTimeNanos=961669824165088}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Setting max election id to 7fffffff0000000000000003 from replica set primary XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Setting max election id to 7fffffff0000000000000003 from replica set primary XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Setting max set version to 8 from replica set primary XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Setting max set version to 8 from replica set primary XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Discovered replica set primary XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Discovered replica set primary XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:12 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:7, serverValue:834106}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 2022-07-13 15:31:12 INFO c.m.d.l.SLF4JLogger(info):71 - Opened connection [connectionId{localValue:7, serverValue:834106}] to XXX.mongodb.net:27017
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - Exception in thread "main" com.mongodb.MongoCommandException: Command failed with error 17276 (Location17276): 'Invalid $project :: caused by :: Use of undefined variable: inc' on server XXX.mongodb.net:27017. The full response is {"ok": 0.0, "errmsg": "Invalid $project :: caused by :: Use of undefined variable: inc", "code": 17276, "codeName": "Location17276", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1657726276, "i": 1}}, "signature": {"hash": {"$binary": {"base64": "kWzWEHRJ9ni3N52th/qcaNgC3fs=", "subType": "00"}}, "keyId": 7111252385065861124}}, "operationTime": {"$timestamp": {"t": 1657726276, "i": 1}}}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: Exception in thread "main" com.mongodb.MongoCommandException: Command failed with error 17276 (Location17276): 'Invalid $project :: caused by :: Use of undefined variable: inc' on server XXX.mongodb.net:27017. The full response is {"ok": 0.0, "errmsg": "Invalid $project :: caused by :: Use of undefined variable: inc", "code": 17276, "codeName": "Location17276", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1657726276, "i": 1}}, "signature": {"hash": {"$binary": {"base64": "kWzWEHRJ9ni3N52th/qcaNgC3fs=", "subType": "00"}}, "keyId": 7111252385065861124}}, "operationTime": {"$timestamp": {"t": 1657726276, "i": 1}}}
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:198)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:198)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:418)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:418)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:342)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:342)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:116)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:116)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:647)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:647)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:244)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:244)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:227)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:227)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:127)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:127)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:117)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:117)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.connection.DefaultServer$OperationCountTrackingConnection.command(DefaultServer.java:348)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.connection.DefaultServer$OperationCountTrackingConnection.command(DefaultServer.java:348)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.CommandOperationHelper.createReadCommandAndExecute(CommandOperationHelper.java:228)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.CommandOperationHelper.createReadCommandAndExecute(CommandOperationHelper.java:228)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.CommandOperationHelper.lambda$executeRetryableRead$4(CommandOperationHelper.java:210)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.CommandOperationHelper.lambda$executeRetryableRead$4(CommandOperationHelper.java:210)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.OperationHelper.lambda$withSourceAndConnection$2(OperationHelper.java:564)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.OperationHelper.lambda$withSourceAndConnection$2(OperationHelper.java:564)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.OperationHelper.withSuppliedResource(OperationHelper.java:589)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.OperationHelper.withSuppliedResource(OperationHelper.java:589)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.OperationHelper.lambda$withSourceAndConnection$3(OperationHelper.java:563)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.OperationHelper.lambda$withSourceAndConnection$3(OperationHelper.java:563)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.OperationHelper.withSuppliedResource(OperationHelper.java:589)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.OperationHelper.withSuppliedResource(OperationHelper.java:589)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.OperationHelper.withSourceAndConnection(OperationHelper.java:562)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.OperationHelper.withSourceAndConnection(OperationHelper.java:562)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.CommandOperationHelper.lambda$executeRetryableRead$5(CommandOperationHelper.java:207)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.CommandOperationHelper.lambda$executeRetryableRead$5(CommandOperationHelper.java:207)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.async.function.RetryingSyncSupplier.get(RetryingSyncSupplier.java:65)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.async.function.RetryingSyncSupplier.get(RetryingSyncSupplier.java:65)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.CommandOperationHelper.executeRetryableRead(CommandOperationHelper.java:213)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.CommandOperationHelper.executeRetryableRead(CommandOperationHelper.java:213)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.CommandOperationHelper.executeRetryableRead(CommandOperationHelper.java:193)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.CommandOperationHelper.executeRetryableRead(CommandOperationHelper.java:193)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.AggregateOperationImpl.execute(AggregateOperationImpl.java:195)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.AggregateOperationImpl.execute(AggregateOperationImpl.java:195)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.AggregateOperation.execute(AggregateOperation.java:306)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.AggregateOperation.execute(AggregateOperation.java:306)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.internal.operation.AggregateOperation.execute(AggregateOperation.java:46)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.internal.operation.AggregateOperation.execute(AggregateOperation.java:46)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:191)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:191)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.client.internal.MongoIterableImpl.execute(MongoIterableImpl.java:135)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.client.internal.MongoIterableImpl.execute(MongoIterableImpl.java:135)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.client.internal.MongoIterableImpl.iterator(MongoIterableImpl.java:92)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.client.internal.MongoIterableImpl.iterator(MongoIterableImpl.java:92)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at com.mongodb.client.internal.MongoIterableImpl.cursor(MongoIterableImpl.java:97)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at com.mongodb.client.internal.MongoIterableImpl.cursor(MongoIterableImpl.java:97)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.db.mongodb.MongoUtils.getTypes(MongoUtils.java:265)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.db.mongodb.MongoUtils.getTypes(MongoUtils.java:265)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.db.mongodb.MongoUtils.lambda$getUniqueFields$0(MongoUtils.java:206)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.db.mongodb.MongoUtils.lambda$getUniqueFields$0(MongoUtils.java:206)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1707)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1707)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at java.base/java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at java.base/java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.db.mongodb.MongoUtils.getUniqueFields(MongoUtils.java:213)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.db.mongodb.MongoUtils.getUniqueFields(MongoUtils.java:213)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.source.mongodb.MongoDbSource.discoverInternal(MongoDbSource.java:119)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.integrations.source.mongodb.MongoDbSource.discoverInternal(MongoDbSource.java:119)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.source.mongodb.MongoDbSource.discoverInternal(MongoDbSource.java:41)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.integrations.source.mongodb.MongoDbSource.discoverInternal(MongoDbSource.java:41)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.source.relationaldb.AbstractDbSource.discoverWithoutSystemTables(AbstractDbSource.java:132)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.integrations.source.relationaldb.AbstractDbSource.discoverWithoutSystemTables(AbstractDbSource.java:132)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.source.relationaldb.AbstractDbSource.getTables(AbstractDbSource.java:322)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.integrations.source.relationaldb.AbstractDbSource.getTables(AbstractDbSource.java:322)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.source.relationaldb.AbstractDbSource.discover(AbstractDbSource.java:83)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.integrations.source.relationaldb.AbstractDbSource.discover(AbstractDbSource.java:83)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:144)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:144)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - 	at io.airbyte.integrations.source.mongodb.MongoDbSource.main(MongoDbSource.java:65)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: 	at io.airbyte.integrations.source.mongodb.MongoDbSource.main(MongoDbSource.java:65)
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:19 INFO i.a.w.p.ExitCodeWatcher(persistExitCode):113 - Received exit code 1 for pod ongodb-v2-discover-0932f516-95cd-497d-ba40-6a0e7746062b-0-fwpdp
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:19 INFO i.a.w.p.KubePodProcess(close):713 - (pod: airbyte / ongodb-v2-discover-0932f516-95cd-497d-ba40-6a0e7746062b-0-fwpdp) - Closed all resources for pod
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: (pod: airbyte / ongodb-v2-discover-0932f516-95cd-497d-ba40-6a0e7746062b-0-fwpdp) - Closed all resources for pod
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:19 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):161 - Completing future exceptionally...
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container io.airbyte.workers.WorkerException: Discover job subprocess finished with exit code 1
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:74) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:24) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.lang.Thread.run(Thread.java:833) [?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: Completing future exceptionally...
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:19 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: Stopping cancellation check scheduling...
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:19 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=8060492a-34a2-3801-b813-8a02edc15c68, activityType=Run, attempt=1
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Discover job subprocess finished with exit code 1
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:132) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.temporal.discover.catalog.DiscoverCatalogActivityImpl.run(DiscoverCatalogActivityImpl.java:84) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.lang.Thread.run(Thread.java:833) [?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Caused by: io.airbyte.workers.WorkerException: Discover job subprocess finished with exit code 1
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:74) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:24) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	... 1 more
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Log4j2Appender says: Activity failure. ActivityId=8060492a-34a2-3801-b813-8a02edc15c68, activityType=Run, attempt=1
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 2022-07-13 15:31:19 ERROR i.t.i.s.WorkflowExecuteRunnable(logWorkflowExecutionException):125 - Workflow execution failure WorkflowId=7c7042f0-9a55-490d-9bce-a42482178af8, RunId=bbfaee28-cb7c-4a1f-8e1b-68313b88518f, WorkflowType=DiscoverCatalogWorkflow
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container io.temporal.failure.ActivityFailure: scheduledEventId=5, startedEventId=6, activityType='Run', activityId='8060492a-34a2-3801-b813-8a02edc15c68', identity='1@airbyte-worker-69ff9f45f5-9w54z', retryState=RETRY_STATE_MAXIMUM_ATTEMPTS_REACHED
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.lang.Thread.getStackTrace(Thread.java:1610) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.sync.ActivityStubBase.execute(ActivityStubBase.java:48) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.sync.ActivityInvocationHandler.lambda$getActivityFunc$0(ActivityInvocationHandler.java:77) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.sync.ActivityInvocationHandlerBase.invoke(ActivityInvocationHandlerBase.java:70) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at jdk.proxy2.$Proxy62.run(Unknown Source) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.temporal.discover.catalog.DiscoverCatalogWorkflowImpl.run(DiscoverCatalogWorkflowImpl.java:28) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.sync.POJOWorkflowImplementationFactory$POJOWorkflowImplementation$RootWorkflowInboundCallsInterceptor.execute(POJOWorkflowImplementationFactory.java:317) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.sync.POJOWorkflowImplementationFactory$POJOWorkflowImplementation.execute(POJOWorkflowImplementationFactory.java:292) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.sync.WorkflowExecuteRunnable.run(WorkflowExecuteRunnable.java:72) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.sync.SyncWorkflow.lambda$start$0(SyncWorkflow.java:137) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.sync.CancellationScopeImpl.run(CancellationScopeImpl.java:101) [temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.sync.WorkflowThreadImpl$RunnableWrapper.run(WorkflowThreadImpl.java:111) [temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.lang.Thread.run(Thread.java:833) [?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Caused by: io.temporal.failure.ApplicationFailure: message='io.airbyte.workers.WorkerException: Discover job subprocess finished with exit code 1', type='java.util.concurrent.ExecutionException', nonRetryable=false
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:132) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.temporal.discover.catalog.DiscoverCatalogActivityImpl.run(DiscoverCatalogActivityImpl.java:84) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method:0) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.base/java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.base/java.lang.Thread.run(Thread.java:833) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Caused by: io.temporal.failure.ApplicationFailure: message='Discover job subprocess finished with exit code 1', type='io.airbyte.workers.WorkerException', nonRetryable=false
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:74) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.DefaultDiscoverCatalogWorker.run(DefaultDiscoverCatalogWorker.java:24) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.38.1-alpha.jar:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container 	at java.base/java.lang.Thread.run(Thread.java:833) ~[?:?]
airbyte-worker-69ff9f45f5-9w54z airbyte-worker-container Collecting content into /tmp/toBePublished13705955414460208088.tmp before uploading.