diff --git a/flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala b/flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala
index 93c4d3023caa5..ebc1c27c8ea1f 100644
--- a/flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala
+++ b/flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala
@@ -447,18 +447,15 @@ class PatternStream[T](jPatternStream: JPatternStream[T]) {
   }
 
  def sideOutputLateData(lateDataOutputTag: OutputTag[T]): PatternStream[T] = {
-   jPatternStream.sideOutputLateData(lateDataOutputTag)
-   this
- }
+    PatternStream[T](jPatternStream.sideOutputLateData(lateDataOutputTag))
+  }
 
   def inProcessingTime(): PatternStream[T] = {
-    jPatternStream.inProcessingTime()
-    this
+    PatternStream[T](jPatternStream.inProcessingTime())
   }
 
   def inEventTime(): PatternStream[T] = {
-    jPatternStream.inEventTime()
-    this
+    PatternStream[T](jPatternStream.inEventTime())
   }
 }