1 |
1
데이터 스트림 분산 병렬 처리 서비스를 구성하는 복수의 태스크들을 등록하는 서비스 관리부;상기 복수의 태스크들의 부하 정보 및 상기 데이터 스트림 분산 병렬 처리 서비스를 제공하는 클러스터를 구성하는 복수의 노드들의 부하 정보를 수집하는 서비스 품질 모니터링부; 및상기 복수의 태스크들의 부하 정보 및 상기 복수의 노드들의 부하 정보에 근거하여 상기 복수의 태스크들을 상기 복수의 노드들에 분산 배치하는 스케쥴링부를 포함하고,상기 복수의 태스크들의 부하 정보는,태스크 중앙처리장치(Central Processing Unit; CPU) 부하 및 태스크 간 입출력 부하와 관련한 정보를 포함하고,상기 스케쥴링부는상기 복수의 노드들의 부하 정보에 포함된 상기 복수의 노드들의 부하 상태에 비해 상기 태스크 간 입출력 부하가 높아서 태스크 간 입출력 과부하가 발생한 경우, 상기 태스크 간 입출력 과부하를 유발하는 태스크들을 입출력 과부하 태스크들로 선정하고, 상기 복수의 태스크들의 부하 정보 및 상기 태스크 간 입출력 부하에 근거하여 상기 입출력 과부하 태스크들을 재배치하고, 상기 입출력 과부하 태스크들을 단일 노드에 단일 프로세스의 별도 쓰레드(thread)로 배치하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 장치
|
2 |
2
삭제
|
3 |
3
삭제
|
4 |
4
삭제
|
5 |
5
청구항 1에 있어서,상기 단일 프로세스의 별도 쓰레드로 배치된 상기 입출력 과부하 태스크들은,선행 태스크와 후행 태스크가 공유 메모리 버퍼를 두고 상기 공유 메모리 버퍼를 통해 직접 통신하는 메모리 통신으로 데이터 통신을 수행하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 장치
|
6 |
6
청구항 5에 있어서,상기 복수의 태스크들 중 상기 단일 프로세스의 별도 쓰레드로 배치된 상기 입출력 과부하 태스크들 이외의 태스크들은,선행 태스크와 후행 태스크가 소켓을 통하여 통신하는 네트워크 통신 또는 파일을 통하여 통신하는 파일 입출력 통신으로 데이터 통신을 수행하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 장치
|
7 |
7
청구항 1에 있어서,상기 스케쥴링부는,상기 복수의 노드들의 부하 정보에 포함된 상기 복수의 노드들의 부하 상태에 비해 상기 태스크 CPU 부하가 높아서 태스크 CPU 과부하가 발생한 경우, 상기 태스크 CPU 과부하를 유발하는 태스크들을 CPU 과부하 태스크들로 선정하고, 상기 복수의 태스크들의 부하 정보 및 상기 태스크 CPU 부하에 근거하여 상기 CPU 과부하 태스크들을 재배치하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 장치
|
8 |
8
청구항 7에 있어서,상기 스케쥴링부는,상기 복수의 노드들에 장착된 코어의 속도 및 개수를 기반으로 상기 CPU 과부하 태스크들을 별도의 노드에 별도의 프로세스로 배치하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 장치
|
9 |
9
청구항 1에 있어서,상기 서비스 품질 모니터링부는,상기 복수의 태스크들의 부하 정보 및 상기 복수의 노드들의 부하 정보에 근거하여 태스크 간 입출력 과부하 발생 여부 및 태스크 CPU 과부하 발생 여부를 포함하는 서비스 품질을 판단하고, 태스크 간 입출력 과부하 또는 태스크 CPU 과부하가 발생하여 서비스 품질이 불만족인 것으로 판단되는 경우, 상기 복수의 태스크들을 상기 복수의 노드들에 재배치하도록 재배치 요청을 상기 스케쥴링부에 송신하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 장치
|
10 |
10
청구항 9에 있어서,상기 스케쥴링부는,상기 서비스 품질 모니터링부로부터 상기 재배치 요청을 수신한 경우, 상기 태스크 간 입출력 과부하 또는 태스크 CPU 과부하의 발생으로 인한 과부하 오버헤드(overhead)와 상기 복수의 태스크들의 재배치로 인한 재배치 오버헤드를 비교하여, 상기 재배치 오버헤드에 대한 상기 과부하 오버헤드의 비율이 소정의 설정값을 초과하는 경우에만 재배치를 수행하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 장치
|
11 |
11
서비스 관리부가 데이터 스트림 분산 병렬 처리 서비스를 구성하는 복수의 태스크들을 등록하는 단계;서비스 품질 모니터링부가 상기 복수의 태스크들의 부하 정보 및 상기 데이터 스트림 분산 병렬 처리 서비스를 제공하는 클러스터를 구성하는 복수의 노드들의 부하 정보를 수집하는 단계; 및스케쥴링부가 상기 복수의 태스크들의 부하 정보 및 상기 복수의 노드들의 부하 정보에 근거하여 상기 복수의 태스크들을 상기 복수의 노드들에 분산 배치하는 단계를 포함하고,상기 복수의 태스크들의 부하 정보는태스크 중앙처리장치(Central Processing Unit; CPU) 부하 및 태스크 간 입출력 부하와 관련한 정보를 포함하고,상기 분산 배치하는 단계는상기 복수의 노드들의 부하 정보에 포함된 상기 복수의 노드들의 부하 상태에 비해 상기 태스크 간 입출력 부하가 높아서 태스크 간 입출력 과부하가 발생한 경우, 상기 스케쥴링부가 상기 태스크 간 입출력 과부하를 유발하는 태스크들을 입출력 과부하 태스크들로 선정하는 단계; 및상기 스케쥴링부가 상기 복수의 태스크들의 부하 정보 및 상기 태스크 간 입출력 부하에 근거하여 상기 입출력 과부하 태스크들을 재배치하는 단계를 포함하고,상기 입출력 과부하 태스크들을 재배치하는 단계는상기 스케쥴링부가 상기 입출력 과부하 태스크들을 단일 노드에 단일 프로세스의 별도 쓰레드(thread)로 배치하는 단계를 포함하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 방법
|
12 |
12
삭제
|
13 |
13
삭제
|
14 |
14
삭제
|
15 |
15
청구항 11에 있어서,상기 단일 프로세스의 별도 쓰레드로 배치된 상기 입출력 과부하 태스크들이 선행 태스크와 후행 태스크가 공유 메모리 버퍼를 두고 상기 공유 메모리 버퍼를 통해 직접 통신하는 메모리 통신으로 데이터 통신을 수행하는 단계를 더 포함하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 방법
|
16 |
16
청구항 15에 있어서,상기 복수의 태스크들 중 상기 단일 프로세스의 별도 쓰레드로 배치된 상기 입출력 과부하 태스크들 이외의 태스크들이 선행 태스크와 후행 태스크가 소켓을 통하여 통신하는 네트워크 통신 또는 파일을 통하여 통신하는 파일 입출력 통신으로 데이터 통신을 수행하는 단계를 더 포함하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 방법
|
17 |
17
청구항 11에 있어서,상기 분산 배치하는 단계는상기 복수의 노드들의 부하 정보에 포함된 상기 복수의 노드들의 부하 상태에 비해 상기 태스크 CPU 부하가 높아서 태스크 CPU 과부하가 발생한 경우, 상기 스케쥴링부가 상기 태스크 CPU 과부하를 유발하는 태스크들을 CPU 과부하 태스크들로 선정하는 단계; 및상기 스케쥴링부가 상기 복수의 태스크들의 부하 정보 및 상기 태스크 CPU 부하에 근거하여 상기 CPU 과부하 태스크들을 재배치하는 단계를 더 포함하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 방법
|
18 |
18
청구항 17에 있어서,상기 CPU 과부하 태스크들을 재배치하는 단계는,상기 스케쥴링부가, 상기 복수의 노드들에 장착된 코어의 속도 및 개수를 기반으로 상기 CPU 과부하 태스크들을 별도의 노드에 별도의 프로세스로 배치하는 단계를 포함하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 방법
|
19 |
19
청구항 11에 있어서,상기 부하 정보를 수집하는 단계는상기 서비스 품질 모니터링부가 상기 복수의 태스크들의 부하 정보 및 상기 복수의 노드들의 부하 정보에 근거하여 태스크 간 입출력 과부하 발생 여부 및 태스크 CPU 과부하 발생 여부를 포함하는 서비스 품질을 판단하는 단계; 및태스크 간 입출력 과부하 또는 태스크 CPU 과부하가 발생하여 서비스 품질이 불만족인 것으로 판단되는 경우, 상기 복수의 태스크들을 상기 복수의 노드들에 재배치하도록 재배치 요청을 상기 스케쥴링부에 송신하는 단계를 포함하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 방법
|
20 |
20
청구항 19에 있어서,상기 스케쥴링부가 상기 서비스 품질 모니터링부로부터 상기 재배치 요청을 수신한 경우, 상기 태스크 간 입출력 과부하 또는 태스크 CPU 과부하의 발생으로 인한 과부하 오버헤드(overhead)와 상기 복수의 태스크들의 재배치로 인한 재배치 오버헤드를 비교하는 단계; 및상기 스케쥴링부가 상기 재배치 오버헤드에 대한 상기 과부하 오버헤드의 비율이 소정의 설정값을 초과하는 경우에만 재배치를 수행하는 단계를 더 포함하는 것을 특징으로 하는 데이터 스트림 분산 병렬 처리 서비스 관리 방법
|