You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2024/06/04 15:44:34 UTC
(flink) 04/05: [hotfix] Unify Preconditions import in StreamConfig
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 54119568c983b8959a976498286c7ceb6b208a00
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Mon May 27 17:27:35 2024 +0200
[hotfix] Unify Preconditions import in StreamConfig
---
.../main/java/org/apache/flink/streaming/api/graph/StreamConfig.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
index 51e9c04bce3..eb98755d6b7 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
@@ -42,7 +42,6 @@ import org.apache.flink.streaming.runtime.tasks.StreamTaskException;
import org.apache.flink.util.ClassLoaderUtil;
import org.apache.flink.util.InstantiationUtil;
import org.apache.flink.util.OutputTag;
-import org.apache.flink.util.Preconditions;
import org.apache.flink.util.TernaryBoolean;
import org.apache.flink.util.concurrent.FutureUtils;
@@ -322,7 +321,7 @@ public class StreamConfig implements Serializable {
}
public <T> TypeSerializer<T> getTypeSerializerSideOut(OutputTag<?> outputTag, ClassLoader cl) {
- Preconditions.checkNotNull(outputTag, "Side output id must not be null.");
+ checkNotNull(outputTag, "Side output id must not be null.");
try {
return InstantiationUtil.readObjectFromConfig(
this.config, TYPE_SERIALIZER_SIDEOUT_PREFIX + outputTag.getId(), cl);
@@ -617,7 +616,7 @@ public class StreamConfig implements Serializable {
public OperatorID getOperatorID() {
byte[] operatorIDBytes = config.getBytes(OPERATOR_ID, null);
- return new OperatorID(Preconditions.checkNotNull(operatorIDBytes));
+ return new OperatorID(checkNotNull(operatorIDBytes));
}
public void setOperatorName(String name) {