diff --git a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/MessageKeyHash.java b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/MessageKeyHash.java index bbac99e4b961d..3ad092d848a62 100644 --- a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/MessageKeyHash.java +++ b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/MessageKeyHash.java @@ -62,7 +62,7 @@ public Hash getHash() { }; private final String name; - private final InlineElement desc; + private final transient InlineElement desc; MessageKeyHash(String name, InlineElement desc) { this.name = name; diff --git a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/TopicRoutingMode.java b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/TopicRoutingMode.java index c3274354f6c28..f251f8f760f20 100644 --- a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/TopicRoutingMode.java +++ b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/TopicRoutingMode.java @@ -67,7 +67,7 @@ public enum TopicRoutingMode implements DescribedEnum { code(TopicRouter.class.getSimpleName()))); private final String name; - private final InlineElement desc; + private final transient InlineElement desc; TopicRoutingMode(String name, InlineElement desc) { this.name = name; diff --git a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/CursorVerification.java b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/CursorVerification.java index fc70bdd3a5786..d604cebe6f525 100644 --- a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/CursorVerification.java +++ b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/CursorVerification.java @@ -35,7 +35,7 @@ public enum CursorVerification implements DescribedEnum { /** Print a warn message and start consuming from the valid offset. */ WARN_ON_MISMATCH(text("Print a warn message and start consuming from the valid offset.")); - private final InlineElement desc; + private final transient InlineElement desc; CursorVerification(InlineElement desc) { this.desc = desc;