flink-cep

0열

1답변

한 번에 하나의 키에 대해 단일 패턴을 사용할 수 있습니까? 예 : 나는 1 분 안에 어떤 조건을 만족시키는 5 가지 이벤트를 얻었는지 확인하고 최소 10 분의 이벤트를 얻으면 2 개의 경고를 얻어야하지만 6 개의 경고를 얻고 싶습니다. 모든 이벤트가 새로운 패턴을 유발하기 때문입니다. 한 번에 하나의 패턴 인스턴스를 키로 사용할 수 있습니까?

0열

1답변

Flink 1.3.2에서 카운터를 추가 할 수 없습니다.

Flink에서 카운터를 추가하려고 시도한 것은 here입니다.하지만 counter.inc()는 Integer 대신 void를 반환합니다. 내 메트릭에 대한 코드는 private static class myMetric extends RichMapFunction<String,Integer> { private Counter counter ;

0열

1답변

jar 파일을 제출할 때 Flink 작업을 실행할 수 없지만 Intellij에서 달리 실행하는 프로그램

My Flink 프로그램이 IntellijIdea에서 성공적으로 실행되지만 해당 프로그램의 jar 파일을 jar 파일로 제출하면 다음 오류가 표시됩니다. ava.lang.RuntimeException: Could not look up the main(String[]) method from the class org.carleton.cep.monitoring.

0열

1답변

Flink CEP의 시퀀스 일치 의미 체계

Apache JIRA에 문제가 있습니다 : https://issues.apache.org/jira/browse/FLINK-3703. 일치하는 순서 후에 계속해야 매칭 알고리즘이 발견 된 곳은 정의 할 수 있으며, 행동의 세 가지 유형이 있습니다 : from first - (즉 현재 동작입니다) after first 미래 일치하는 모든 이벤트를 유지 계속이

0열

3답변

Flink 실행 계획 UI에 표시 할 연산자, 소스, 싱크 및 패턴 이름 지정

운영자와 소스에 이름을 지정하고 싶습니다. 의는 예를 들어 이 나는 형태 FLINK 대시 보드를 촬영 한 것으로, 실행 계획의 스크린 샷이다 보자. 여기에 나는 DataStreams의 2 소스를 가지고 있고 그들과 합류하고있다. 제 질문은 이러한 소스를 EcgStream 및 Sp02 Stream과 같이 이름을 짓고 Join1 등으로 명명 할 수 있습니까

0열

1답변

Flink에서 2 개 이상의 스트림에 합류하고 합류하지 않고 2 개 이상의 스트림에 CEP를 적용하십시오.

질문 1 : 여러 센서 [예를 들어 8 센서]의 데이터를 통합해야하는 경우 시나리오를 진행하고 있습니다. 그들을 나무 형태로 합치십시오. 예를 들어 [s1, s2, s3 s4]를 결합하여 스트림 A를 만들고 [s5, s6, s7 및 s8]을 만들어 스트림 B를 만든 다음 스트림 A와 B에서 CEP를 수행합니다. 어떻게 할 수 있습니까? 질문 # 2 : 여러

0열

1답변

Apache Flink : 소스에서 다른 데이터 스트림으로 패턴을 적용하는 방법은 무엇입니까?

이벤트의 데이터 스트림과 패턴의 다른 데이터 스트림이 있습니다. 패턴은 런타임에 사용자가 제공하며 카프카 (Kafka) 주제를 통해 올 필요가 있습니다. Flink-CEP를 사용하여 각 패턴을 이벤트 스트림에 적용해야합니다. 미리 패턴을 모를 때 DataStream에서 PatternStream을 가져 오는 방법이 있습니까?

2열

1답변

1.4 아파치 FLINK에 foldLeft 연산자 상당 다음 윈도우 다음</p>가 <p>집계 동작의 출력을 집계 keyBy I는 다음의 데이터 스트림 이 사용 아파치 FLINK 1.4 시작 같은 스트림을 설정 한 데이터 스트림

있는가 AggregateResult 객체 그래서 끝나는 스트림은 SingleOutputStreamOperator 유형입니다. 내가하고 싶은 것은 scala foldLeft와 같습니다. 해당 기능을 제공하는 운영자가 있습니까? 감사

1열

1답변

KeyedStream (Apache Flink)에서 키당 워터 마크를 생성 할 수 있습니까?

다른 물리적 장치가 이벤트를 보내는 유스 케이스를 구현하고 있으며 네트워크/전원 문제로 인해 플립 크 소스에서 이벤트를 수신하는 데 지연이 발생할 수 있습니다. Flink 작업 내의 연산자 중 하나는 Pattern 연산자이며 시간에 민감한 특정 패턴이 있으므로 Event 시간 특성을 사용하고 있습니다. 그러나 문제는 특정 장치의 이벤트가 예기치 않게 지연되

0열

2답변

FLINK에서 수퍼 사이즈 창을 처리하는 방법은 무엇입니까?

지난 3 개월 동안 다른 사람의 작업을 통합해야한다는 요구 사항이 있습니다. 그런 다음 결과를 ML 모델에 넣어 이상한 부분을 얻습니다. 시스템의 거대한 흐름을 고려하면 매우 큰 창이됩니다. 이 시나리오를 어떻게 처리 할 수 있습니까?