flume

0열

1답변

Httfs로 Http 소스 flume이 작동하지 않습니다. 게시물 요청의 상태 코드는 400입니까?

flume 에이전트에 대한 http-source를 설정하는 동안 포트 8989를 사용했습니다. 에이전트가 잘 시작되지만 POST 요청을 만들 때 status_code 400을 얻고 status_code 요청이 400이됩니다. 누군가 제가 지적했습니다. 게시물 요청에서 잘못된 데이터를 전달합니다. 어떻게해야 데이터 유형을 전달해야하는지 알 수 있습니다. 또한

0열

1답변

Flume 1.7 & Kafka - 주제의 시작 부분에서 어떻게 다시 시작 하시겠습니까?

Flume 1.7 Kafka source을 사용하여 Apache Kafka에서 데이터를 AbstractSink으로 가져옵니다. : 과거에는 지금 ./kafka-consumer-groups.sh --delete을 시도하는 다음과 같은 오류 메시지를 제공, ./kafka-consumer-groups.sh --delete하지만 수로 1.7 (분명히) 이후 "새로

1열

1답변

수로 구성

나는 수로를 구성하려고 내가이 링크를 다음입니다 : https://www.eduonix.com/blog/bigdata-and-hadoop/flume-installation-and-streaming-twitter-data-using-flume/ 그러나 6 단계에서 나는 다음과 같은 명령을 실행 sudo mv Downloads/flume-sources-1.0-

0열

1답변

flush 에이전트 (syslogs 소스 및 hbase 싱크 포함)

나는 flume을 syslogs 소스 및 hbase 싱크와 함께 사용하려고합니다. 내가 flume agent를 실행할 때 나는이 오류를 얻는다 : Failed to start agent because dependencies were not found in classpath. Error follows. java.lang.NoClassDefFoundError:

0열

1답변

AsyncHBaseSink와 HbaseSink 사이의 차이점

flume Hbase을위한 두 개의 싱크가 있다는 것을 읽었습니다. 그래서 그것들 (AsyncHBaseSink와 HbaseSink) 사이의 차이점은 무엇이고 언제 사용합니까?

0열

1답변

flush를 사용하여 csv 파일을 avro로 변환하고

큰 데이터를 처음 사용하고 Flume을 사용하여 csv 파일을 HDFS로 전송하는 작업이 있지만이 CSV를 avro로 변환해야합니다. 내가 사용 수로 구성 다음과 같은 것을하려고 노력 : a1.channels = dataChannel a1.sources = dataSource a1.sinks = dataSink a1.channels.dataChann

0열

1답변

flume 구성의 24 단계

Flume 구성으로 거의 완료되었지만 24 단계에서 스택을 작성했습니다. 설명한대로 시도했지만 동일한 결과를 얻을 수 없습니다. 누군가가 제발 도와 드릴까요 : 오픈하여 VM에서 Mozilla 브라우저 및 작성있어 FlumeData 파일에 클릭 HDFS에/사용자/수로/트위터로 이동 ? https://www.eduonix.com/blog/bigdata-and

0열

1답변

Flume Json Hive 싱크

나는 flume을 json 레코드로 하이브에 삽입하려고했는데 테이블을 만들었습니다. 다음과 같이 싱크가 구성 - agent1.sinks.sk-json.type = hive agent1.sinks.sk-json.hive.metastore = dt-s39.campus.ad.bgu.ac.il:3306 agent1.sinks.sk-json.hive.databa

1열

1답변

flume이 파이썬 소켓이나 텔넷으로 작업하는 동안 이벤트를 올바르게 가져올 수 없음

나는 Flume을 Python 스크립트로 로그를 수집하기 위해 netcat 소스로 Flume을 설정하는 사용자 가이드를 따르기 위해 telnet과 nc 테스트를 사용한다. 잘 작동한다. 내 설정 코드 : a1.sources = r1 a1.sinks = k1 a1.channels = c1 Describe/configure the source a1.so

0열

1답변

트윗

처리되지 않은 오류가 발생 추출하는 동안 수로에서 오류를 처리되지 않은 해결하는 방법 -. org.apache.flume.node.PollingPropertiesFileConfigurationProviders $ FileWatchRunnable.run (PollingPropertiesFileConfigurationProvider.java 나는 수로를 사용하