This is an automated email from the ASF dual-hosted git repository. dmvk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit f3955cff98439eeeb5dcb55f9a5040722652b207 Author: David Moravek <[email protected]> AuthorDate: Mon Feb 27 17:29:09 2023 +0100 [hotfix] Mark InstantiationUtil#readObjectFromConfig as @Nullable. Signed-off-by: David Moravek <[email protected]> --- flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java b/flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java index 200e3921af3..938d5dee795 100644 --- a/flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java +++ b/flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java @@ -30,6 +30,8 @@ import org.apache.flink.core.memory.DataOutputViewStreamWrapper; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import javax.annotation.Nullable; + import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.IOException; @@ -466,6 +468,7 @@ public final class InstantiationUtil { } } + @Nullable public static <T> T readObjectFromConfig(Configuration config, String key, ClassLoader cl) throws IOException, ClassNotFoundException { byte[] bytes = config.getBytes(key, null);
