You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ty...@apache.org on 2023/01/19 02:30:56 UTC
[incubator-seatunnel] branch dev updated: [Hotfix][Core] Fix Handover using linked blocking queue cause the oom (#3469)
This is an automated email from the ASF dual-hosted git repository.
tyrantlucifer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 73b523d55 [Hotfix][Core] Fix Handover using linked blocking queue cause the oom (#3469)
73b523d55 is described below
commit 73b523d55ccb7240336e0ccbe9481695738feca8
Author: Harvey Yue <yw...@126.com>
AuthorDate: Thu Jan 19 10:30:50 2023 +0800
[Hotfix][Core] Fix Handover using linked blocking queue cause the oom (#3469)
* [Bugfix][Core] Fix Handover using linked blocking queue cause the oom
* Revert "[Bugfix][Core] Fix Handover using linked blocking queue cause the oom"
This reverts commit e4b094565f902741f567d9baf1e5c44c6bbbf1e5.
* [Hotfix][Translation][Spark] Fix the bug that oom
Co-authored-by: tyrantlucifer <ty...@gmail.com>
---
.../src/main/java/org/apache/seatunnel/common/Handover.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/seatunnel-common/src/main/java/org/apache/seatunnel/common/Handover.java b/seatunnel-common/src/main/java/org/apache/seatunnel/common/Handover.java
index d1f62fda8..d6dbc47e2 100644
--- a/seatunnel-common/src/main/java/org/apache/seatunnel/common/Handover.java
+++ b/seatunnel-common/src/main/java/org/apache/seatunnel/common/Handover.java
@@ -24,9 +24,10 @@ import java.util.Optional;
import java.util.concurrent.LinkedBlockingQueue;
public final class Handover<T> implements Closeable {
+ private static final int DEFAULT_QUEUE_SIZE = 10000;
private final Object lock = new Object();
private final LinkedBlockingQueue<T> blockingQueue =
- new LinkedBlockingQueue<>();
+ new LinkedBlockingQueue<>(DEFAULT_QUEUE_SIZE);
private Throwable error;
public boolean isEmpty() {