commit b23e69170f94f8f1265172bd0609c4f3471cf490
author Meng (Ethan) Li <ethanopensource@gmail.com> Tue Jan 19 09:47:47 2021 -0600
committer GitHub <noreply@github.com> Tue Jan 19 09:47:47 2021 -0600
tree be917021e8dd73ac27b6992fe6a91913d0e52932
parent af0b1fd873a4c28253811d9bc27e32c4279daddf

[STORM-3735] Register NodeInfo class to Kyro (#3372)

storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java

diff --git a/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java b/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java
index 431746f..3e7feef 100644
--- a/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java
+++ b/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java
@@ -32,6 +32,7 @@
 import java.util.TreeMap;
 import org.apache.storm.Config;
 import org.apache.storm.generated.ComponentCommon;
+import org.apache.storm.generated.NodeInfo;
 import org.apache.storm.generated.StormTopology;
 import org.apache.storm.messaging.netty.BackPressureStatus;
 import org.apache.storm.serialization.types.ArrayListSerializer;
@@ -75,6 +76,7 @@
         k.register(org.apache.storm.metric.api.IMetricsConsumer.TaskInfo.class);
         k.register(ConsList.class);
         k.register(BackPressureStatus.class);
+        k.register(NodeInfo.class);
 
         synchronized (loader) {
             for (SerializationRegister sr : loader) {