alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5272 Notify all threads in case of mutliple writers

Browse Source
This commit is contained in:
Jiri Pechanec 2022-06-20 13:55:04 +02:00
parent e5935d3540
commit 5e1ae24e92
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-core/src/main/java/io/debezium/connector/base/ChangeEventQueue.java
View File

@ -199,7 +199,7 @@ protected void doEnqueue(T record) throws InterruptedException {
synchronized (this) {
while (queue.size() >= maxQueueSize || (maxQueueSizeInBytes > 0 && currentQueueSizeInBytes >= maxQueueSizeInBytes)) {
// notify poll() to drain queue
this.notify();
this.notifyAll();
// queue size or queue sizeInBytes threshold reached, so wait a bit
this.wait(pollInterval.toMillis());
}
@ -214,7 +214,7 @@ protected void doEnqueue(T record) throws InterruptedException {
if (queue.size() >= maxBatchSize || (maxQueueSizeInBytes > 0 && currentQueueSizeInBytes >= maxQueueSizeInBytes)) {
// notify poll() to start draining queue and do not wait
this.notify();
this.notifyAll();
}
}
}