인프런 커뮤니티 질문&답변

코드몽키님의 프로필 이미지
코드몽키

작성한 질문수

15일간의 빅데이터 파일럿 프로젝트

6.적재 파일럿 실행 4단계 - 적재 기능 테스트

tail -f flume~ 오류

작성

·

402

0

  • [root@server02 flume-ng]# tail -f flume-cmf-flume-AGENT-server02.hadoop.com.log value.serializer = class org.apache.kafka.common.serialization.ByteArray                  Serializer
  • INFO org.eclipse.jetty.server.Server: jetty-9.3.25.v2018                  0904, build timestamp: 2018-09-05T06:11:46+09:00, git hash: 3ce520221d0240229c86                  2b122d2b06c12a625732
  • INFO org.eclipse.jetty.server.AbstractConnector: Started                   ServerConnector@470d2611{HTTP/1.1,[http/1.1]}{0.0.0.0:41414}
  • INFO org.eclipse.jetty.server.Server: Started @5342ms
  • INFO org.apache.kafka.common.utils.AppInfoParser: Kafka                   version: 2.2.1-cdh6.3.2
  • INFO org.apache.kafka.common.utils.AppInfoParser: Kafka                   commitId: null
  • INFO org.apache.flume.instrumentation.MonitoredCounterGr                  oup: Monitored counter group for type: SINK, name: DriverCarInfo_KafkaSink: Succ                  essfully registered new MBean.
  • INFO org.apache.flume.instrumentation.MonitoredCounterGr                  oup: Component type: SINK, name: DriverCarInfo_KafkaSink started
  • INFO org.apache.kafka.clients.Metadata: Cluster ID: lhtw                  uwZxS2CI85Bn_v6BuQ

 

 

 

재시작 했는데도 안되네요 ㅠㅠ 

문제점이 무엇일까요?

답변 3

1

Big.D님의 프로필 이미지
Big.D
지식공유자

안녕하세요! 코드몽키님!

올려주신 Flume의 로그 내용이나, Cloudera Manager의 상태 정보로만 봤을땐 특이 사항이 없어 보입니다.

문제의 상황과 오류 메세지를 좀더 상세하게 올려 주시고요..

무엇인 안되는지를 좀더 구체적으로 설명해 주세요~

- 빅디 드림

 

0

코드몽키님의 프로필 이미지
코드몽키
질문자

해결했습니다 빅디님 감사합니다 :)

0

코드몽키님의 프로필 이미지
코드몽키
질문자

11:30 쯤 영상에서 위와 같이 tail -f flume-cmf-flume~~~ 치면 flume.sink.hdfs.BucketWriter: Creating ~~ 설명하시는데, 저한테는 저부분이 뜨질 안항서 질문드렸습니다     .tmp 파일도 안만들어져서요

Big.D님의 프로필 이미지
Big.D
지식공유자

아~ 네!!  상황파악 됐습니다. ㅎㅎ

음...보여주신 로그상에서 특별히 에러가 없는 것으로 봤을땐..

플럼의 파일 수집 이벤트(SpoolDir)가 작동하지 않은것 같습니다.

우선 스마트카 시뮬레이터가 파일을 생성 하는 위치와, 플럼이 이 파일을 읽어 들이는 위치가 달라서 다소 헷갈릴 수 있는데요. 아래와 같습니다.

1. 로그시뮬레이터가 스마트카 상태파일을 생성하는 위치: /home/pilot-pjt/working/SmartCar/

2. 플럼이 스마트카 상태파일을 읽어 들이는 위치 : /home/pilot-pjt/working/car-batch-log/

이때 1번에 생성된 파일을 2번으로 이동 시켜줘야,  플럼의 파일 이벤트가 작동해서 해당 파일을 읽어 들이는데요..이를위해 아래 명령으로 1번에 생긴 파일을 2번으로 이동 시키는 명령이 잘 실행 됐었는지도 확인해 봐야 합니다.

$ mv /home/pilot-pjt/working/SmartCar/SmartCarStatusInfo_20160101.txt /home/pilot-pjt/working/car-batch-log/

해당 강의 내용중 "SmartCar 로그시뮬레이터 작동" 과 "플럼 이벤트 작동" 부분을 한번더 꼼꼼히 보시면서 실습해 보시기 바랍니다.

추가로 플럼의 Conf 파일 수정 사항이 미적용 되어서, 파일 수집 이벤트가 발생하지 않았을 수도 있습니다.  "CM Home > Flume > 재시작"도 꼭 해보시기 바랍니다.

- 빅디 드림

코드몽키님의 프로필 이미지
코드몽키

작성한 질문수

질문하기