[FLINK-31048][Connector/Pulsar] Fix incorrect java doc in PulsarSourc…

…e and PulsarSourceBuilder. This closes apache#28
cbornet · Jun 19, 2023 · 8fbb48a · 8fbb48a
1 parent 39f93c2
commit 8fbb48a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java b/...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();
  * }</pre>

diff --git a/...or-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java b/...or-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();
  * }</pre>
  *
@@ -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();
  * }</pre>