diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java index e8077fa4792ec..5ab44c0199ea8 100644 --- a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java +++ b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java @@ -226,7 +226,7 @@ private void checkPatternNameUniqueness() { /** * Creates the Start {@link State} of the resulting NFA graph. * - * @param sinkState the state that Start state should point to (alwyas first state of middle states) + * @param sinkState the state that Start state should point to (always first state of middle states) * @return created state */ @SuppressWarnings("unchecked") diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java index 14c3e2d24191c..92b655e090744 100644 --- a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java +++ b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java @@ -151,7 +151,7 @@ public Pattern subtype(final Class subtypeClass) { * between first and the last event must not be longer than the window time. * * @param windowTime Time of the matching window - * @return The same pattenr operator with the new window length + * @return The same pattern operator with the new window length */ public Pattern within(Time windowTime) { if (windowTime != null) {