Skip to content
This repository was archived by the owner on Dec 14, 2022. It is now read-only.

Commit d0acf6b

Browse files
author
zouyunhe
committed
check style
1 parent e5c9b97 commit d0acf6b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSource.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -163,8 +163,8 @@ public class FlinkPulsarSource<T> extends RichParallelSourceFunction<T>
163163
private String externalSubscriptionName;
164164

165165
/**
166-
* The subscription position to use when subscription does not exist; Only relevant when startup mode is {@link
167-
* StartupMode#EXTERNAL_SUBSCRIPTION}.
166+
* The subscription position to use when subscription does not exist; Only relevant when startup
167+
* mode is {@link StartupMode#EXTERNAL_SUBSCRIPTION}.
168168
*/
169169
private MessageId subscriptionPosition;
170170

0 commit comments

Comments
 (0)