increasing processing time

streamnative · Aug 16, 2023 · dbbbb68 · dbbbb68
1 parent 9c1d3dc
commit dbbbb68
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/test/scala/org/apache/spark/sql/pulsar/PulsarAdmissionControlSuite.scala b/src/test/scala/org/apache/spark/sql/pulsar/PulsarAdmissionControlSuite.scala
@@ -40,7 +40,7 @@ class PulsarAdmissionControlSuite extends PulsarSourceTest {
 
  // Each Int adds 38 bytes to message size, so we expect 3 Ints in each message
  testStream(mapped)(
- StartStream(trigger = ProcessingTime(10)),
+ StartStream(trigger = ProcessingTime(100)),
  makeSureGetOffsetCalled,
  AddPulsarData(Set(topic), 1, 2, 3),
  CheckLastBatch(2, 3, 4),