You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/06/15 12:07:48 UTC
[flink] 01/04: [hotfix][tests] Streamline SubmissionBufferingTaskManagerGateway
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit fa719938441bda7a6dc55339ad582812df95ecf8
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Tue Jun 14 13:42:11 2022 +0200
[hotfix][tests] Streamline SubmissionBufferingTaskManagerGateway
---
.../apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java
index 65c7b0c33f9..4d8db038d0a 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java
@@ -1559,7 +1559,7 @@ public class AdaptiveSchedulerTest extends TestLogger {
public SubmissionBufferingTaskManagerGateway(int capacity) {
submittedTasks = new ArrayBlockingQueue<>(capacity);
- super.setSubmitConsumer(submittedTasks::offer);
+ setSubmitConsumer(ignored -> {});
}
@Override