CouchbaseTestFlowSpec: touch 1s, wait 2s and check exists

[raboof]

Seen in https://github.com/apache/pekko-connectors/actions/runs/9823914568/job/27122318959?pr=730:

--> [docs.scaladsl.CouchbaseTestFlowSpec: touch 1s, wait 2s and check exists] Start of log messages of test that [Failed(org.scalatest.exceptions.TestFailedException: true was not equal to false)]
02:26:31.559 INFO  [default-dispatcher-5] o.a.pekko.event.slf4j.Slf4jLogger     Slf4jLogger started
02:26:31.564 DEBUG [default-dispatcher-5] org.apache.pekko.event.EventStream    logger log1-Slf4jLogger started
02:26:31.566 DEBUG [default-dispatcher-5] org.apache.pekko.event.EventStream    Default Loggers started
02:26:31.587 DEBUG [default-dispatcher-6] a.p.s.Serialization(pekko://default)  Replacing JavaSerializer with DisabledJavaSerializer, due to `pekko.actor.allow-java-serialization = off`.
02:26:31.957 DEBUG [pool-6-thread-3     ] reactor.util.Loggers                  Using Slf4j logging framework
02:26:32.174 DEBUG [pool-6-thread-3     ] logcapture                            enabling CapturingAppender
02:26:32.338 INFO  [cb-events           ] com.couchbase.core                    [com.couchbase.core][DnsSrvLookupFailedEvent][131ms] DNS SRV lookup failed (name not found). This is expected if the there is no DNS SRV record associated with the hostname in the connection string. Will now try to bootstrap directly from the given hostname. To suppress this message, specify an IP address instead of a hostname (for example: 127.0.0.1 instead of localhost), specify more than one hostname, or set the `io.enableDnsSrv` client setting to false.
02:26:32.666 INFO  [cb-events           ] com.couchbase.core                    [com.couchbase.core][CoreCreatedEvent] {"clientVersion":"3.6.0","clientGitHash":"${buildNumber}","coreVersion":"2.6.0","coreGitHash":"${buildNumber}","userAgent":"couchbase-java/3.6.0 (Linux 5.15.0-1064-azure amd64; OpenJDK 64-Bit Server VM 1.8.0_412-b08)","maxNumRequestsInRetry":32768,"ioEnvironment":{"nativeIoEnabled":true,"eventLoopThreadCount":2,"eventLoopGroups":["EpollEventLoopGroup"]},"ioConfig":{"captureTraffic":[],"mutationTokensEnabled":true,"networkResolution":"auto","dnsSrvEnabled":true,"tcpKeepAlivesEnabled":true,"tcpKeepAliveTimeMs":60000,"configPollIntervalMs":2500,"kvCircuitBreakerConfig":"disabled","queryCircuitBreakerConfig":"disabled","viewCircuitBreakerConfig":"disabled","searchCircuitBreakerConfig":"disabled","analyticsCircuitBreakerConfig":"disabled","managerCircuitBreakerConfig":"disabled","eventingCircuitBreakerConfig":"disabled","backupCircuitBreakerConfig":"disabled","numKvConnections":1,"maxHttpConnections":12,"idleHttpConnectionTimeoutMs":1000,"configIdleRedialTimeoutMs":300000,"memcachedHashingStrategy":"StandardMemcachedHashingStrategy","timerConfig":{"numTimers":1,"tickDurationMs":10,"numBuckets":512}},"compressionConfig":{"enabled":true,"minRatio":0.83,"minSize":32},"securityConfig":{"tlsEnabled":false,"nativeTlsEnabled":true,"hostnameVerificationEnabled":true,"trustCertificates":null,"trustManagerFactory":null,"ciphers":[]},"timeoutConfig":{"kvMs":2500,"kvDurableMs":10000,"kvScanMs":75000,"managementMs":75000,"queryMs":75000,"viewMs":75000,"searchMs":75000,"analyticsMs":75000,"connectMs":10000,"disconnectMs":10000,"eventingMs":75000,"backupMs":75000},"loggerConfig":{"diagnosticContextEnabled":false},"orphanReporterConfig":{"emitIntervalMs":10000,"sampleSize":10,"queueLength":1024,"enabled":true},"thresholdLoggingTracerConfig":{"enabled":true,"emitIntervalMs":10000,"sampleSize":10,"queueLength":1024,"kvThresholdMs":500,"queryThresholdMs":1000,"searchThresholdMs":1000,"analyticsThresholdMs":1000,"viewThresholdMs":1000,"transactionsThresholdMs":5000},"loggingMeterConfig":{"enabled":true,"emitIntervalMs":600000},"retryStrategy":"BestEffortRetryStrategy","requestTracer":"ThresholdLoggingTracer","meter":"LoggingMeter","numRequestCallbacks":0,"scheduler":"ParallelScheduler","schedulerThreadCount":4,"transactionsConfig":{"durabilityLevel":"MAJORITY","timeoutMs":15000,"cleanupConfig":{"runLostAttemptsCleanupThread":true,"runRegularAttemptsCleanupThread":true,"cleanupWindowMs":60000,"cleanupSet":""},"numAtrs":1024,"metadataCollection":"none","scanConsistency":"none"}} {"connectionString":"couchbase://localhost","coreId":"0xc31b2aa200000001","numCoreInstances":1,"seedNodes":[{"address":"localhost"}]}
02:26:32.666 INFO  [cb-events           ] com.couchbase.transactions            [com.couchbase.transactions][TransactionsStartedEvent] Transactions successfully initialised, regular cleanup enabled=true, lost cleanup enabled=true
02:26:32.673 INFO  [cb-events           ] com.couchbase.node                    [com.couchbase.node][NodeCreatedEvent] Node created {"coreId":"0xc31b2aa200000001","managerPort":"8091","remote":"localhost"}
02:26:33.074 INFO  [cb-events           ] com.couchbase.core                    [com.couchbase.core][BucketOpenedEvent][460ms] Opened bucket "pekko" {"coreId":"0xc31b2aa200000001"}
02:26:35.172 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestSourceSpec: get document by jsonObject]
02:26:35.359 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestSourceSpec: get document by jsonObject] that [Succeeded]
02:26:35.368 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestSourceSpec: get document by scala case class]
02:26:35.422 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestSourceSpec: get document by scala case class] that [Succeeded]
02:26:35.423 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestSourceSpec: get document class with type]
02:26:35.453 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestSourceSpec: get document class with type] that [Succeeded]
02:26:35.454 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestSourceSpec: scan document]
02:26:35.760 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestSourceSpec: scan document] that [Succeeded]
02:26:35.761 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestSourceSpec: query document by sql++]
02:26:35.790 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestSourceSpec: query document by sql++] that [Succeeded]
02:26:35.790 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestSourceSpec: query json document by sql++]
02:26:35.820 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestSourceSpec: query json document by sql++] that [Succeeded]
02:26:35.821 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestSourceSpec: query all indexes]
02:26:35.864 INFO  [chbaseTestSourceSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestSourceSpec: query all indexes] that [Succeeded]
02:26:35.950 INFO  [default-dispatcher-5] o.a.pekko.event.slf4j.Slf4jLogger     Slf4jLogger started
02:26:35.950 DEBUG [default-dispatcher-5] org.apache.pekko.event.EventStream    logger log1-Slf4jLogger started
02:26:35.950 DEBUG [default-dispatcher-5] org.apache.pekko.event.EventStream    Default Loggers started
02:26:35.963 DEBUG [default-dispatcher-5] a.p.s.Serialization(pekko://default)  Replacing JavaSerializer with DisabledJavaSerializer, due to `pekko.actor.allow-java-serialization = off`.
02:26:39.507 INFO  [ouchbaseTestFlowSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestFlowSpec: insert-get-remove document]
02:26:39.545 INFO  [ouchbaseTestFlowSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestFlowSpec: insert-get-remove document] that [Succeeded]
02:26:39.546 INFO  [ouchbaseTestFlowSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestFlowSpec: upsert-get document]
02:26:39.565 INFO  [ouchbaseTestFlowSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestFlowSpec: upsert-get document] that [Succeeded]
02:26:39.566 INFO  [ouchbaseTestFlowSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestFlowSpec: replace data]
02:26:39.598 INFO  [ouchbaseTestFlowSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestFlowSpec: replace data] that [Succeeded]
02:26:39.599 INFO  [ouchbaseTestFlowSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestFlowSpec: check exists]
02:26:39.625 INFO  [ouchbaseTestFlowSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestFlowSpec: check exists] that [Succeeded]
02:26:39.625 INFO  [ouchbaseTestFlowSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging started for test [docs.scaladsl.CouchbaseTestFlowSpec: touch 1s, wait 2s and check exists]
02:26:41.660 INFO  [ouchbaseTestFlowSpec] o.a.p.s.c.t.scaladsl.LogCapturing     Logging finished for test [docs.scaladsl.CouchbaseTestFlowSpec: touch 1s, wait 2s and check exists] that [Failed(org.scalatest.exceptions.TestFailedException: true was not equal to false)]
<-- [docs.scaladsl.CouchbaseTestFlowSpec: touch 1s, wait 2s and check exists] End of log messages of test that [Failed(org.scalatest.exceptions.TestFailedException: true was not equal to false)]
[info] CouchbaseTestFlowSpec:
[info] - insert-get-remove document (38 milliseconds)
[info] - upsert-get document (20 milliseconds)
[info] - replace data (32 milliseconds)
[info] - check exists (26 milliseconds)
[info] - touch 1s, wait 2s and check exists *** FAILED *** (2 seconds, 39 milliseconds)

[info]   true was not equal to false (CouchbaseTestFlowSpec.scala:127)
[info]   org.scalatest.exceptions.TestFailedException:
[info]   at org.scalatest.matchers.MatchersHelper$.indicateFailure(MatchersHelper.scala:392)
[info]   at org.scalatest.matchers.should.Matchers$AnyShouldWrapper.shouldBe(Matchers.scala:7539)
[info]   at docs.scaladsl.CouchbaseTestFlowSpec.$anonfun$new$21(CouchbaseTestFlowSpec.scala:127)
[info]   at org.apache.pekko.stream.testkit.scaladsl.StreamTestKit$.assertAllStagesStopped(StreamTestKit.scala:42)
[info]   at docs.scaladsl.CouchbaseTestFlowSpec.$anonfun$new$20(CouchbaseTestFlowSpec.scala:113)
[info]   at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
[info]   at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)
[info]   at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
[info]   at org.scalatest.Transformer.apply(Transformer.scala:22)
[info]   at org.scalatest.Transformer.apply(Transformer.scala:20)
[info]   at org.scalatest.wordspec.AnyWordSpecLike$$anon$3.apply(AnyWordSpecLike.scala:1240)
[info]   at org.apache.pekko.stream.connectors.testkit.scaladsl.LogCapturing.withFixture(LogCapturing.scala:70)
[info]   at org.apache.pekko.stream.connectors.testkit.scaladsl.LogCapturing.withFixture$(LogCapturing.scala:66)
[info]   at docs.scaladsl.CouchbaseTestFlowSpec.withFixture(CouchbaseTestFlowSpec.scala:39)
[info]   at org.scalatest.wordspec.AnyWordSpecLike.invokeWithFixture$1(AnyWordSpecLike.scala:1238)
[info]   at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTest$1(AnyWordSpecLike.scala:1250)
[info]   at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
[info]   at org.scalatest.wordspec.AnyWordSpecLike.runTest(AnyWordSpecLike.scala:1250)
[info]   at org.scalatest.wordspec.AnyWordSpecLike.runTest$(AnyWordSpecLike.scala:1232)
[info]   at docs.scaladsl.CouchbaseTestFlowSpec.org$scalatest$BeforeAndAfterEach$$super$runTest(CouchbaseTestFlowSpec.scala:39)
[info]   at org.scalatest.BeforeAndAfterEach.runTest(BeforeAndAfterEach.scala:234)
[info]   at org.scalatest.BeforeAndAfterEach.runTest$(BeforeAndAfterEach.scala:227)
[info]   at docs.scaladsl.CouchbaseTestFlowSpec.runTest(CouchbaseTestFlowSpec.scala:39)
[info]   at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTests$1(AnyWordSpecLike.scala:1309)
[info]   at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:413)
[info]   at scala.collection.immutable.List.foreach(List.scala:431)
[info]   at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
[info]   at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:396)
[info]   at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:475)
[info]   at org.scalatest.wordspec.AnyWordSpecLike.runTests(AnyWordSpecLike.scala:1309)
[info]   at org.scalatest.wordspec.AnyWordSpecLike.runTests$(AnyWordSpecLike.scala:1308)
[info]   at org.scalatest.wordspec.AnyWordSpec.runTests(AnyWordSpec.scala:1880)
[info]   at org.scalatest.Suite.run(Suite.scala:1114)
[info]   at org.scalatest.Suite.run$(Suite.scala:1096)
[info]   at org.scalatest.wordspec.AnyWordSpec.org$scalatest$wordspec$AnyWordSpecLike$$super$run(AnyWordSpec.scala:1880)
[info]   at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$run$1(AnyWordSpecLike.scala:1354)
[info]   at org.scalatest.SuperEngine.runImpl(Engine.scala:535)
[info]   at org.scalatest.wordspec.AnyWordSpecLike.run(AnyWordSpecLike.scala:1354)
[info]   at org.scalatest.wordspec.AnyWordSpecLike.run$(AnyWordSpecLike.scala:1352)
[info]   at docs.scaladsl.CouchbaseTestFlowSpec.org$scalatest$BeforeAndAfterAll$$super$run(CouchbaseTestFlowSpec.scala:39)
[info]   at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:213)
[info]   at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:210)
[info]   at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:208)
[info]   at docs.scaladsl.CouchbaseTestFlowSpec.run(CouchbaseTestFlowSpec.scala:39)
[info]   at org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:321)
[info]   at org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:517)
[info]   at sbt.TestRunner.runTest$1(TestFramework.scala:153)
[info]   at sbt.TestRunner.run(TestFramework.scala:168)
[info]   at sbt.TestFramework$$anon$3$$anonfun$$lessinit$greater$1.$anonfun$apply$1(TestFramework.scala:336)
[info]   at sbt.TestFramework$.sbt$TestFramework$$withContextLoader(TestFramework.scala:296)
[info]   at sbt.TestFramework$$anon$3$$anonfun$$lessinit$greater$1.apply(TestFramework.scala:336)
[info]   at sbt.TestFramework$$anon$3$$anonfun$$lessinit$greater$1.apply(TestFramework.scala:336)
[info]   at sbt.TestFunction.apply(TestFramework.scala:348)
[info]   at sbt.Tests$.processRunnable$1(Tests.scala:475)
[info]   at sbt.Tests$.$anonfun$makeSerial$1(Tests.scala:481)
[info]   at sbt.std.Transform$$anon$3.$anonfun$apply$2(Transform.scala:47)
[info]   at sbt.std.Transform$$anon$4.work(Transform.scala:69)
[info]   at sbt.Execute.$anonfun$submit$2(Execute.scala:283)
[info]   at sbt.internal.util.ErrorHandling$.wideConvert(ErrorHandling.scala:24)
[info]   at sbt.Execute.work(Execute.scala:292)
[info]   at sbt.Execute.$anonfun$submit$1(Execute.scala:283)
[info]   at sbt.ConcurrentRestrictions$$anon$4.$anonfun$submitValid$1(ConcurrentRestrictions.scala:265)
[info]   at sbt.CompletionService$$anon$2.call(CompletionService.scala:65)
[info]   at java.util.concurrent.FutureTask.run(FutureTask.java:266)
[info]   at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[info]   at java.util.concurrent.FutureTask.run(FutureTask.java:266)
[info]   at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[info]   at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[info]   at java.lang.Thread.run(Thread.java:750)
[info] - mutateIn data: add field to JsonDoc (34 milliseconds)
[info] - increment and decrement on Number document (25 milliseconds)
[info] Run completed in 10 seconds, 782 milliseconds.
[info] Total number of tests run: 14
[info] Suites: completed 2, aborted 0
[info] Tests: succeeded 13, failed 1, canceled 0, ignored 0, pending 0
[info] *** 1 TEST FAILED ***
[error] Failed tests:
[error] 	docs.scaladsl.CouchbaseTestFlowSpec

@laglangyue you seem most familiar with Couchbase, could you have a look?