From c7e497a455fbe018be2a74add4748fc8e0e0d8a9 Mon Sep 17 00:00:00 2001 From: Weijie Guo Date: Tue, 14 Feb 2023 01:18:06 +0800 Subject: [PATCH] [FLINK-31048][Connector/Pulsar] Fix incorrect java doc in PulsarSource and PulsarSourceBuilder. --- .../apache/flink/connector/pulsar/source/PulsarSource.java | 2 +- .../flink/connector/pulsar/source/PulsarSourceBuilder.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java index c7d272bc..c038f322 100644 --- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java +++ b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java @@ -57,7 +57,7 @@ * .setServiceUrl(getServiceUrl()) * .setAdminUrl(getAdminUrl()) * .setSubscriptionName("test") - * .setDeserializationSchema(PulsarDeserializationSchema.flinkSchema(new SimpleStringSchema())) + * .setDeserializationSchema(new SimpleStringSchema()) * .setBounded(StopCursor::defaultStopCursor) * .build(); * } diff --git a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java index 80d8c30a..1c8cfbe0 100644 --- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java +++ b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java @@ -89,7 +89,7 @@ * .setAdminUrl(PULSAR_BROKER_HTTP_URL) * .setSubscriptionName("flink-source-1") * .setTopics(Arrays.asList(TOPIC1, TOPIC2)) - * .setDeserializationSchema(PulsarDeserializationSchema.flinkSchema(new SimpleStringSchema())) + * .setDeserializationSchema(new SimpleStringSchema()) * .build(); * } * @@ -118,7 +118,7 @@ * .setAdminUrl(PULSAR_BROKER_HTTP_URL) * .setSubscriptionName("flink-source-1") * .setTopics(Arrays.asList(TOPIC1, TOPIC2)) - * .setDeserializationSchema(PulsarDeserializationSchema.flinkSchema(new SimpleStringSchema())) + * .setDeserializationSchema(new SimpleStringSchema()) * .setUnboundedStopCursor(StopCursor.atEventTime(System.currentTimeMillis())) * .build(); * }