flink-streaming

2열

1답변

IDE에서 flink를 실행 중입니다. 질의 가능한 데이터를 저장하면 예외 , 작동하지만 난 그것을 쿼리 할 때 어떻게 든, 그것은 발생되고있다 예외에 Failure(akka.actor.ActorNotFound: Actor not found for: ActorSelection[Anchor(akka.tcp://[email protected]:6123/), P

2열

1답변

Flink RabbitMQ 상관 ID

Flink에서 RabbiMQ와 함께 고 가용성을 사용하고 Correlation Ids와 Enable Checkpoint를 사용하는 방법을 이해하고 있지만 작동하지 않습니다. 내 프로듀서 코드 : connection = factory.newConnection(); Channel channel = connection.createChannel(); Stri

1열

1답변

Flink의 전역 변수

데이터 스트림의 요소를 저장하기 위해 크기 2의 FIFO 큐를 사용하고 싶습니다. 어떤 경우이든 현재 요소가 아닌 스트림에있는 이전 요소가 필요합니다. 이렇게하려면 스트림 코드 외부에서 큐를 만들고 현재 요소를 큐에 넣고 있습니다. 내 큐에 두 개의 요소가있는 경우, 나는 그것을 dequeue하고 첫 번째 요소를 사용합니다. 내가 직면 한 문제는 스트림 코

0열

1답변

방법의 나는 다른 종류의 두 <code>DataStream</code> 년대 있다고 가정 해 봅시다 하나의 파일

에 여러 개의 데이터 스트림의 쓰기? 나는 여러 가지 시도를했지만 작동하지 않는 것 같습니다. FLINK가 다음 메시지와 함께 불평 때문에 예를 들어, 난 그냥 바로 stream1.writeAsText("path/to/file.txt").setParallelism(1) stream2.writeAsText("path/to/file.txt").setParal

2열

1답변

플 링크 스트리밍 : 각 타임 윈도우의 요소 중 상위 n 개를 가져옵니다.

데이터 스트림의 튜플 (플로트, 문자열)을 정렬하고 각 타임 윈도우에 대해 3 개의 가장 큰 값 (고정)을 선택했습니다. 데이터 스트림의 윈도우 처리는 시간을 처리하고 자연 순서로 정렬하는 것입니다. FLINK 1.0.1을 사용하여, 다음 날 예상 작업 이름을 지정하지 않는 내 시도 아웃 중 하나 sortMetricStream에서 val topTasks

1열

1답변

Flink 1.x에서 EventTimeSourceFunction (Flink 0.10.x)을 대체 할 수있는 것은 무엇입니까?

Flink 0.10.1을 기반으로하는 SlidingArrivalCount.scala 예제를 Flink 1.1.1로 마이그레이션하려고합니다. 예제에서 사용 된 TaxiRideSource 데이터 스트림 소스는 org.apache.flink.streaming.api.functions.source.EventTimeSourceFunction 인터페이스를 구현하며 더

2열

1답변

Scala WindowFunction이 컴파일되지 않습니다.

저는 Apache Flink를 사용하여 프로토 타입 응용 프로그램을 작성했습니다. 이 과정에서 특정 유스 케이스에 대해 org.apache.flink.streaming.api.functions.windowingWindowFunction을 사용하기로했습니다. 그러나 apply() 함수의 본문을 작성하는 동안이 오류가 발생합니다 (아래 코드는 필자가 작성한 응

3열

1답변

체크 포인트에서 Apache Flink 작업 복원

Apache Flink + RabbitMQ 스택을 사용하고 있습니다. 세이브 포인트를 수동으로 트리거하고 작업을 복원 할 수있는 기회를 알고 있지만 문제는 성공적인 체크 포인트 이후에 Flink가 메시지를 확인한다는 것이고 세이브 포인트를 작성하고 상태를 복원하려면 마지막 성공 세이브 포인트와 마지막 성공 체크 포인트 사이의 모든 데이터가 손실됩니다 . 체

0열

1답변

Flink TimeStamp, 계산 된 필드를 스트림에 추가합니다.

저는 순서가 잘못된 스트림이 있으므로 순서를 지정하고 다음 프레임의 같은 필드로 필드 값을 합계해야합니다. 내 코드 : env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); DataStream<Message> messageswithTS = messages.assignTimestampsAndWate

1열

1답변

Apache Flink Kafka Itergration

아파치 플립 크 1.1.2와 함께 아파치 카프카 2.11-0.10.0.0을 통합하려고합니다. 나는 그것을 테스트하기 위해 scala-shell을 사용하고 있으며 다음과 같은 오류가 발생합니다. 클래스 org.apache.flink.streaming.api.checkpoint.CheckpointNotifier 내가 클래스 경로에 org.apache.flink