shell

Definition

Cluster ์ƒ์˜ ์ž„์˜์˜ host์—์„œ shell ๋ช…๋ น์„ ์‹คํ–‰ํ•œ๋‹ค. [Flow๊ตฌ์„ฑ]๋…ธ๋“œ ์ค‘ [shell]๋…ธ๋“œ๋ฅผ drag & drop ํ•œ ํ›„ Property ํ•ญ๋ชฉ์„ ์ž…๋ ฅํ•œ๋‹ค. Property ํŒจ๋„์˜ [๋”๋ณด๊ธฐ+] ๋ฒ„ํŠผ์„ ๋ˆ„๋ฅด๋ฉด ์ž…๋ ฅ๊ฐ€๋Šฅํ•œ ์ „์ฒด Property ํ•ญ๋ชฉ์„ ๋ณผ ์ˆ˜ ์žˆ๋‹ค.

Set

[setting], [scheduler], [parameter] ์„ค์ •์€ [์›Œํฌํ”Œ๋กœ์šฐ ์ƒ์„ฑ] > [์„ค์ •]์„ ์ฐธ๊ณ ํ•œ๋‹ค.

property

[Node Description] ์ž‘์„ฑ ์ค‘์ธ ๋…ธ๋“œ๋ช… ์ž…๋ ฅ

flow020

  1. prepare : ๋…ธ๋“œ ์‹คํ–‰ ๊ฒฐ๊ณผ๋ฅผ HDFS์— ์ €์žฅํ•˜๊ธฐ ์œ„ํ•ด ํŒŒ์ผ์‚ญ์ œ/ํด๋”์ƒ์„ฑ ์ž‘์—… ์„  ์ˆ˜ํ–‰(์›Œํฌํ”Œ๋กœ์šฐ ๋ฐ˜๋ณต์‹คํ–‰ ์‹œ ํ™œ์šฉ๊ฐ€๋Šฅ)
    • delete : ๋…ธ๋“œ ์‹คํ–‰ ์ „ ์‚ญ์ œํ•  ํด๋”/ํŒŒ์ผ ๊ฒฝ๋กœ
    • mkdir : ๋…ธ๋“œ ์‹คํ–‰ ์ „ ์ƒ์„ฑํ•  ํด๋” ๊ฒฝ๋กœ
  2. file : ๋…ธ๋“œ์—์„œ ์‚ฌ์šฉํ•  ๋ผ์ด๋ธŒ๋Ÿฌ๋ฆฌ ๊ฒฝ๋กœ๋ฅผ ์„ค์ •
  3. archive : archive๊ฒฝ๋กœ๋ฅผ ์„ค์ •
  4. retry : max: ์žฌ์ˆ˜ํ–‰ ํšŸ ์ˆ˜ : period: ์žฌ์ˆ˜ํ–‰ ๊ฐ„๊ฒฉ
  5. jobXml : jobxml์ž…๋ ฅ
  6. configuration : ์‹คํ–‰์— ์‚ฌ์šฉํ•  ์†์„ฑ (key, value) ์ž…๋ ฅ
  7. envVar : keyValPair ์ž…๋ ฅ
  8. captionOutput : captureOutput ์—ฌ๋ถ€ ์„ ํƒ
  9. shellCmd : shell command๋ฅผ ์ง์ ‘ ์ž…๋ ฅ
  10. argument : ์ธ์ˆ˜ ์„ค์ •
  11. forceOK : ์‹คํŒจ ์‹œ ๊ฐ•์ œ OK ์ฒ˜๋ฆฌ ์—ฌ๋ถ€

Example

ํฌ๊ธฐ๊ฐ€ 0 byte์ธ ํŒŒ์ผ์„ ๋งŒ๋“œ๋Š” ์Šคํฌ๋ฆฝํŠธ๋ฅผ [shell] ๋…ธ๋“œ์—์„œ ์‹คํ–‰ํ•œ๋‹ค.

touch /usr/local/hadoop/sample.txt
  1. [shell]๋…ธ๋“œ์—์„œ ์‹คํ–‰๋˜๋Š” shell์€ ์‚ฌ์ „์— hdfs์— ์œ„์น˜ํ•ด์•ผ ํ•˜๋ฏ€๋กœ, ์œ„ ๋‚ด์šฉ์„ ์ €์žฅ(crefile.sh) ํ›„ [HDFS๋ธŒ๋ผ์šฐ์ €] ๋˜๋Š” ํ„ฐ๋ฏธ๋„์— ์ ‘์†ํ•ด์„œ hdfs์— ์ €์žฅํ•œ๋‹ค.
  • kbtest ํด๋Ÿฌ์Šคํ„ฐ /tmp/ManSample/shell ํด๋”์— ์ €์žฅ
  1. [Flow๊ตฌ์„ฑ]๋…ธ๋“œ ์ค‘ [shell]๋…ธ๋“œ๋ฅผ drag & drop ํ•œ ํ›„ Property ํ•ญ๋ชฉ์„ ์ž…๋ ฅํ•œ๋‹ค.
  • 2.file : ์•ž์„œ ์ €์žฅํ•œ ํŒŒ์ผ์„ ์„ ํƒํ•œ๋‹ค.

flow053

  • 9.shellCmd : sheel command๋ฅผ ์ž…๋ ฅํ•œ๋‹ค. ์‹คํ–‰ ์Šคํฌ๋ฆฝํŠธ๋ฅผ hdfs์— ์ €์žฅํ–ˆ์œผ๋ฏ€๋กœ, ํŒŒ์ผ๋ช…๋งŒ ์ž…๋ ฅํ•œ๋‹ค. ์˜ค๋ฅธ์ชฝ Script Editor๋ฅผ ํŒ์—…ํ•˜์—ฌ ๋ช…๋ น์–ด๋ฅผ ์ž…๋ ฅํ•  ์ˆ˜ ์žˆ๋‹ค.

flow054

  1. ์›Œํฌํ”Œ๋กœ์šฐ ์ €์žฅ/์‹คํ–‰ ์‹œ shell์ด ์‹คํ–‰๋˜์–ด 0byte์˜ ๋นˆ ํŒŒ์ผ์ด ์ƒ์„ฑ๋œ๋‹ค.

flow055

[Note] shell ๋…ธ๋“œ ์‚ฌ์šฉ์‹œ ์œ ์˜์‚ฌํ•ญ

  1. shell ๋…ธ๋“œ ์ˆ˜ํ–‰์„ ์œ„ํ•œ shell ์Šคํฌ๋ฆฝํŠธ๋ฅผ hdfs์— ์ ์žฌํ•ด์•ผ ํ•œ๋‹ค.
  2. shell ์Šคํฌ๋ฆฝํŠธ๋Š” yarn resource manager์—์„œ randomํ•˜๊ฒŒ ์ง€์ •ํ•˜๋Š” node manager์—์„œ ์ˆ˜ํ–‰๋œ๋‹ค. hdfs์— ์ ์žฌ๋œ ํŒŒ์ผ์„ local๋กœ ๋‚ด๋ฆฌ๋Š” ๋ช…๋ น ์ˆ˜ํ–‰์‹œ ์ž‘์—…์ด ์‹คํ–‰๋˜๋Š” node manager๋ฅผ ๋จผ์ € ํ™•์ธํ•œ๋‹ค.