flink-streaming

3열

1답변

에서 데이터 스트림을 풍부하게, 나는이 사건의 무한 스트림을 풍부하게합니다. 스트림 자체는 ID 해시를 통해 병렬 처리됩니다. 모든 이벤트에 대해 외부 소스 (예 : REST, DB)에 대한 호출이있을 수 있습니다. 이 호출은 본질적으로 차단됩니다. 하나의 스트림 파티션 내에서 이벤트 순서가 유지되어야합니다. 내 생각 는 여론 조사를 각 이벤트에 대한 외부

7열

3답변

org.apache.flink.api.common.typeinfo.TypeInformation [...] 유형의 evidence 매개 변수에 대한 암시 적 값을 찾을 수 없습니다.

Apache Flink에 대한 몇 가지 유스 케이스를 작성하려고합니다. 나는 꽤 자주로 실행 한 오류가 could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[SomeType] 내 문제는 그들이 해달라고하는

4열

1답변

Apache flink에서 노드간에 데이터 집합을 공유하는 가장 좋은 방법은 무엇입니까?

i Apache Flink를 사용하여 데이터 스트림을 처리 중이며 입력 데이터를 처리하는 모든 노드간에 인덱스를 공유해야합니다. 색인은 노드에 의해 자주 업데이트됩니다. 내가 알고 싶습니다. 효율의 관점에서 방송 변수를 통해 데이터 세트를 공유하는 것이 좋습니다. 브로드 캐스트 변수가 업데이트 될 때마다 모든 노드에서 업데이트됩니까? 아니요? Apache

4열

1답변

창 기간 동안 Flink DataStream을 사용하여 평균을 계산하십시오.

Flink DataStream API를 사용하고 있습니다. 여기에서 랙을 사용할 수 있습니다. & 랙 ID별로 온도 그룹의 "평균"을 계산하고 싶습니다. 내 창 간격은 40 초입니다. & 내 창은 10 초마다 움직입니다 ... 다음은 내 코드입니다. 모든 rackID에 대해 온도는 매초마다입니다. 그러나 지금은 계산하고 싶습니다. average 온도 ::

0열

1답변

FLINK 사용자 정의 파티션 프로그램의 예를

다음과 같이 내가 해결하기 위해 노력하고 사용 사례는 다음과 같습니다 우리는 카프카에서 흐르는 데이터 스트림이이 우리는이를 포함하는 메시지/기록을 보장하고 싶습니다 특정 엔티티 값은 동일한 연산자에 의해 처리됩니다. 우리는 향후 메시지를 풍부하게 할 수 있도록이 연산자에 대한 상태를 유지하고자합니다. 그래서 예를 들면 : 모든 메시지가 인코딩 된 데이터를

0열

1답변

flink.api.table.TableException : 유형 스칼라 FLINK 표 API를 사용하려고

미안 지원되지 않습니다. flink.api.table.TableException: Type is not supported:<GenericType<java.lang.Object> 내 받는다는 종속성 : <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-scala_2.11<

2열

1답변

증거 매개 변수

나는 간단한 단어 카운트 FLINK 작업을 쓰고 있어요하지만이 오류가 계속에 대한 암시 적 가치를 찾을 수 없습니다. 이 추가 object Job { def main(args: Array[String]) { // set up the execution environment val env = StreamExecutionEnvironm

0열

1답변

Twitter Flick을 사용하여 트위터 스트림 및 쿼리로 그래프 작성

트위터 스트림을 듣고 트윗에서 원하는 데이터를 추출하여 성공했습니다. 지금은이 그래프는 시간에 걸쳐 건물을 유지 나는이 그래프를 통해 쿼리를 실행하려는 동안 (user)--[tweets]-->(tweet) (tweet)--[mentions]-->(user) (tweet)--[tagged]-->(hashtag) 처럼, 추출 된 정보와 그래프를 구축

0열

1답변

Apache Flink : "검사 점 장벽을 수신 한 결과로 검사 점을 트리거하는 중 오류가 발생했습니다."

다음과 같이 간헐적으로 예외가 발생했습니다. java.lang.RuntimeException: Error triggering a checkpoint as the result of receiving checkpoint barrier at org.apache.flink.streaming.runtime.tasks.StreamTask$2.onEvent(S

2열

1답변

Flink에서 동적으로 새 데이터 스트림 만들기

데이터베이스에서 사용할 수있는 특정 규칙에 따라 하나의 원시 데이터 스트림에서 새 데이터 스트림을 만들려고합니다. 일단 플린 크 작업을 시작한 후에 데이터베이스의 업데이트 된 항목에 따라 새로운 데이터 스트림을 작성해야한다면 어떻게 할 수 있습니까? 그래서 여기서는 Flink 작업을 다시 시작하지 않고 런타임에 동적으로 새로운 데이터 스트림을 만들고이를 실