Skip to content

Commit f7104b3

Browse files
committed
[FLINK-37479][postgres] Fix comments missing period
1 parent b541e0e commit f7104b3

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -289,7 +289,7 @@ public PostgresSourceBuilder<T> lsnCommitCheckpointsDelay(int lsnCommitDelay) {
289289
return this;
290290
}
291291

292-
/** Whether the connector should read partitioned tables via partition root or not */
292+
/** Whether the connector should read partitioned tables via partition root or not. */
293293
public PostgresSourceBuilder<T> publishViaPartitionRoot(boolean publishViaPartitionRoot) {
294294
this.configFactory.setPublishViaPartitionRoot(publishViaPartitionRoot);
295295
return this;

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config/PostgresSourceConfigFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ public void setLsnCommitCheckpointsDelay(int lsnCommitCheckpointsDelay) {
186186
this.lsnCommitCheckpointsDelay = lsnCommitCheckpointsDelay;
187187
}
188188

189-
/** Enable include partitioned table */
189+
/** Enable include partitioned table. */
190190
public void setPublishViaPartitionRoot(boolean publishViaPartitionRoot) {
191191
this.publishViaPartitionRoot = publishViaPartitionRoot;
192192
}

0 commit comments

Comments
 (0)