title: Flink CEP Event Not triggering
body: <p>I have implement the CEP Pattern in Flink which is working as expected connecting to local Kafka broker. But when i connecting to cluster based cloud kafka setup, the Flink CEP is not triggering.</p>
  <pre><code>final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
      //saves checkpoint
      env.getCheckpointConfig().enableExternalizedCheckpoints(
              CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);
      env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
  </code></pre>
  <p>I am using AscendingTimestampExtractor,</p>
  <pre><code>consumer.assignTimestampsAndWatermarks(
      new AscendingTimestampExtractor&lt;ObjectNode&gt;() {
        @Override
        public long extractAscendingTimestamp(ObjectNode objectNode) {
          long timestamp;
          Instant instant = Instant.parse(objectNode.get(&quot;value&quot;).get(&quot;timestamp&quot;).asText());
          timestamp = instant.toEpochMilli();
          return timestamp;
        }
      });
  </code></pre>
  <p>And also i am getting Warn Message that,</p>
  <blockquote>
  <p>AscendingTimestampExtractor:140 - Timestamp monotony violated: 1594017872227 &lt; 1594017873133</p>
  </blockquote>
  <p>And Also i tried using AssignerWithPeriodicWatermarks and AssignerWithPunctuatedWatermarks none of one is working</p>
  <p>I have attached Flink console screenshot where Watermark is not assigning.
  <a href="https://i.stack.imgur.com/nWs5b.png" rel="nofollow noreferrer">Updated flink console screenshot</a></p>
  <p>Could Anyone Help?</p>