Roiocam commented on code in PR #195:
URL:
https://github.com/apache/pekko-persistence-jdbc/pull/195#discussion_r1616093226
##########
core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/LimitWindowingStreamTest.scala:
##########
@@ -50,22 +50,23 @@ abstract class LimitWindowingStreamTest(configFile: String)
implicit val mat: Materializer = SystemMaterializer(system).materializer
val persistenceId = UUID.randomUUID().toString
- val payload = 'a'.toByte
+ val writerUuid = UUID.randomUUID().toString
+ val payload = Array.fill(16)('a'.toByte)
val eventsPerBatch = 1000
val numberOfInsertBatches = 16
val totalMessages = numberOfInsertBatches * eventsPerBatch
withDao { dao =>
val lastInsert =
Source
- .fromIterator(() => (1 to numberOfInsertBatches).toIterator)
+ .fromIterator(() => (1 to numberOfInsertBatches).iterator)
.mapAsync(1) { i =>
val end = i * eventsPerBatch
val start = end - (eventsPerBatch - 1)
- log.info(s"batch $i (events from $start to $end")
+ log.info(s"batch $i - events from $start to $end")
val atomicWrites =
(start to end).map { j =>
- AtomicWrite(immutable.Seq(PersistentRepr(payload, j,
persistenceId)))
+ AtomicWrite(immutable.Seq(PersistentRepr(payload, j,
persistenceId, writerUuid = writerUuid)))
Review Comment:
Oracle not allow insert null `writedUuid`
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
