(storm) branch master updated: Log when falling back to java serialization (#3824)

[rabreu]

This is an automated email from the ASF dual-hosted git repository.

rabreu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git


The following commit(s) were added to refs/heads/master by this push:
     new 1ccd04ded Log when falling back to java serialization (#3824)
1ccd04ded is described below

commit 1ccd04dedef90324adc3d8009b0cd6da742f7444
Author: MaheshAravindV <55615133+mahesharavi...@users.noreply.github.com>
AuthorDate: Thu Jan 2 06:32:53 2025 +0530

    Log when falling back to java serialization (#3824)
---
 .../jvm/org/apache/storm/serialization/DefaultKryoFactory.java | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git 
a/storm-client/src/jvm/org/apache/storm/serialization/DefaultKryoFactory.java 
b/storm-client/src/jvm/org/apache/storm/serialization/DefaultKryoFactory.java
index d361e252e..ef00ea47f 100644
--- 
a/storm-client/src/jvm/org/apache/storm/serialization/DefaultKryoFactory.java
+++ 
b/storm-client/src/jvm/org/apache/storm/serialization/DefaultKryoFactory.java
@@ -14,11 +14,15 @@ package org.apache.storm.serialization;
 
 import com.esotericsoftware.kryo.Kryo;
 import com.esotericsoftware.kryo.Serializer;
+import com.esotericsoftware.kryo.util.Util;
 import java.util.Map;
 import org.apache.storm.Config;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 
 public class DefaultKryoFactory implements IKryoFactory {
+    private static final Logger LOG = 
LoggerFactory.getLogger(DefaultKryoFactory.class);
 
     @Override
     public Kryo getKryo(Map<String, Object> conf) {
@@ -51,6 +55,12 @@ public class DefaultKryoFactory implements IKryoFactory {
         @Override
         public Serializer getDefaultSerializer(Class type) {
             if (override) {
+                LOG.warn("Class is not registered: {}\n"
+                        + "Note: To register this class use: 
kryo.register({});\n"
+                        + "Falling back to java serialization.",
+                        Util.className(type), Util.className(type)
+                );
+
                 return new SerializableSerializer();
             } else {
                 return super.getDefaultSerializer(type);