1
다른 물리적 장치가 이벤트를 보내는 유스 케이스를 구현하고 있으며 네트워크/전원 문제로 인해 플립 크 소스에서 이벤트를 수신하는 데 지연이 발생할 수 있습니다. Flink 작업 내의 연산자 중 하나는 Pattern 연산자이며 시간에 민감한 특정 패턴이 있으므로 Event 시간 특성을 사용하고 있습니다. 그러나 문제는 특정 장치의 이벤트가 예기치 않게 지연되어 이러한 이벤트가 삭제되도록하는 경우에 발생합니다 (지연 시간을 허용하도록 정적 바인딩을 실제로 정의 할 수 없기 때문에).KeyedStream (Apache Flink)에서 키당 워터 마크를 생성 할 수 있습니까?
원본 장치 ID로 키 입력 된 KeyedStream을 사용하고 있으므로 각 CEP 운영자 인스턴스 (키당 하나)가 해당 스트림 파티션의 이벤트 시간을 기준으로 시간을 진행할 수있는 방법이 있습니다. 또는 다른 말로하면, KeyedStream에서 파티션 당 워터 마크를 생성하는 방법이 있습니까?