[storm] branch master updated: [STORM-3735] Register NodeInfo class to Kyro (#3372)

[et...@apache.org]

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

ethanli 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 b23e691  [STORM-3735] Register NodeInfo class to Kyro (#3372)
b23e691 is described below

commit b23e69170f94f8f1265172bd0609c4f3471cf490
Author: Meng (Ethan) Li <et...@gmail.com>
AuthorDate: Tue Jan 19 09:47:47 2021 -0600

    [STORM-3735] Register NodeInfo class to Kyro (#3372)
---
 .../src/jvm/org/apache/storm/serialization/SerializationFactory.java    | 2 ++
 1 file changed, 2 insertions(+)

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.ServiceLoader;
 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 @@ public class SerializationFactory {
         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) {