You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by GitBox <gi...@apache.org> on 2021/06/07 09:39:28 UTC
[GitHub] [camel-quarkus] ppalaga commented on issue #2658: Intermittent failures in MongoDbTest.testTailingConsumer()
ppalaga commented on issue #2658:
URL: https://github.com/apache/camel-quarkus/issues/2658#issuecomment-855776266
Disabling `MongoDbTest.testTailingConsumer()` and `MongoDbTest.testPersistentTailingConsumer()`. The failures occurred in ~50% of runs for me.
The output when `testTailingConsumer()` is disabled and `testPersistentTailingConsumer()` is enabled:
```
[INFO] Running org.apache.camel.quarkus.component.mongodb.it.MongoDbTest
2021-06-07 11:33:41,761 INFO [org.apa.cam.qua.com.mon.it.MongoDbTestResource] (pool-4-thread-1) TestcontainersConfiguration(userProperties={docker.client.strategy=org.testcontainers.dockerclient.EnvironmentAndSystemPropertyClientProviderStrategy}, classpathProperties={}, environment={PATH=/home/ppalaga/gems/bin:/home/ppalaga/orgs/graalvm/mx:/home/ppalaga/bin/async-profiler-1.6-linux-x64:/home/ppalaga/bin/vscode-installations/code/bin:/home/ppalaga/.yarn/bin:/home/ppalaga/.config/yarn/global/node_modules/.bin:/home/ppalaga/bin:/home/ppalaga/bin/gradle-3.5.x/bin:/home/ppalaga/gems/bin:/home/ppalaga/.sdkman/candidates/mvnd/current/bin:/home/ppalaga/.sdkman/candidates/maven/current/bin:/home/ppalaga/.sdkman/candidates/jbang/current/bin:/home/ppalaga/.sdkman/candidates/jbake/current/bin:/home/ppalaga/.sdkman/candidates/java/current/bin:/home/ppalaga/orgs/graalvm/mx:/home/ppalaga/bin/async-profiler-1.6-linux-x64:/home/ppalaga/bin/vscode-installations/code/bin:/home/ppalaga/.yarn/bin:/h
ome/ppalaga/.config/yarn/global/node_modules/.bin:/home/ppalaga/bin:/home/ppalaga/bin/gradle-3.5.x/bin:/usr/local/bin:/usr/bin:/bin:/usr/local/sbin:/usr/sbin, INVOCATION_ID=91cf6a0b3e6545bba8bbfe4dd01c306b, XAUTHORITY=/run/user/1000/xauth_gXOUKd, SDKMAN_VERSION=5.11.5+713, HISTCONTROL=ignoredups, XDG_DATA_DIRS=/home/ppalaga/.local/share/flatpak/exports/share:/var/lib/flatpak/exports/share:/usr/local/share:/usr/share, DBUS_SESSION_BUS_ADDRESS=unix:path=/run/user/1000/bus, ANDROID_HOME=/home/ppalaga/bin/android/android-sdk, XDG_CURRENT_DESKTOP=KDE, JOURNAL_STREAM=8:22148, QT_AUTO_SCREEN_SCALE_FACTOR=0, MAVEN_HOME=/home/ppalaga/bin/maven/apache-maven-3.6.x, MAIL=/var/spool/mail/ppalaga, SSH_AGENT_PID=3189, SDKMAN_DIR=/home/ppalaga/.sdkman, GRAALVM_HOME=/home/ppalaga/.sdkman/candidates/java/21.1.0.r11-grl, SESSION_MANAGER=local/unix:@/tmp/.ICE-unix/3268,unix/unix:/tmp/.ICE-unix/3268, LOGNAME=ppalaga, JBANG_EDITOR=code, MANAGERPID=3118, PWD=/home/ppalaga/orgs/cq/camel-quarkus/integration
-tests/mongodb, XCURSOR_THEME=breeze_cursors, LANGUAGE=en_US, KDE_SESSION_VERSION=5, LESSOPEN=||/usr/bin/lesspipe.sh %s, SHELL=/bin/bash, SDKMAN_CANDIDATES_API=https://api.sdkman.io/2, ECLIPSE_WORKSPACE=/home/ppalaga/orgs/cq, OLDPWD=/home/ppalaga/orgs/cq/camel-quarkus/integration-tests/mongodb, GEM_HOME=/home/ppalaga/gems, KDE_FULL_SESSION=true, SSH_ASKPASS=/usr/bin/ksshaskpass, XDG_SESSION_PATH=/org/freedesktop/DisplayManager/Session0, FG_AIRCRAFT=/home/ppalaga/FlightGear/Aircraft, MVND_HOME=/home/ppalaga/.sdkman/candidates/mvnd/current, SYSTEMD_EXEC_PID=3412, LS_COLORS=rs=0:di=01;34:ln=01;36:mh=00:pi=40;33:so=01;35:do=01;35:bd=40;33;01:cd=40;33;01:or=40;31;01:mi=01;37;41:su=37;41:sg=30;43:ca=30;41:tw=30;42:ow=34;42:st=37;44:ex=01;32:*.tar=01;31:*.tgz=01;31:*.arc=01;31:*.arj=01;31:*.taz=01;31:*.lha=01;31:*.lz4=01;31:*.lzh=01;31:*.lzma=01;31:*.tlz=01;31:*.txz=01;31:*.tzo=01;31:*.t7z=01;31:*.zip=01;31:*.z=01;31:*.dz=01;31:*.gz=01;31:*.lrz=01;31:*.lz=01;31:*.lzo=01;31:*.xz=01;31:*.zst
=01;31:*.tzst=01;31:*.bz2=01;31:*.bz=01;31:*.tbz=01;31:*.tbz2=01;31:*.tz=01;31:*.deb=01;31:*.rpm=01;31:*.jar=01;31:*.war=01;31:*.ear=01;31:*.sar=01;31:*.rar=01;31:*.alz=01;31:*.ace=01;31:*.zoo=01;31:*.cpio=01;31:*.7z=01;31:*.rz=01;31:*.cab=01;31:*.wim=01;31:*.swm=01;31:*.dwm=01;31:*.esd=01;31:*.jpg=01;35:*.jpeg=01;35:*.mjpg=01;35:*.mjpeg=01;35:*.gif=01;35:*.bmp=01;35:*.pbm=01;35:*.pgm=01;35:*.ppm=01;35:*.tga=01;35:*.xbm=01;35:*.xpm=01;35:*.tif=01;35:*.tiff=01;35:*.png=01;35:*.svg=01;35:*.svgz=01;35:*.mng=01;35:*.pcx=01;35:*.mov=01;35:*.mpg=01;35:*.mpeg=01;35:*.m2v=01;35:*.mkv=01;35:*.webm=01;35:*.webp=01;35:*.ogm=01;35:*.mp4=01;35:*.m4v=01;35:*.mp4v=01;35:*.vob=01;35:*.qt=01;35:*.nuv=01;35:*.wmv=01;35:*.asf=01;35:*.rm=01;35:*.rmvb=01;35:*.flc=01;35:*.avi=01;35:*.fli=01;35:*.flv=01;35:*.gl=01;35:*.dl=01;35:*.xcf=01;35:*.xwd=01;35:*.yuv=01;35:*.cgm=01;35:*.emf=01;35:*.ogv=01;35:*.ogx=01;35:*.aac=01;36:*.au=01;36:*.flac=01;36:*.m4a=01;36:*.mid=01;36:*.midi=01;36:*.mka=01;36:*.mp3=01;36
:*.mpc=01;36:*.ogg=01;36:*.ra=01;36:*.wav=01;36:*.oga=01;36:*.opus=01;36:*.spx=01;36:*.xspf=01;36:, XDG_SESSION_DESKTOP=KDE, SHLVL=2, FG_SCENERY=/home/ppalaga/FlightGear/Scenery, KDE_APPLICATIONS_AS_SCOPE=1, OXYGEN_DISABLE_INNER_SHADOWS_HACK=1, HISTSIZE=100000, SDKMAN_OLD_PWD=/home/ppalaga/orgs/cq/camel-quarkus/integration-tests/mongodb, JAVA_HOME=/usr/lib/jvm/java-11-openjdk, BASH_FUNC_which%%=() { ( alias;
eval ${which_declare} ) | /usr/bin/which --tty-only --read-alias --read-functions --show-tilde --show-dot "$@"
}, JBANG_HOME=/home/ppalaga/.sdkman/candidates/jbang/current, TERM=xterm, KDE_SESSION_UID=1000, XDG_CONFIG_DIRS=/etc/xdg:/usr/share/kde-settings/kde-profile/default/xdg, XDG_SEAT_PATH=/org/freedesktop/DisplayManager/Seat0, LANG=en_IE.UTF-8, XDG_SESSION_ID=1, MOZ_GMP_PATH=/usr/lib64/mozilla/plugins/gmp-gmpopenh264/system-installed, XDG_SESSION_TYPE=x11, HISTFILESIZE=100000, DISPLAY=:0, GTK_RC_FILES=/etc/gtk/gtkrc:/home/ppalaga/.gtkrc:/home/ppalaga/.config/gtkrc, which_declare=declare -f, ECLIPSE_HOME=/home/ppalaga/bin/eclipse-installations/java-latest/eclipse, MAVEN_CMD_LINE_ARGS= -DtrimStackTrace=false --no-snapshot-updates clean test, _=/usr/lib/jvm/java-11-openjdk-11.0.11.0.9-2.fc34.x86_64/bin/java, XDG_SESSION_CLASS=user, SDKMAN_CANDIDATES_DIR=/home/ppalaga/.sdkman/candidates, JBAKE_HOME=/home/ppalaga/.sdkman/candidates/jbake/current, XCURSOR_SIZE=24, LIBOVERLAY_SCROLLBAR=0, GDK_CORE_DEVICE_EVENTS=1, DESKTOP_SESSION=/usr/share/xsessions/plasmax11, MAVEN_PROJECTBASEDIR=/home/ppa
laga/orgs/cq/camel-quarkus, SDKMAN_PLATFORM=linuxx64, USER=ppalaga, GTK2_RC_FILES=/etc/gtk-2.0/gtkrc:/home/ppalaga/.gtkrc-2.0:/home/ppalaga/.gtkrc-2.0-kde4:/home/ppalaga/.config/gtkrc-2.0, XDG_MENU_PREFIX=kf5-, XDG_SEAT=seat0, SSH_AUTH_SOCK=/tmp/ssh-XXXXXXbSzAX2/agent.3133, EDITOR=/home/ppalaga/bin/nano-ansi.sh, PK_OFFLINE_UPDATE=1, GTK_OVERLAY_SCROLLING=0, HOSTNAME=terpistone, KDEDIRS=/usr, XDG_RUNTIME_DIR=/run/user/1000, XDG_VTNR=2, HOME=/home/ppalaga})
2021-06-07 11:33:41,794 INFO [org.tes.doc.DockerClientProviderStrategy] (pool-4-thread-1) Loaded org.testcontainers.dockerclient.EnvironmentAndSystemPropertyClientProviderStrategy from ~/.testcontainers.properties, will try it first
2021-06-07 11:33:42,195 INFO [org.tes.doc.DockerClientProviderStrategy] (pool-4-thread-1) Found Docker environment with Environment variables, system properties and defaults. Resolved dockerHost=unix:///var/run/docker.sock
2021-06-07 11:33:42,196 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) Docker host IP address is localhost
2021-06-07 11:33:42,228 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) Connected to docker:
Server Version: 20.10.6
API Version: 1.41
Operating System: Fedora 34 (KDE Plasma)
Total Memory: 64247 MB
2021-06-07 11:33:42,231 INFO [org.tes.uti.ImageNameSubstitutor] (pool-4-thread-1) Image name substitution will be performed by: DefaultImageNameSubstitutor (composite of 'ConfigurationFileImageNameSubstitutor' and 'PrefixingImageNameSubstitutor')
2021-06-07 11:33:42,271 INFO [org.tes.uti.RegistryAuthLocator] (pool-4-thread-1) Failure when attempting to lookup auth config. Please ignore if you don't have images in an authenticated registry. Details: (dockerImageName: testcontainers/ryuk:0.3.1, configFile: /home/ppalaga/.docker/config.json. Falling back to docker-java default behaviour. Exception message: /home/ppalaga/.docker/config.json (No such file or directory)
2021-06-07 11:33:42,732 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) Ryuk started - will monitor and terminate Testcontainers containers on JVM exit
2021-06-07 11:33:42,732 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) Checking the system...
2021-06-07 11:33:42,733 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) โ๏ธ Docker server version should be at least 1.6.0
2021-06-07 11:33:42,817 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) โ๏ธ Docker environment should have more than 2GB free disk space
2021-06-07 11:33:42,849 INFO [๐ณ .4]] (pool-4-thread-1) Creating container for image: mongo:4.4
2021-06-07 11:33:43,108 INFO [๐ณ .4]] (pool-4-thread-1) Starting container with ID: f7247c51447f301cf13994fc0ae4c07add4fdfbaff88f011477add7d1d63ad86
2021-06-07 11:33:43,496 INFO [๐ณ .4]] (pool-4-thread-1) Container mongo:4.4 is starting: f7247c51447f301cf13994fc0ae4c07add4fdfbaff88f011477add7d1d63ad86
2021-06-07 11:33:44,690 INFO [๐ณ .4]] (pool-4-thread-1) Container mongo:4.4 started in PT1.872502S
2021-06-07 11:33:45,417 INFO [org.mon.dri.cluster] (pool-4-thread-1) Cluster created with settings {hosts=[localhost:49178], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:33:45,449 INFO [org.mon.dri.cluster] (pool-4-thread-1) Cluster description not yet available. Waiting for 30000 ms before timing out
2021-06-07 11:33:45,470 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde7f94aca2c50b911ab95', description='null'}-localhost:49178) Opened connection [connectionId{localValue:2, serverValue:5}] to localhost:49178
2021-06-07 11:33:45,470 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde7f94aca2c50b911ab95', description='null'}-localhost:49178) Opened connection [connectionId{localValue:1, serverValue:6}] to localhost:49178
2021-06-07 11:33:45,478 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde7f94aca2c50b911ab95', description='null'}-localhost:49178) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49178, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=18507045, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde7f7713c9e9d5ac97dc2, counter=6}, lastWriteDate=Mon Jun 07 11:33:45 CEST 2021, lastUpdateTimeNanos=7814680973127}
2021-06-07 11:33:45,492 INFO [org.mon.dri.connection] (pool-4-thread-1) Opened connection [connectionId{localValue:3, serverValue:7}] to localhost:49178
2021-06-07 11:33:45,587 INFO [org.mon.dri.connection] (pool-4-thread-1) Closed connection [connectionId{localValue:3, serverValue:7}] to localhost:49178 because the pool has been closed.
2021-06-07 11:33:46,032 INFO [org.mon.dri.cluster] (main) Cluster created with settings {hosts=[localhost:49178], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:33:46,036 INFO [org.mon.dri.cluster] (main) Cluster created with settings {hosts=[localhost:49178], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:33:46,037 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde7fa4aca2c50b911ab96', description='null'}-localhost:49178) Opened connection [connectionId{localValue:4, serverValue:9}] to localhost:49178
2021-06-07 11:33:46,036 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde7fa4aca2c50b911ab96', description='null'}-localhost:49178) Opened connection [connectionId{localValue:5, serverValue:8}] to localhost:49178
2021-06-07 11:33:46,038 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde7fa4aca2c50b911ab96', description='null'}-localhost:49178) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49178, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=2058125, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde7f7713c9e9d5ac97dc2, counter=6}, lastWriteDate=Mon Jun 07 11:33:45 CEST 2021, lastUpdateTimeNanos=7815248267066}
2021-06-07 11:33:46,047 INFO [org.mon.dri.cluster] (main) Cluster created with settings {hosts=[localhost:49178], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:33:46,048 INFO [org.mon.dri.cluster] (main) Cluster created with settings {hosts=[localhost:49178], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:33:46,052 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde7fa4aca2c50b911ab98', description='null'}-localhost:49178) Opened connection [connectionId{localValue:9, serverValue:13}] to localhost:49178
2021-06-07 11:33:46,052 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde7fa4aca2c50b911ab98', description='null'}-localhost:49178) Opened connection [connectionId{localValue:8, serverValue:12}] to localhost:49178
2021-06-07 11:33:46,053 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde7fa4aca2c50b911ab98', description='null'}-localhost:49178) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49178, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=2865573, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde7f7713c9e9d5ac97dc2, counter=6}, lastWriteDate=Mon Jun 07 11:33:45 CEST 2021, lastUpdateTimeNanos=7815263682401}
2021-06-07 11:33:46,054 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde7fa4aca2c50b911ab99', description='null'}-localhost:49178) Opened connection [connectionId{localValue:11, serverValue:15}] to localhost:49178
2021-06-07 11:33:46,054 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde7fa4aca2c50b911ab97', description='null'}-localhost:49178) Opened connection [connectionId{localValue:7, serverValue:10}] to localhost:49178
2021-06-07 11:33:46,055 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde7fa4aca2c50b911ab99', description='null'}-localhost:49178) Opened connection [connectionId{localValue:10, serverValue:14}] to localhost:49178
2021-06-07 11:33:46,056 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde7fa4aca2c50b911ab99', description='null'}-localhost:49178) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49178, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=4154442, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde7f7713c9e9d5ac97dc2, counter=6}, lastWriteDate=Mon Jun 07 11:33:45 CEST 2021, lastUpdateTimeNanos=7815266711173}
2021-06-07 11:33:46,058 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde7fa4aca2c50b911ab97', description='null'}-localhost:49178) Opened connection [connectionId{localValue:6, serverValue:11}] to localhost:49178
2021-06-07 11:33:46,059 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde7fa4aca2c50b911ab97', description='null'}-localhost:49178) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49178, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=7661409, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde7f7713c9e9d5ac97dc2, counter=6}, lastWriteDate=Mon Jun 07 11:33:45 CEST 2021, lastUpdateTimeNanos=7815268976109}
2021-06-07 11:33:46,124 INFO [org.apa.cam.qua.cor.CamelBootstrapRecorder] (main) Bootstrap runtime: org.apache.camel.quarkus.main.CamelMainRuntime
2021-06-07 11:33:46,240 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (main) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=tailingCollection&database=test&tailTrackIncreasingField=increasing
2021-06-07 11:33:46,246 INFO [org.mon.dri.connection] (main) Opened connection [connectionId{localValue:12, serverValue:16}] to localhost:49178
2021-06-07 11:33:46,256 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (main) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=persistentTailingCollection&database=test&persistentId=darwin&persistentTailTracking=true&tailTrackIncreasingField=increasing
2021-06-07 11:33:46,258 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (main) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=streamChangesCollection&consumerType=changeStreams&database=test
2021-06-07 11:33:46,269 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Starting MongoDB Tailable Cursor consumer, binding to collection: db: com.mongodb.client.internal.MongoDatabaseImpl@434b120b, col: tailingCollection
2021-06-07 11:33:46,343 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Starting MongoDB Tailable Cursor consumer, binding to collection: db: com.mongodb.client.internal.MongoDatabaseImpl@48cec770, col: persistentTailingCollection
2021-06-07 11:33:46,379 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Routes startup summary (total:3 started:3)
2021-06-07 11:33:46,379 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Started route1 (mongodb://camelMongoClient)
2021-06-07 11:33:46,379 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Started persistentTailingCollection (mongodb://camelMongoClient)
2021-06-07 11:33:46,379 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Started route2 (mongodb://camelMongoClient)
2021-06-07 11:33:46,379 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.10.0 (camel-1) started in 200ms (build:0ms init:82ms start:118ms)
2021-06-07 11:33:46,511 INFO [io.quarkus] (main) Quarkus 2.0.0.CR3 on JVM started in 6.083s. Listening on: http://localhost:41839
2021-06-07 11:33:46,512 INFO [io.quarkus] (main) Profile test activated.
2021-06-07 11:33:46,512 INFO [io.quarkus] (main) Installed features: [camel-core, camel-mongodb, camel-mongodb-gridfs, camel-support-common, camel-support-mongodb, cdi, mongodb-client, resteasy, resteasy-jsonb, smallrye-context-propagation]
2021-06-07 11:33:46,526 INFO [org.mon.dri.cluster] (main) Cluster created with settings {hosts=[localhost:49178], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:33:46,538 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde7fa4aca2c50b911ab9b', description='null'}-localhost:49178) Opened connection [connectionId{localValue:13, serverValue:17}] to localhost:49178
2021-06-07 11:33:46,538 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde7fa4aca2c50b911ab9b', description='null'}-localhost:49178) Opened connection [connectionId{localValue:14, serverValue:18}] to localhost:49178
2021-06-07 11:33:46,539 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde7fa4aca2c50b911ab9b', description='null'}-localhost:49178) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49178, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=10563973, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde7f7713c9e9d5ac97dc2, counter=6}, lastWriteDate=Mon Jun 07 11:33:46 CEST 2021, lastUpdateTimeNanos=7815750187023}
2021-06-07 11:33:46,905 INFO [org.mon.dri.connection] (main) Opened connection [connectionId{localValue:15, serverValue:19}] to localhost:49178
2021-06-07 11:33:47,288 INFO [org.mon.dri.connection] (Camel (camel-1) thread #0 - mongodb://camelMongoClient) Opened connection [connectionId{localValue:16, serverValue:20}] to localhost:49178
2021-06-07 11:33:47,456 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=outputTypeDocumentList&database=test&dynamicity=true&operation=findAll&outputType=DocumentList
2021-06-07 11:33:48,545 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=outputTypeDocument&database=test&dynamicity=true&operation=findOneByQuery&outputType=Document
2021-06-07 11:33:50,294 INFO [org.mon.dri.connection] (Camel (camel-1) thread #0 - mongodb://camelMongoClient) Opened connection [connectionId{localValue:17, serverValue:21}] to localhost:49178
2021-06-07 11:33:54,229 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=camelMongoClientCamelTest&database=test&dynamicity=true&operation=insert
2021-06-07 11:33:54,277 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=camelMongoClientCamelTest&database=test&dynamicity=true&operation=findAll&outputType=MongoIterable
2021-06-07 11:33:54,320 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://myMongoClient?collection=myMongoClientCamelTest&database=test&dynamicity=true&operation=insert
2021-06-07 11:33:54,322 INFO [org.mon.dri.connection] (executor-thread-0) Opened connection [connectionId{localValue:18, serverValue:22}] to localhost:49178
2021-06-07 11:33:54,355 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://myMongoClient?collection=myMongoClientCamelTest&database=test&dynamicity=true&operation=findAll&outputType=MongoIterable
2021-06-07 11:33:54,371 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=dynamicCamelTest&database=test&dynamicity=true&operation=insert
2021-06-07 11:33:54,429 INFO [org.mon.dri.connection] (main) Closed connection [connectionId{localValue:15, serverValue:19}] to localhost:49178 because the pool has been closed.
[ERROR] Tests run: 10, Failures: 0, Errors: 1, Skipped: 1, Time elapsed: 16.338 s <<< FAILURE! - in org.apache.camel.quarkus.component.mongodb.it.MongoDbTest
[ERROR] testPersistentTailingConsumer Time elapsed: 5.538 s <<< ERROR!
org.awaitility.core.ConditionTimeoutException: Lambda expression in org.apache.camel.quarkus.component.mongodb.it.MongoDbTest that uses java.lang.String: expected the predicate to return <true> but it returned <false> for input of <{size=0}> within 5 seconds.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:166)
at org.awaitility.core.AbstractHamcrestCondition.await(AbstractHamcrestCondition.java:86)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:939)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:645)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:662)
at org.apache.camel.quarkus.component.mongodb.it.MongoDbTest.waitForTailingResults(MongoDbTest.java:283)
at org.apache.camel.quarkus.component.mongodb.it.MongoDbTest.testPersistentTailingConsumer(MongoDbTest.java:171)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at io.quarkus.test.junit.QuarkusTestExtension.runExtensionMethod(QuarkusTestExtension.java:993)
at io.quarkus.test.junit.QuarkusTestExtension.interceptTestMethod(QuarkusTestExtension.java:870)
at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:84)
at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:131)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:65)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:108)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:96)
at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:75)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:150)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
[INFO] Running org.apache.camel.quarkus.component.mongodb.it.MongodbGridfsTest
2021-06-07 11:33:54,449 INFO [org.apa.cam.com.mon.gri.GridFsEndpoint] (executor-thread-0) Initialize GridFS endpoint: mongodb-gridfs://camelMongoClient?database=test&operation=create
2021-06-07 11:33:54,563 INFO [org.apa.cam.com.mon.gri.GridFsEndpoint] (executor-thread-0) Initialize GridFS endpoint: mongodb-gridfs://camelMongoClient?database=test&operation=findOne
2021-06-07 11:33:54,580 INFO [org.apa.cam.com.mon.gri.GridFsEndpoint] (executor-thread-0) Initialize GridFS endpoint: mongodb-gridfs://camelMongoClient?database=test&operation=remove
2021-06-07 11:33:54,611 INFO [org.apa.cam.com.mon.gri.GridFsEndpoint] (executor-thread-0) Initialize GridFS endpoint: mongodb-gridfs://myMongoClient?database=test&operation=create
2021-06-07 11:33:54,626 INFO [org.apa.cam.com.mon.gri.GridFsEndpoint] (executor-thread-0) Initialize GridFS endpoint: mongodb-gridfs://myMongoClient?database=test&operation=findOne
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.174 s - in org.apache.camel.quarkus.component.mongodb.it.MongodbGridfsTest
2021-06-07 11:33:54,681 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.10.0 (camel-1) shutting down
2021-06-07 11:33:54,684 INFO [org.apa.cam.com.mon.MongoDbChangeStreamsThread] (main) Stopping MongoDB Tailable Cursor consumer, bound to collection: db: test, col: streamChangesCollection
2021-06-07 11:33:54,685 INFO [org.apa.cam.com.mon.MongoDbChangeStreamsThread] (main) Going to wait for stopping
2021-06-07 11:33:55,274 WARN [org.apa.cam.com.mon.MongoDbChangeStreamsThread] (Camel (camel-1) thread #2 - mongodb://camelMongoClient) Exception from consuming from MongoDB caused by Attempted to decrement the reference count below 0. ConsumerThread will be stopped.: com.mongodb.MongoException: Attempted to decrement the reference count below 0
at com.mongodb.MongoException.fromThrowableNonNull(MongoException.java:83)
at com.mongodb.internal.operation.ChangeStreamBatchCursor.resumeableOperation(ChangeStreamBatchCursor.java:185)
at com.mongodb.internal.operation.ChangeStreamBatchCursor.hasNext(ChangeStreamBatchCursor.java:64)
at com.mongodb.client.internal.MongoChangeStreamCursorImpl.hasNext(MongoChangeStreamCursorImpl.java:58)
at org.apache.camel.component.mongodb.MongoDbChangeStreamsThread.doRun(MongoDbChangeStreamsThread.java:72)
at org.apache.camel.component.mongodb.MongoAbstractConsumerThread.run(MongoAbstractConsumerThread.java:70)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.IllegalStateException: Attempted to decrement the reference count below 0
at com.mongodb.internal.binding.AbstractReferenceCounted.release(AbstractReferenceCounted.java:39)
at com.mongodb.internal.binding.ClusterBinding$ClusterBindingConnectionSource.release(ClusterBinding.java:134)
at com.mongodb.client.internal.ClientSessionBinding$SessionBindingConnectionSource.release(ClientSessionBinding.java:152)
at com.mongodb.internal.operation.QueryBatchCursor.releaseConnectionSourceIfNoServerCursor(QueryBatchCursor.java:357)
at com.mongodb.internal.operation.QueryBatchCursor.getMore(QueryBatchCursor.java:287)
at com.mongodb.internal.operation.QueryBatchCursor.hasNext(QueryBatchCursor.java:141)
at com.mongodb.internal.operation.ChangeStreamBatchCursor$1.apply(ChangeStreamBatchCursor.java:68)
at com.mongodb.internal.operation.ChangeStreamBatchCursor$1.apply(ChangeStreamBatchCursor.java:64)
at com.mongodb.internal.operation.ChangeStreamBatchCursor.resumeableOperation(ChangeStreamBatchCursor.java:182)
... 7 more
2021-06-07 11:33:55,276 INFO [org.apa.cam.com.mon.MongoDbChangeStreamsThread] (main) Stopped MongoDB Tailable Cursor consumer, bound to collection: db: test, col: streamChangesCollection
2021-06-07 11:33:55,278 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Stopping MongoDB Tailable Cursor consumer, bound to collection: db: test, col: persistentTailingCollection
2021-06-07 11:33:55,279 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Going to wait for stopping
2021-06-07 11:33:55,411 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (Camel (camel-1) thread #1 - mongodb://camelMongoClient) Cursor was closed, likely the consumer was stopped and closed the cursor on purpose.: java.lang.IllegalStateException: Attempted to decrement the reference count below 0
at com.mongodb.internal.binding.AbstractReferenceCounted.release(AbstractReferenceCounted.java:39)
at com.mongodb.internal.binding.ClusterBinding$ClusterBindingConnectionSource.release(ClusterBinding.java:134)
at com.mongodb.client.internal.ClientSessionBinding$SessionBindingConnectionSource.release(ClientSessionBinding.java:152)
at com.mongodb.internal.operation.QueryBatchCursor.releaseConnectionSourceIfNoServerCursor(QueryBatchCursor.java:357)
at com.mongodb.internal.operation.QueryBatchCursor.getMore(QueryBatchCursor.java:287)
at com.mongodb.internal.operation.QueryBatchCursor.hasNext(QueryBatchCursor.java:141)
at com.mongodb.client.internal.MongoBatchCursorAdapter.hasNext(MongoBatchCursorAdapter.java:54)
at org.apache.camel.component.mongodb.MongoDbTailingThread.doRun(MongoDbTailingThread.java:112)
at org.apache.camel.component.mongodb.MongoAbstractConsumerThread.run(MongoAbstractConsumerThread.java:70)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
2021-06-07 11:33:55,436 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Stopped MongoDB Tailable Cursor consumer, bound to collection: db: test, col: persistentTailingCollection
2021-06-07 11:33:55,437 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Stopping MongoDB Tailable Cursor consumer, bound to collection: db: test, col: tailingCollection
2021-06-07 11:33:55,437 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Going to wait for stopping
2021-06-07 11:33:56,301 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Stopped MongoDB Tailable Cursor consumer, bound to collection: db: test, col: tailingCollection
2021-06-07 11:33:56,303 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Routes shutdown summary (total:3 stopped:3)
2021-06-07 11:33:56,303 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Stopped route1 (mongodb://camelMongoClient)
2021-06-07 11:33:56,303 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Stopped persistentTailingCollection (mongodb://camelMongoClient)
2021-06-07 11:33:56,303 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Stopped route2 (mongodb://camelMongoClient)
2021-06-07 11:33:56,305 INFO [org.mon.dri.connection] (main) Closed connection [connectionId{localValue:18, serverValue:22}] to localhost:49178 because the pool has been closed.
2021-06-07 11:33:56,310 INFO [org.mon.dri.connection] (main) Closed connection [connectionId{localValue:17, serverValue:21}] to localhost:49178 because the pool has been closed.
2021-06-07 11:33:56,311 INFO [org.mon.dri.connection] (main) Closed connection [connectionId{localValue:12, serverValue:16}] to localhost:49178 because the pool has been closed.
2021-06-07 11:33:56,311 INFO [org.mon.dri.connection] (main) Closed connection [connectionId{localValue:16, serverValue:20}] to localhost:49178 because the pool has been closed.
2021-06-07 11:33:56,315 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.10.0 (camel-1) shutdown in 1s634ms (uptime:10s54ms)
2021-06-07 11:33:56,340 INFO [io.quarkus] (main) Quarkus stopped in 1.683s
[INFO]
[INFO] Results:
[INFO]
[ERROR] Errors:
[ERROR] MongoDbTest.testPersistentTailingConsumer:171->waitForTailingResults:283 ยป ConditionTimeout
```
And this is when `testPersistentTailingConsumer()` is disabled and `testTailingConsumer()` is enabled:
```
[INFO] Running org.apache.camel.quarkus.component.mongodb.it.MongoDbTest
2021-06-07 11:38:44,378 INFO [org.apa.cam.qua.com.mon.it.MongoDbTestResource] (pool-4-thread-1) TestcontainersConfiguration(userProperties={docker.client.strategy=org.testcontainers.dockerclient.EnvironmentAndSystemPropertyClientProviderStrategy}, classpathProperties={}, environment={PATH=/home/ppalaga/gems/bin:/home/ppalaga/orgs/graalvm/mx:/home/ppalaga/bin/async-profiler-1.6-linux-x64:/home/ppalaga/bin/vscode-installations/code/bin:/home/ppalaga/.yarn/bin:/home/ppalaga/.config/yarn/global/node_modules/.bin:/home/ppalaga/bin:/home/ppalaga/bin/gradle-3.5.x/bin:/home/ppalaga/gems/bin:/home/ppalaga/.sdkman/candidates/mvnd/current/bin:/home/ppalaga/.sdkman/candidates/maven/current/bin:/home/ppalaga/.sdkman/candidates/jbang/current/bin:/home/ppalaga/.sdkman/candidates/jbake/current/bin:/home/ppalaga/.sdkman/candidates/java/current/bin:/home/ppalaga/orgs/graalvm/mx:/home/ppalaga/bin/async-profiler-1.6-linux-x64:/home/ppalaga/bin/vscode-installations/code/bin:/home/ppalaga/.yarn/bin:/h
ome/ppalaga/.config/yarn/global/node_modules/.bin:/home/ppalaga/bin:/home/ppalaga/bin/gradle-3.5.x/bin:/usr/local/bin:/usr/bin:/bin:/usr/local/sbin:/usr/sbin, INVOCATION_ID=91cf6a0b3e6545bba8bbfe4dd01c306b, XAUTHORITY=/run/user/1000/xauth_gXOUKd, SDKMAN_VERSION=5.11.5+713, HISTCONTROL=ignoredups, XDG_DATA_DIRS=/home/ppalaga/.local/share/flatpak/exports/share:/var/lib/flatpak/exports/share:/usr/local/share:/usr/share, DBUS_SESSION_BUS_ADDRESS=unix:path=/run/user/1000/bus, ANDROID_HOME=/home/ppalaga/bin/android/android-sdk, XDG_CURRENT_DESKTOP=KDE, JOURNAL_STREAM=8:22148, QT_AUTO_SCREEN_SCALE_FACTOR=0, MAVEN_HOME=/home/ppalaga/bin/maven/apache-maven-3.6.x, MAIL=/var/spool/mail/ppalaga, SSH_AGENT_PID=3189, SDKMAN_DIR=/home/ppalaga/.sdkman, GRAALVM_HOME=/home/ppalaga/.sdkman/candidates/java/21.1.0.r11-grl, SESSION_MANAGER=local/unix:@/tmp/.ICE-unix/3268,unix/unix:/tmp/.ICE-unix/3268, LOGNAME=ppalaga, JBANG_EDITOR=code, MANAGERPID=3118, PWD=/home/ppalaga/orgs/cq/camel-quarkus/integration
-tests/mongodb, XCURSOR_THEME=breeze_cursors, LANGUAGE=en_US, KDE_SESSION_VERSION=5, LESSOPEN=||/usr/bin/lesspipe.sh %s, SHELL=/bin/bash, SDKMAN_CANDIDATES_API=https://api.sdkman.io/2, ECLIPSE_WORKSPACE=/home/ppalaga/orgs/cq, OLDPWD=/home/ppalaga/orgs/cq/camel-quarkus/integration-tests/mongodb, GEM_HOME=/home/ppalaga/gems, KDE_FULL_SESSION=true, SSH_ASKPASS=/usr/bin/ksshaskpass, XDG_SESSION_PATH=/org/freedesktop/DisplayManager/Session0, FG_AIRCRAFT=/home/ppalaga/FlightGear/Aircraft, MVND_HOME=/home/ppalaga/.sdkman/candidates/mvnd/current, SYSTEMD_EXEC_PID=3412, LS_COLORS=rs=0:di=01;34:ln=01;36:mh=00:pi=40;33:so=01;35:do=01;35:bd=40;33;01:cd=40;33;01:or=40;31;01:mi=01;37;41:su=37;41:sg=30;43:ca=30;41:tw=30;42:ow=34;42:st=37;44:ex=01;32:*.tar=01;31:*.tgz=01;31:*.arc=01;31:*.arj=01;31:*.taz=01;31:*.lha=01;31:*.lz4=01;31:*.lzh=01;31:*.lzma=01;31:*.tlz=01;31:*.txz=01;31:*.tzo=01;31:*.t7z=01;31:*.zip=01;31:*.z=01;31:*.dz=01;31:*.gz=01;31:*.lrz=01;31:*.lz=01;31:*.lzo=01;31:*.xz=01;31:*.zst
=01;31:*.tzst=01;31:*.bz2=01;31:*.bz=01;31:*.tbz=01;31:*.tbz2=01;31:*.tz=01;31:*.deb=01;31:*.rpm=01;31:*.jar=01;31:*.war=01;31:*.ear=01;31:*.sar=01;31:*.rar=01;31:*.alz=01;31:*.ace=01;31:*.zoo=01;31:*.cpio=01;31:*.7z=01;31:*.rz=01;31:*.cab=01;31:*.wim=01;31:*.swm=01;31:*.dwm=01;31:*.esd=01;31:*.jpg=01;35:*.jpeg=01;35:*.mjpg=01;35:*.mjpeg=01;35:*.gif=01;35:*.bmp=01;35:*.pbm=01;35:*.pgm=01;35:*.ppm=01;35:*.tga=01;35:*.xbm=01;35:*.xpm=01;35:*.tif=01;35:*.tiff=01;35:*.png=01;35:*.svg=01;35:*.svgz=01;35:*.mng=01;35:*.pcx=01;35:*.mov=01;35:*.mpg=01;35:*.mpeg=01;35:*.m2v=01;35:*.mkv=01;35:*.webm=01;35:*.webp=01;35:*.ogm=01;35:*.mp4=01;35:*.m4v=01;35:*.mp4v=01;35:*.vob=01;35:*.qt=01;35:*.nuv=01;35:*.wmv=01;35:*.asf=01;35:*.rm=01;35:*.rmvb=01;35:*.flc=01;35:*.avi=01;35:*.fli=01;35:*.flv=01;35:*.gl=01;35:*.dl=01;35:*.xcf=01;35:*.xwd=01;35:*.yuv=01;35:*.cgm=01;35:*.emf=01;35:*.ogv=01;35:*.ogx=01;35:*.aac=01;36:*.au=01;36:*.flac=01;36:*.m4a=01;36:*.mid=01;36:*.midi=01;36:*.mka=01;36:*.mp3=01;36
:*.mpc=01;36:*.ogg=01;36:*.ra=01;36:*.wav=01;36:*.oga=01;36:*.opus=01;36:*.spx=01;36:*.xspf=01;36:, XDG_SESSION_DESKTOP=KDE, SHLVL=2, FG_SCENERY=/home/ppalaga/FlightGear/Scenery, KDE_APPLICATIONS_AS_SCOPE=1, OXYGEN_DISABLE_INNER_SHADOWS_HACK=1, HISTSIZE=100000, SDKMAN_OLD_PWD=/home/ppalaga/orgs/cq/camel-quarkus/integration-tests/mongodb, JAVA_HOME=/usr/lib/jvm/java-11-openjdk, BASH_FUNC_which%%=() { ( alias;
eval ${which_declare} ) | /usr/bin/which --tty-only --read-alias --read-functions --show-tilde --show-dot "$@"
}, JBANG_HOME=/home/ppalaga/.sdkman/candidates/jbang/current, TERM=xterm, KDE_SESSION_UID=1000, XDG_CONFIG_DIRS=/etc/xdg:/usr/share/kde-settings/kde-profile/default/xdg, XDG_SEAT_PATH=/org/freedesktop/DisplayManager/Seat0, LANG=en_IE.UTF-8, XDG_SESSION_ID=1, MOZ_GMP_PATH=/usr/lib64/mozilla/plugins/gmp-gmpopenh264/system-installed, XDG_SESSION_TYPE=x11, HISTFILESIZE=100000, DISPLAY=:0, GTK_RC_FILES=/etc/gtk/gtkrc:/home/ppalaga/.gtkrc:/home/ppalaga/.config/gtkrc, which_declare=declare -f, ECLIPSE_HOME=/home/ppalaga/bin/eclipse-installations/java-latest/eclipse, MAVEN_CMD_LINE_ARGS= -DtrimStackTrace=false --no-snapshot-updates clean test, _=/usr/lib/jvm/java-11-openjdk-11.0.11.0.9-2.fc34.x86_64/bin/java, XDG_SESSION_CLASS=user, SDKMAN_CANDIDATES_DIR=/home/ppalaga/.sdkman/candidates, JBAKE_HOME=/home/ppalaga/.sdkman/candidates/jbake/current, XCURSOR_SIZE=24, LIBOVERLAY_SCROLLBAR=0, GDK_CORE_DEVICE_EVENTS=1, DESKTOP_SESSION=/usr/share/xsessions/plasmax11, MAVEN_PROJECTBASEDIR=/home/ppa
laga/orgs/cq/camel-quarkus, SDKMAN_PLATFORM=linuxx64, USER=ppalaga, GTK2_RC_FILES=/etc/gtk-2.0/gtkrc:/home/ppalaga/.gtkrc-2.0:/home/ppalaga/.gtkrc-2.0-kde4:/home/ppalaga/.config/gtkrc-2.0, XDG_MENU_PREFIX=kf5-, XDG_SEAT=seat0, SSH_AUTH_SOCK=/tmp/ssh-XXXXXXbSzAX2/agent.3133, EDITOR=/home/ppalaga/bin/nano-ansi.sh, PK_OFFLINE_UPDATE=1, GTK_OVERLAY_SCROLLING=0, HOSTNAME=terpistone, KDEDIRS=/usr, XDG_RUNTIME_DIR=/run/user/1000, XDG_VTNR=2, HOME=/home/ppalaga})
2021-06-07 11:38:44,403 INFO [org.tes.doc.DockerClientProviderStrategy] (pool-4-thread-1) Loaded org.testcontainers.dockerclient.EnvironmentAndSystemPropertyClientProviderStrategy from ~/.testcontainers.properties, will try it first
2021-06-07 11:38:44,799 INFO [org.tes.doc.DockerClientProviderStrategy] (pool-4-thread-1) Found Docker environment with Environment variables, system properties and defaults. Resolved dockerHost=unix:///var/run/docker.sock
2021-06-07 11:38:44,800 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) Docker host IP address is localhost
2021-06-07 11:38:44,833 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) Connected to docker:
Server Version: 20.10.6
API Version: 1.41
Operating System: Fedora 34 (KDE Plasma)
Total Memory: 64247 MB
2021-06-07 11:38:44,836 INFO [org.tes.uti.ImageNameSubstitutor] (pool-4-thread-1) Image name substitution will be performed by: DefaultImageNameSubstitutor (composite of 'ConfigurationFileImageNameSubstitutor' and 'PrefixingImageNameSubstitutor')
2021-06-07 11:38:44,873 INFO [org.tes.uti.RegistryAuthLocator] (pool-4-thread-1) Failure when attempting to lookup auth config. Please ignore if you don't have images in an authenticated registry. Details: (dockerImageName: testcontainers/ryuk:0.3.1, configFile: /home/ppalaga/.docker/config.json. Falling back to docker-java default behaviour. Exception message: /home/ppalaga/.docker/config.json (No such file or directory)
2021-06-07 11:38:45,376 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) Ryuk started - will monitor and terminate Testcontainers containers on JVM exit
2021-06-07 11:38:45,376 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) Checking the system...
2021-06-07 11:38:45,377 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) โ๏ธ Docker server version should be at least 1.6.0
2021-06-07 11:38:45,462 INFO [org.tes.DockerClientFactory] (pool-4-thread-1) โ๏ธ Docker environment should have more than 2GB free disk space
2021-06-07 11:38:45,494 INFO [๐ณ .4]] (pool-4-thread-1) Creating container for image: mongo:4.4
2021-06-07 11:38:45,756 INFO [๐ณ .4]] (pool-4-thread-1) Starting container with ID: d52bed2e4d6c244d352b1359dd2db9dfd002e47cb5eca9c84feee3f95c3c6082
2021-06-07 11:38:46,148 INFO [๐ณ .4]] (pool-4-thread-1) Container mongo:4.4 is starting: d52bed2e4d6c244d352b1359dd2db9dfd002e47cb5eca9c84feee3f95c3c6082
2021-06-07 11:38:47,330 INFO [๐ณ .4]] (pool-4-thread-1) Container mongo:4.4 started in PT1.867867S
2021-06-07 11:38:48,042 INFO [org.mon.dri.cluster] (pool-4-thread-1) Cluster created with settings {hosts=[localhost:49188], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:38:48,074 INFO [org.mon.dri.cluster] (pool-4-thread-1) Cluster description not yet available. Waiting for 30000 ms before timing out
2021-06-07 11:38:48,092 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde928f686221e0fd92289', description='null'}-localhost:49188) Opened connection [connectionId{localValue:2, serverValue:6}] to localhost:49188
2021-06-07 11:38:48,092 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde928f686221e0fd92289', description='null'}-localhost:49188) Opened connection [connectionId{localValue:1, serverValue:5}] to localhost:49188
2021-06-07 11:38:48,099 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde928f686221e0fd92289', description='null'}-localhost:49188) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49188, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=16769828, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde92661e317f161082580, counter=6}, lastWriteDate=Mon Jun 07 11:38:47 CEST 2021, lastUpdateTimeNanos=8117303622997}
2021-06-07 11:38:48,112 INFO [org.mon.dri.connection] (pool-4-thread-1) Opened connection [connectionId{localValue:3, serverValue:7}] to localhost:49188
2021-06-07 11:38:48,189 INFO [org.mon.dri.connection] (pool-4-thread-1) Closed connection [connectionId{localValue:3, serverValue:7}] to localhost:49188 because the pool has been closed.
2021-06-07 11:38:48,652 INFO [org.mon.dri.cluster] (main) Cluster created with settings {hosts=[localhost:49188], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:38:48,656 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde928f686221e0fd9228a', description='null'}-localhost:49188) Opened connection [connectionId{localValue:4, serverValue:8}] to localhost:49188
2021-06-07 11:38:48,657 INFO [org.mon.dri.cluster] (main) Cluster created with settings {hosts=[localhost:49188], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:38:48,657 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde928f686221e0fd9228a', description='null'}-localhost:49188) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49188, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=2274855, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde92661e317f161082580, counter=6}, lastWriteDate=Mon Jun 07 11:38:48 CEST 2021, lastUpdateTimeNanos=8117867782695}
2021-06-07 11:38:48,656 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde928f686221e0fd9228a', description='null'}-localhost:49188) Opened connection [connectionId{localValue:5, serverValue:9}] to localhost:49188
2021-06-07 11:38:48,670 INFO [org.mon.dri.cluster] (main) Cluster created with settings {hosts=[localhost:49188], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:38:48,671 INFO [org.mon.dri.cluster] (main) Cluster created with settings {hosts=[localhost:49188], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:38:48,675 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde928f686221e0fd9228c', description='null'}-localhost:49188) Opened connection [connectionId{localValue:8, serverValue:12}] to localhost:49188
2021-06-07 11:38:48,676 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde928f686221e0fd9228c', description='null'}-localhost:49188) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49188, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=3466491, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde92661e317f161082580, counter=6}, lastWriteDate=Mon Jun 07 11:38:48 CEST 2021, lastUpdateTimeNanos=8117886968986}
2021-06-07 11:38:48,677 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde928f686221e0fd9228c', description='null'}-localhost:49188) Opened connection [connectionId{localValue:9, serverValue:14}] to localhost:49188
2021-06-07 11:38:48,678 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde928f686221e0fd9228d', description='null'}-localhost:49188) Opened connection [connectionId{localValue:11, serverValue:15}] to localhost:49188
2021-06-07 11:38:48,680 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde928f686221e0fd9228b', description='null'}-localhost:49188) Opened connection [connectionId{localValue:6, serverValue:11}] to localhost:49188
2021-06-07 11:38:48,680 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde928f686221e0fd9228d', description='null'}-localhost:49188) Opened connection [connectionId{localValue:10, serverValue:13}] to localhost:49188
2021-06-07 11:38:48,680 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde928f686221e0fd9228b', description='null'}-localhost:49188) Opened connection [connectionId{localValue:7, serverValue:10}] to localhost:49188
2021-06-07 11:38:48,682 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde928f686221e0fd9228b', description='null'}-localhost:49188) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49188, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=7169438, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde92661e317f161082580, counter=6}, lastWriteDate=Mon Jun 07 11:38:48 CEST 2021, lastUpdateTimeNanos=8117892285748}
2021-06-07 11:38:48,682 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde928f686221e0fd9228d', description='null'}-localhost:49188) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49188, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=6992313, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde92661e317f161082580, counter=6}, lastWriteDate=Mon Jun 07 11:38:48 CEST 2021, lastUpdateTimeNanos=8117892116197}
2021-06-07 11:38:48,743 INFO [org.apa.cam.qua.cor.CamelBootstrapRecorder] (main) Bootstrap runtime: org.apache.camel.quarkus.main.CamelMainRuntime
2021-06-07 11:38:48,832 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (main) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=tailingCollection&database=test&tailTrackIncreasingField=increasing
2021-06-07 11:38:48,837 INFO [org.mon.dri.connection] (main) Opened connection [connectionId{localValue:12, serverValue:16}] to localhost:49188
2021-06-07 11:38:48,862 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (main) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=persistentTailingCollection&database=test&persistentId=darwin&persistentTailTracking=true&tailTrackIncreasingField=increasing
2021-06-07 11:38:48,864 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (main) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=streamChangesCollection&consumerType=changeStreams&database=test
2021-06-07 11:38:48,877 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Starting MongoDB Tailable Cursor consumer, binding to collection: db: com.mongodb.client.internal.MongoDatabaseImpl@40ed1d35, col: tailingCollection
2021-06-07 11:38:48,948 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Starting MongoDB Tailable Cursor consumer, binding to collection: db: com.mongodb.client.internal.MongoDatabaseImpl@45e3ed62, col: persistentTailingCollection
2021-06-07 11:38:48,994 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Routes startup summary (total:3 started:3)
2021-06-07 11:38:48,995 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Started route1 (mongodb://camelMongoClient)
2021-06-07 11:38:48,995 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Started persistentTailingCollection (mongodb://camelMongoClient)
2021-06-07 11:38:48,995 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Started route2 (mongodb://camelMongoClient)
2021-06-07 11:38:48,995 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.10.0 (camel-1) started in 197ms (build:0ms init:69ms start:128ms)
2021-06-07 11:38:49,092 INFO [io.quarkus] (main) Quarkus 2.0.0.CR3 on JVM started in 6.076s. Listening on: http://localhost:33723
2021-06-07 11:38:49,093 INFO [io.quarkus] (main) Profile test activated.
2021-06-07 11:38:49,093 INFO [io.quarkus] (main) Installed features: [camel-core, camel-mongodb, camel-mongodb-gridfs, camel-support-common, camel-support-mongodb, cdi, mongodb-client, resteasy, resteasy-jsonb, smallrye-context-propagation]
2021-06-07 11:38:49,103 INFO [org.mon.dri.cluster] (main) Cluster created with settings {hosts=[localhost:49188], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2021-06-07 11:38:49,117 INFO [org.mon.dri.connection] (cluster-ClusterId{value='60bde929f686221e0fd9228f', description='null'}-localhost:49188) Opened connection [connectionId{localValue:13, serverValue:17}] to localhost:49188
2021-06-07 11:38:49,117 INFO [org.mon.dri.connection] (cluster-rtt-ClusterId{value='60bde929f686221e0fd9228f', description='null'}-localhost:49188) Opened connection [connectionId{localValue:14, serverValue:18}] to localhost:49188
2021-06-07 11:38:49,117 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='60bde929f686221e0fd9228f', description='null'}-localhost:49188) Monitor thread successfully connected to server with description ServerDescription{address=localhost:49188, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=12084721, setName='my-mongo-set', canonicalAddress=mongodb_private:27017, hosts=[mongodb_private:27017], passives=[], arbiters=[], primary='mongodb_private:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion{processId=60bde92661e317f161082580, counter=6}, lastWriteDate=Mon Jun 07 11:38:48 CEST 2021, lastUpdateTimeNanos=8118328444128}
2021-06-07 11:38:49,445 INFO [org.mon.dri.connection] (main) Opened connection [connectionId{localValue:15, serverValue:19}] to localhost:49188
2021-06-07 11:38:49,901 INFO [org.mon.dri.connection] (Camel (camel-1) thread #0 - mongodb://camelMongoClient) Opened connection [connectionId{localValue:16, serverValue:20}] to localhost:49188
2021-06-07 11:38:50,023 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=outputTypeDocumentList&database=test&dynamicity=true&operation=findAll&outputType=DocumentList
2021-06-07 11:38:52,963 INFO [org.mon.dri.connection] (Camel (camel-1) thread #1 - mongodb://camelMongoClient) Opened connection [connectionId{localValue:17, serverValue:21}] to localhost:49188
2021-06-07 11:38:56,653 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=outputTypeDocument&database=test&dynamicity=true&operation=findOneByQuery&outputType=Document
2021-06-07 11:38:56,813 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=camelMongoClientCamelTest&database=test&dynamicity=true&operation=insert
2021-06-07 11:38:56,848 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=camelMongoClientCamelTest&database=test&dynamicity=true&operation=findAll&outputType=MongoIterable
2021-06-07 11:38:56,887 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://myMongoClient?collection=myMongoClientCamelTest&database=test&dynamicity=true&operation=insert
2021-06-07 11:38:56,890 INFO [org.mon.dri.connection] (executor-thread-0) Opened connection [connectionId{localValue:18, serverValue:22}] to localhost:49188
2021-06-07 11:38:56,922 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://myMongoClient?collection=myMongoClientCamelTest&database=test&dynamicity=true&operation=findAll&outputType=MongoIterable
2021-06-07 11:38:56,939 INFO [org.apa.cam.com.mon.MongoDbEndpoint] (executor-thread-0) Initialising MongoDb endpoint: mongodb://camelMongoClient?collection=dynamicCamelTest&database=test&dynamicity=true&operation=insert
2021-06-07 11:38:56,994 INFO [org.mon.dri.connection] (main) Closed connection [connectionId{localValue:15, serverValue:19}] to localhost:49188 because the pool has been closed.
[ERROR] Tests run: 10, Failures: 0, Errors: 1, Skipped: 1, Time elapsed: 16.354 s <<< FAILURE! - in org.apache.camel.quarkus.component.mongodb.it.MongoDbTest
[ERROR] testTailingConsumer Time elapsed: 5.572 s <<< ERROR!
org.awaitility.core.ConditionTimeoutException: Lambda expression in org.apache.camel.quarkus.component.mongodb.it.MongoDbTest that uses java.lang.String: expected the predicate to return <true> but it returned <false> for input of <{size=0}> within 5 seconds.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:166)
at org.awaitility.core.AbstractHamcrestCondition.await(AbstractHamcrestCondition.java:86)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:939)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:645)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:662)
at org.apache.camel.quarkus.component.mongodb.it.MongoDbTest.waitForTailingResults(MongoDbTest.java:283)
at org.apache.camel.quarkus.component.mongodb.it.MongoDbTest.testTailingConsumer(MongoDbTest.java:156)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at io.quarkus.test.junit.QuarkusTestExtension.runExtensionMethod(QuarkusTestExtension.java:993)
at io.quarkus.test.junit.QuarkusTestExtension.interceptTestMethod(QuarkusTestExtension.java:870)
at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:84)
at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:131)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:65)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:108)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:96)
at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:75)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:150)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
[INFO] Running org.apache.camel.quarkus.component.mongodb.it.MongodbGridfsTest
2021-06-07 11:38:57,012 INFO [org.apa.cam.com.mon.gri.GridFsEndpoint] (executor-thread-0) Initialize GridFS endpoint: mongodb-gridfs://camelMongoClient?database=test&operation=create
2021-06-07 11:38:57,127 INFO [org.apa.cam.com.mon.gri.GridFsEndpoint] (executor-thread-0) Initialize GridFS endpoint: mongodb-gridfs://camelMongoClient?database=test&operation=findOne
2021-06-07 11:38:57,203 INFO [org.apa.cam.com.mon.gri.GridFsEndpoint] (executor-thread-0) Initialize GridFS endpoint: mongodb-gridfs://camelMongoClient?database=test&operation=remove
2021-06-07 11:38:57,242 INFO [org.apa.cam.com.mon.gri.GridFsEndpoint] (executor-thread-0) Initialize GridFS endpoint: mongodb-gridfs://myMongoClient?database=test&operation=create
2021-06-07 11:38:57,259 INFO [org.apa.cam.com.mon.gri.GridFsEndpoint] (executor-thread-0) Initialize GridFS endpoint: mongodb-gridfs://myMongoClient?database=test&operation=findOne
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.233 s - in org.apache.camel.quarkus.component.mongodb.it.MongodbGridfsTest
2021-06-07 11:38:57,308 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.10.0 (camel-1) shutting down
2021-06-07 11:38:57,311 INFO [org.apa.cam.com.mon.MongoDbChangeStreamsThread] (main) Stopping MongoDB Tailable Cursor consumer, bound to collection: db: test, col: streamChangesCollection
2021-06-07 11:38:57,312 INFO [org.apa.cam.com.mon.MongoDbChangeStreamsThread] (main) Going to wait for stopping
2021-06-07 11:38:57,780 WARN [org.apa.cam.com.mon.MongoDbChangeStreamsThread] (Camel (camel-1) thread #2 - mongodb://camelMongoClient) Exception from consuming from MongoDB caused by Attempted to decrement the reference count below 0. ConsumerThread will be stopped.: com.mongodb.MongoException: Attempted to decrement the reference count below 0
at com.mongodb.MongoException.fromThrowableNonNull(MongoException.java:83)
at com.mongodb.internal.operation.ChangeStreamBatchCursor.resumeableOperation(ChangeStreamBatchCursor.java:185)
at com.mongodb.internal.operation.ChangeStreamBatchCursor.hasNext(ChangeStreamBatchCursor.java:64)
at com.mongodb.client.internal.MongoChangeStreamCursorImpl.hasNext(MongoChangeStreamCursorImpl.java:58)
at org.apache.camel.component.mongodb.MongoDbChangeStreamsThread.doRun(MongoDbChangeStreamsThread.java:72)
at org.apache.camel.component.mongodb.MongoAbstractConsumerThread.run(MongoAbstractConsumerThread.java:70)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.IllegalStateException: Attempted to decrement the reference count below 0
at com.mongodb.internal.binding.AbstractReferenceCounted.release(AbstractReferenceCounted.java:39)
at com.mongodb.internal.binding.ClusterBinding$ClusterBindingConnectionSource.release(ClusterBinding.java:134)
at com.mongodb.client.internal.ClientSessionBinding$SessionBindingConnectionSource.release(ClientSessionBinding.java:152)
at com.mongodb.internal.operation.QueryBatchCursor.releaseConnectionSourceIfNoServerCursor(QueryBatchCursor.java:357)
at com.mongodb.internal.operation.QueryBatchCursor.getMore(QueryBatchCursor.java:287)
at com.mongodb.internal.operation.QueryBatchCursor.hasNext(QueryBatchCursor.java:141)
at com.mongodb.internal.operation.ChangeStreamBatchCursor$1.apply(ChangeStreamBatchCursor.java:68)
at com.mongodb.internal.operation.ChangeStreamBatchCursor$1.apply(ChangeStreamBatchCursor.java:64)
at com.mongodb.internal.operation.ChangeStreamBatchCursor.resumeableOperation(ChangeStreamBatchCursor.java:182)
... 7 more
2021-06-07 11:38:57,782 INFO [org.apa.cam.com.mon.MongoDbChangeStreamsThread] (main) Stopped MongoDB Tailable Cursor consumer, bound to collection: db: test, col: streamChangesCollection
2021-06-07 11:38:57,784 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Stopping MongoDB Tailable Cursor consumer, bound to collection: db: test, col: persistentTailingCollection
2021-06-07 11:38:57,784 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Going to wait for stopping
2021-06-07 11:38:57,968 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Stopped MongoDB Tailable Cursor consumer, bound to collection: db: test, col: persistentTailingCollection
2021-06-07 11:38:57,969 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Stopping MongoDB Tailable Cursor consumer, bound to collection: db: test, col: tailingCollection
2021-06-07 11:38:57,970 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Going to wait for stopping
2021-06-07 11:38:58,967 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (Camel (camel-1) thread #0 - mongodb://camelMongoClient) Cursor was closed, likely the consumer was stopped and closed the cursor on purpose.: java.lang.IllegalStateException: Attempted to decrement the reference count below 0
at com.mongodb.internal.binding.AbstractReferenceCounted.release(AbstractReferenceCounted.java:39)
at com.mongodb.internal.binding.ClusterBinding$ClusterBindingConnectionSource.release(ClusterBinding.java:134)
at com.mongodb.client.internal.ClientSessionBinding$SessionBindingConnectionSource.release(ClientSessionBinding.java:152)
at com.mongodb.internal.operation.QueryBatchCursor.releaseConnectionSourceIfNoServerCursor(QueryBatchCursor.java:357)
at com.mongodb.internal.operation.QueryBatchCursor.getMore(QueryBatchCursor.java:287)
at com.mongodb.internal.operation.QueryBatchCursor.hasNext(QueryBatchCursor.java:141)
at com.mongodb.client.internal.MongoBatchCursorAdapter.hasNext(MongoBatchCursorAdapter.java:54)
at org.apache.camel.component.mongodb.MongoDbTailingThread.doRun(MongoDbTailingThread.java:112)
at org.apache.camel.component.mongodb.MongoAbstractConsumerThread.run(MongoAbstractConsumerThread.java:70)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
2021-06-07 11:38:58,968 INFO [org.apa.cam.com.mon.MongoDbTailingThread] (main) Stopped MongoDB Tailable Cursor consumer, bound to collection: db: test, col: tailingCollection
2021-06-07 11:38:58,969 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Routes shutdown summary (total:3 stopped:3)
2021-06-07 11:38:58,970 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Stopped route1 (mongodb://camelMongoClient)
2021-06-07 11:38:58,970 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Stopped persistentTailingCollection (mongodb://camelMongoClient)
2021-06-07 11:38:58,970 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Stopped route2 (mongodb://camelMongoClient)
2021-06-07 11:38:58,972 INFO [org.mon.dri.connection] (main) Closed connection [connectionId{localValue:18, serverValue:22}] to localhost:49188 because the pool has been closed.
2021-06-07 11:38:58,975 INFO [org.mon.dri.connection] (main) Closed connection [connectionId{localValue:17, serverValue:21}] to localhost:49188 because the pool has been closed.
2021-06-07 11:38:58,975 INFO [org.mon.dri.connection] (main) Closed connection [connectionId{localValue:12, serverValue:16}] to localhost:49188 because the pool has been closed.
2021-06-07 11:38:58,976 INFO [org.mon.dri.connection] (main) Closed connection [connectionId{localValue:16, serverValue:20}] to localhost:49188 because the pool has been closed.
2021-06-07 11:38:58,979 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.10.0 (camel-1) shutdown in 1s671ms (uptime:10s112ms)
2021-06-07 11:38:59,001 INFO [io.quarkus] (main) Quarkus stopped in 1.716s
[INFO]
[INFO] Results:
[INFO]
[ERROR] Errors:
[ERROR] MongoDbTest.testTailingConsumer:156->waitForTailingResults:283 ยป ConditionTimeout
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org