apache-flink

1열

1답변

동일한 식별자를 가진 두 이벤트를 기반으로 정의 된 시간대에 두 개의 이벤트가 발생하는지 감지하고 싶습니다. 예를 들어, DoorEvent는 다음과 같습니다 예에서 <doorevent> <door> <id>1</id> <status>open</status> </door> <timestamp>12345679</ti

0열

1답변

JunitTest 타입의 데이터 스트림 플링 섹터가있는 경우

내 플립크 패턴의 타임 아웃이 올바르게 작동하는지 테스트 할 수 있습니다. 나는 이것에 대한 FLINK의 스펙터를 사용하고 난 다음 테스트 케이스가 : @Test public void SameDoor_TwoStatuses_OneSecondTimeoutPattern() { // Arrange long now = new Date().getT

0열

1답변

taskmanager가 Flink 클러스터에서 죽임

3 개의 노드 클러스터에서 Apache Flink 프로그램을 실행하고 있습니다. 이들 중 하나는 jobmanager 및 taskmanager로 작동합니다. 다른 두 명은 taskmanager입니다. 나는 (내가 jobmanager에 그것을 할) 나는 (프로그램의 노 실제 실행의 분 후) 다음과 같은 오류를 얻을 내 프로그램을 시작 : java.lang.Ex

1열

1답변

Flink SocketTextStream 소스를 단일 컴퓨터로 예약

나는 어떻게되는지 알아 내려고합니다 : 여러 개의 socketTextStream에서 프로그램을 읽는 중이고이 텍스트 스트림이 다른 데이터 흐름으로 유입됩니다. 일). 내가 클러스터에서 작업을 실행할 때 for(int i =0; i< hosts.length; i++) { DataStream<String> someStream = env.socketT

0열

1답변

작업 제출을 자동화하고 Apache flink에서 실행하는 방법

현재 Flink 대시 보드에서 작업 병을 업로드하는 조항이 있습니다. 이것은 수동 프로세스입니다. maven 명령을 통해이 프로세스를 자동화하는 방법이 있습니까? 아파치 빔이 플링커 러너를 가지고있는 것처럼 당신이 당신의 메이븐 프로젝트를 패키징 할 수 있고 메이븐 명령 자체를 사용하여 제출할 수있는 것과 같은 것.

2열

1답변

Flink에서 다중 KeyBy를 지원하는 방법

아래 코드 샘플에서는 모든 국가에서 직원 기록 (국가, 고용주, 이름, 연봉, 연령)의 스트림을 받고 가장 높은 급여 직원을 덤프하려고합니다. 불행히도 복수 키 BY가 작동하지 않습니다. KeyBy (고용주) 만 반영되므로 올바른 결과를 얻지 못합니다. 내가 무엇이 누락 되었습니까? StreamExecutionEnvironment env = Stream

0열

1답변

Flink 저장 점이 거부되었습니다.

사용자 정의 병렬 가능 소켓 소스를 구현 한 작업에서 저장 지점을 사용하려고합니다. Cancelling job 4c99e0220c8c4683d1287269073b5c2c with savepoint to savepoints/. java.lang.Exception: Canceling the job with ID 4c99e0220c8c4683d1287269

0열

3답변

Flink 'timeWindow'작업이 PopularPlacesFromKafka 예제 파일에 대한 출력을 생성하지 않음

샘플 파일을 얻을 때 어떤 이유로 데이터 아티산의 Flink 자습서 자료를 사용할 것입니다. PopularPlacesFromKafka.scala 출력이 표준 출력으로 보내지지 않습니다. ... // find popular places val popularSpots = rides // match ride to grid cell and event

0열

1답변

Apache Spark/Apache Flink로 스케일링

Apache Kafka에서 읽는 애플리케이션을 계획하고 (잠재적으로 시간이 많이 걸리는) 처리 후에는 데이터를 데이터베이스에 저장합니다. 내 경우는 메시지가 아니라 스트림이지만 확장성에 대한 것입니다. Spark 또는 Flink에 연결하는 것에 대해 생각하고 있지만 이러한 크기 조정 방법을 이해할 수는 없습니다. 내 앱, Spark/Flink의 일부가 읽었

0열

1답변

Flink에서 hdfs의 데이터 읽기

저는 Flink의 신입생이며 hdfs에서 데이터를 읽는 방법에 대해 궁금합니다. 아무도 내게 약간의 조언이나 간단한 예제를 줄 수 있습니까? 다들 감사 해요.