메뉴 건너뛰기

Cloudera, BigData, Semantic IoT, Hadoop, NoSQL

Cloudera CDH/CDP 및 Hadoop EcoSystem, Semantic IoT등의 개발/운영 기술을 정리합니다. gooper@gooper.com로 문의 주세요.


1. 일반 사용자의 Impala Memory 리소스 사용 제약을 위하여 Impala Admission Control 설정 방법

2. 쿼리 수행시 메모리 판단 기준

  2.1) Impala Admission Control에서 설정 가능한 항목 확인

   > Max Memory Limit : 쿼리 실행계획의 "Per-Host Resou rce Estimates" 값으로 체크되어 배제, impalad프로세스에 대한 전체 제한을 설정

   > Maximum Query Memory Limit : 쿼리 실행계획의 "M ax Per-Host Resource Reservation" 값으로 필요 메모리 최소 값체크, 각 호스트의 쿼리당 메모리로 체크

  2.2) Maximum Query Memory Limit 설정에서 쿼리별 필요한 최소 메모리 계산 방법

   > 필요한 최소메모리(A)가 구하고자 하는 값의 100%, Max Per-Host Resource Reservation(B)가 80%, 나머지 20%(20%가 32보다 작으면 32M)

   > A(100%)=B(80%)+Max(32M,(A의 20%))

  2.3) Maximum Query Memory Limit 값 설정을 위한 참조 할 수 있는 메모리 값

   > 참조값1)쿼리 실행계획의 "Max Per-Host Resource Reservation" 값으로 최소 메모리값을 계산하여 참조

    => Impala 데몬 호스트에 필요한 쿼리당 "최소 메모리"입니다.

    => 최소 메모리값을 구하여 설정하면 쿼리는 실행 되지만, 추가로 필요한 메모리양 만큼 디스크를 사용(spill)하여 성능이 저하 될 수 있습니다.

    => Maximum Query Memory Limit 설정값이 "최소 메모리" 값보다 작으면 쿼리는 실패합니다.

   > 참조값2)쿼리 프로파일의 "per Node Peak Memory Usage"값을 참조

    => 각 impala 데몬 호스트에서 사용되는 쿼리당의 "최대 메모리" 사용량입니다.

    => CM > Impala > Queries 에서 "Per Node Peak Memory Usage" 로 확인 가능 합니다.

    => CM > Charts > Chart Builder 에서 select memory_per_node_peak from IMPALA_QUERIES where service_name="impala" 쿼리로도 확인 가능 합니다.

3. 다음과 같이 쿼리 수행시 판단하면 된다. 

  3.1) Impala Admission Control > "Maximum Query Memory Limit" 항목을 이용 하여 Impala Memory 리소스 사용 제약

  3.2) "per Node Peak Memory Usage"값을 참고 하여 Maximum Query Memory Limit 값을 설정

    (각 호스트에서 쿼리에 필요 할 수 있는 "최대 메모리" 사용량으로 설정합니다.)

번호 제목 날짜 조회 수
501 룰에 매칭되면 발생되는 엑티베이션 객체에 대한 작업(이전값 혹은 현재값)을 처리하는 클래스 파일 2016.07.21 346
500 커리 변경 이벤트를 처리하기 위한 구현클래스 2016.07.21 596
499 워킹 메모리에 대한 정보를 처리하는 클래스 파일 2016.07.21 442
498 drools에서 drl관련 로그를 기록하기 위한 클래스 파일 2016.07.21 394
497 ServerInfo객체파일 2016.07.21 151
496 drools를 이용한 로그,rule matching등의 테스트 java프로그램 file 2016.07.21 237
495 거침없이 배우는 Drools 책의 샘플소스 file 2016.07.22 1369
494 슬라이딩 윈도우 예제 2016.07.28 190
493 Journal Storage Directory /data/hadoop/journal/data/mycluster not formatted 오류시 조치사항 2016.07.29 1603
492 hadoop클러스터를 구성하던 서버중 HA를 담당하는 서버의 hostname등이 변경되어 문제가 발생했을때 조치사항 2016.07.29 408
491 start-all.sh로 spark데몬 기동시 "JAVA_HOME is not set"오류 발생시 조치사항 2016.08.01 318
490 bin/start-hbase.sh실행시 org.apache.hadoop.hbase.util.FileSystemVersionException: HBase file layout needs to be upgraded오류가 발생하면 조치사항 2016.08.01 435
489 kafkaWordCount.scala의 producer와 consumer 클래스를 이용하여 kafka를 이용한 word count 테스트 하기 2016.08.02 275
488 build할때 unmappable character for encoding MS949 에러 발생시 조치사항 2016.08.03 421
487 [SBT] project.sbt에 libraryDependencies에 필요한 jar를 지정했으나 sbt compile할때 클래스를 못찾는 오류가 발생했을때 조치사항 2016.08.03 160
486 [SBT] SBT 사용법 정리(링크) 2016.08.04 959
485 [SBT] assembly시 "[error] deduplicate: different file contents found in the following:"오류 발생시 조치사항 2016.08.04 737
484 gradle을 이용하여 jar파일 생성시 provided속성을 지정할 수 있게 설정하는 방법 2016.08.09 361
483 로컬의 라이브러리파일들을 dependency에 포함시키는 방법 2016.08.09 321
482 [Elephas] Jena Elephas를 이용하여 Spark에서 rdfTriples의 RDD를 만들고 RDD관련 작업하는 샘플소스 2016.08.10 203
위로