This is an automated email from the ASF dual-hosted git repository. mdedetrich pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
commit ddea46df3046f8243b856a395a94107f28b0cfab Author: João Ferreira <[email protected]> AuthorDate: Wed Dec 27 15:19:04 2023 +0000 Revert "test showing the thread starvation" This reverts commit 6442c27285843b71acf8d19ecae65945e7cff0fd. --- .../kinesis/KinesisSchedulerSourceSpec.scala | 36 ---------------------- 1 file changed, 36 deletions(-) diff --git a/kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerSourceSpec.scala b/kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerSourceSpec.scala index 5cfb66c63..bca357c36 100644 --- a/kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerSourceSpec.scala +++ b/kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerSourceSpec.scala @@ -251,42 +251,6 @@ class KinesisSchedulerSourceSpec killSwitch.shutdown() sinkProbe.expectComplete() }) - - "not starve dispatcher threads with 15 sources" in assertAllStagesStopped { - val scheduler: Scheduler = org.mockito.Mockito.mock(classOf[Scheduler]) - when(scheduler.run()).thenAnswer(new Answer[Unit] { - override def answer(invocation: InvocationOnMock): Unit = - Thread.sleep(10000) - }) - - val killSwitch = KillSwitches.shared("") - - for (_ <- 1 to 15) - KinesisSchedulerSource(_ => scheduler, KinesisSchedulerSourceSettings.defaults) - .via(killSwitch.flow) - .run() - - killSwitch.shutdown() - - } - - "not starve dispatcher threads with 16 sources" in assertAllStagesStopped { - val scheduler: Scheduler = org.mockito.Mockito.mock(classOf[Scheduler]) - when(scheduler.run()).thenAnswer(new Answer[Unit] { - override def answer(invocation: InvocationOnMock): Unit = - Thread.sleep(10000) - }) - - val killSwitch = KillSwitches.shared("") - - for (_ <- 1 to 16) - KinesisSchedulerSource(_ => scheduler, KinesisSchedulerSourceSettings.defaults) - .via(killSwitch.flow) - .run() - - killSwitch.shutdown() - - } } private abstract class KinesisSchedulerContext(schedulerFailure: Option[Throwable] = None, --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
