This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
commit f6ead4c4ef3c195381c7f5090764fbda881ebcc4 Author: noelo <noel.ocon...@gmail.com> AuthorDate: Thu Nov 10 12:27:55 2022 +0100 [FLINK-29860][Connectors/Pulsar] InlineElement fields should be transient (#21262) --- .../flink/connector/pulsar/sink/writer/router/MessageKeyHash.java | 2 +- .../flink/connector/pulsar/sink/writer/router/TopicRoutingMode.java | 2 +- .../apache/flink/connector/pulsar/source/config/CursorVerification.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/MessageKeyHash.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/MessageKeyHash.java index bbac99e..3ad092d 100644 --- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/MessageKeyHash.java +++ b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/MessageKeyHash.java @@ -62,7 +62,7 @@ public enum MessageKeyHash implements DescribedEnum { }; 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-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/TopicRoutingMode.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/TopicRoutingMode.java index c327435..f251f8f 100644 --- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/TopicRoutingMode.java +++ b/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-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/CursorVerification.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/CursorVerification.java index fc70bdd..d604ceb 100644 --- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/CursorVerification.java +++ b/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;