[hotfix][javadocs] Finish sentence in FlinkKafkaConsumerBase

laubersder · Nov 19, 2018 · 7be58c7 · 7be58c7
1 parent 8eb6cff
commit 7be58c7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ase/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java b/...ase/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
@@ -326,7 +326,7 @@ public FlinkKafkaConsumerBase<T> assignTimestampsAndWatermarks(AssignerWithPerio
  *
  * <p>This setting will only have effect if checkpointing is enabled for the job.
  * If checkpointing isn't enabled, only the "auto.commit.enable" (for 0.8) / "enable.auto.commit" (for 0.9+)
- * property settings will be
+ * property settings will be used.
  *
  * @return The consumer object, to allow function chaining.
  */