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 2021/02/08 00:37:59 UTC
[flink] 01/03: [hotfix][tests] TestingPhysicalSlot rejects payload
if one is already assigned
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 e5de073680d1e1e61c1afc44fe851354f8abdc1c
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Tue Feb 2 14:00:02 2021 +0100
[hotfix][tests] TestingPhysicalSlot rejects payload if one is already assigned
---
.../java/org/apache/flink/runtime/scheduler/TestingPhysicalSlot.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TestingPhysicalSlot.java b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TestingPhysicalSlot.java
index 1e38d1c..0c9128e 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TestingPhysicalSlot.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TestingPhysicalSlot.java
@@ -68,12 +68,15 @@ public class TestingPhysicalSlot extends SimpleSlotContext implements PhysicalSl
@Override
public boolean tryAssignPayload(Payload payload) {
+ if (this.payload != null) {
+ return false;
+ }
this.payload = payload;
return true;
}
@Nullable
- Payload getPayload() {
+ public Payload getPayload() {
return payload;
}