From 0846dbc4f9b80ee2ec44868e9b878587de1a5842 Mon Sep 17 00:00:00 2001 From: noelo Date: Tue, 8 Nov 2022 15:04:22 +0100 Subject: [PATCH 1/2] fixes #FLINK-29860 Pulsar connector bug --- .../connector/pulsar/source/config/CursorVerification.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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; From d9f653d04340f81ebad79518d56c385c1ba6b289 Mon Sep 17 00:00:00 2001 From: noelo Date: Wed, 9 Nov 2022 09:42:55 +0100 Subject: [PATCH 2/2] fixes #FLINK-29860 additional updates to avoid potential issue swith other fields --- .../connector/pulsar/sink/writer/router/MessageKeyHash.java | 2 +- .../connector/pulsar/sink/writer/router/TopicRoutingMode.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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;