RegexHbaseEventSerializer

[Hadoop] Flume RegexHbaseEventSerializer Error

이슈사항Flume 1.4.1에서 Hbase로 갖고 올 경우 hbaseSink.serializer = org.apache.flume.sink.hbase.RegexHbaseEventSerializer 옵션을 사용하면 Regex로 로그를 파싱하여 가져 올 수 있다고 하였다. 허나 정규식은 전혀 먹히지 않아 소스코드 수정 후 성공하였다. RegexHbaseEventSerializer.java 소스코드를 살펴보면다음과 같이 기본 정규식이 세팅되 있다. 즉 문자의 모든 것을 가져온다는 의미인데public static final String REGEX_DEFAULT = "(.*)"; conf에서 hbaseSink.serializer.colNames = a 와 같이 컬럼을 하나만 줬을 경우에는 잘 들어간다. 이유는 위..