flume

    0

    1답변

    간단한 다중 스레드 flume 소스를 설정하는 방법에 대한 조언을 찾고 있습니다. Reading Flume spoolDir in parallel 우리는이 : 항상 단일 스레드 될 것입니다 내 인터셉터를 테스트하기 위해 내 로컬 dev에 환경에서 SPOOLDIR 소스를 사용하고 있습니다 만, 아래 링크에서, 그것은 SPOOLDIR 소스처럼 보이는 인터셉터는

    0

    1답변

    Flume의 Http 소스는 Event 개체를 생성 할 책임이있는 처리기에 달려 있습니다. 이 처리기가 여러 스레드로 생성되는지, 들어오는 http 메시지 당 하나씩 말해 보겠습니다. 대답이 "예"이면 수영장이 있습니까? 그런 풀의 크기는 어느 정도입니까? 대답이 "아니오"이면 들어오는 http 메시지가 순차적으로 처리된다고 가정해야합니까? (나는 그렇지

    0

    1답변

    나의 요구 사항은 kafka에서 오는 데이터에 정규 표현식을 적용하는 것이다. 데이터는 다음과 같다 : abc|def|mnq|xyz abc1|def1|mnq1|xyz1 abc2|def2|mnq2|xyz2 가 나는 수로 통역원을 사용하여 첫 번째 고통에서 두 번째 단어 즉 (DEF)에 정규 표현식을 적용 할. 정규 표현식은 단어와 10 진수를 필터링

    0

    1답변

    매번 Flume을 시작할 때 Flume, Hive 및 Hadoop 사이에이 메시지가 나타납니다. 이것을 피하는 가장 좋은 방법은 무엇입니까? 나는 flume lib 디렉토리에서 하나의 jar 파일을 제거하려고했지만 다른 파일 (hive, hadoop)에 영향을 주는지는 확실하지 않습니다. Info: Sourcing environment configurati

    0

    1답변

    한 서버 (Unix Server A)에서 csv 파일을 hdfs 디렉토리로 보내려고합니다. 어떤 csv 파일을 기반으로 hdfs의 다른 디렉토리에 파일을 저장하려고합니다. 저는 kafka 제작자가 유닉스 서버 A에서 kafka로 보낼 11 개의 csv 파일을 가지고 있습니다. csv 파일의 첫 번째 요소에는 키가 포함됩니다. 첫 번째 요소를 가져 와서 카프

    0

    1답변

    flume, hadoop 및 hive를 사용하여 트위터 정서 분석을하고 있습니다. 이 명령을 사용하여 하이브와 테이블을 생성 한 후 : hive -f tweets.sql 을이 오류가 얻을 : FAILED: SemanticException Line 3:17 Invalid path ''data/dictionary/dictionary.tsv'': No fil

    0

    1답변

    로그 집계를 위해 Hadoop에서 POC를 수행하려고합니다. 적어도 100 개의 사이트를 호스팅하는 여러 IIS 서버가 있습니다. HDFS로 지속적으로 로그를 스트리밍하고 추가 분석을 위해 Hive에 데이터를 파싱하고 저장하려고합니다. 1) 아파치 카프카 올바른 선택 또는 Apache 수로 2) 스트리밍 후 더 나은 제안에 도움이 종류의 또한 정보하시기 바

    0

    1답변

    플랫 파일을 HDFS에 업로드하는 데 flume이 시간이 걸리는 이유를 확인하는 데 도움이 필요합니다. 나는 단지 하나의 파일 (10MB 크기)을 업로드하려했지만, 17 시간은 여전히 ​​".tmp"로 업로드 중입니다. 내가 로그 세부 사항을 선택하면이 채널에 갇혀있는 것처럼, 그것은 보인다 년 11 월 10 일 X : XX : XX.XXX PM 정보 or

    1

    2답변

    Apache Flume을 다운로드하여 압축을 풉니 다. 실행할 준비가되었는지 어떻게 확인할 수 있습니까?

    0

    1답변

    CDH5가 설치된 AWS EC2 시스템 (RedHat)에서 Flume 에이전트를 시작하려고합니다. 내가 무슨해야합니까 ... 내가 CDH5 가이드를 확인하고는이 에이전트를 시작하는 방법 말한다 -bash: /etc/init.d/flume-ng-agent: No such file or directory : 나는 명령을 사용합니다 sudo /etc/init