csv - Spark RDD External Storage -

-

i have written python code sum.py on summing numbers each csv file in directory data. going use apache-spark on amazon web service (aws), parallelize summation process each csv file. have done following steps:

  1. i've created 1 master , 2 slave nodes on aws.
  2. i used bash command $ scp -r -i my-key-pair.pem my_dir root@host_name upload directory my_dir onto aws cluster master node. folder my_dir contains 2 sub-directories: code , data, in which, code contains python code sum.py, , data contains csv files.
  3. i've login aws master node, , there used bash command $ ./spark/copy-dir /my_dir/code/ send code directory code contains sum.py slave nodes.
  4. on aws master node, i've put directory data containing csv files hdfs using $ ./ephemeral-hdfs/bin/hadoop fs -put /root/my_dir/data/.

now when submit application on aws master node: $ ./spark-submit ~/my_dir/code/sum.py, shows error worker node cannot find csv files. however, after send data directory data slave nodes using command copy-dir, works perfectly.

so confused problem. far know, driver program on master node loads csv files, creates rdd , sends separate tasks rdd each of slave nodes. means slave nodes don't need know original csv files, receive rdd master node. if true, why should send csv files each of slave node? also, if send csv files slave nodes, external disk storage on slave nodes gonna used. mean apache-spark costly tool parallel computing? appreciate if helps me on these 2 questions.

yes, have make data available nodes. however, each node try best load data concerned (its partition), , can tune level of parallelism best fit task. there many ways make data available nodes besides copying on each node's file system. consider using distributed file system, hdfs, or hosting files in accessible location each node, includes s3 or file server.


Comments

Post a Comment

Popular posts from this blog

Upgrade php version of xampp not success -

-
today decided upgrade xampp new php version (5.6.11). have downloaded , configured based on google said. after resetting server, runs successfully. when check xampp's phpinfo, has not been updated. screenshot what have missed? back htdocs files , database. download xampp . uninstall xampp control panel. manually remove xampp folder partition. install back problem solved
Read more

c - Bitwise operation with (signed) enum value -

-
i using enumerator values flags: typedef enum { = 0x00, b = 0x01u, // u has no influence, expected c = 0x02u, // u has no influence, expected ... } enum_name; volatile unsigned char* reg = someaddress; *reg |= b; according misra-c:2004 bitwise operations shall not done signed type. unfortunately, compiler iar use signed int (or short or char) underlying type of enums, , option can find relates size, not signedness ("--enum-is-int"). according iar c/c++ development guide arm , pages 169 , 211, can define type of enum s if enable iar language extensions ( -e command-line option, or project > options > c/c++ compiler > language > allow iar extensions in ide). in particular, should define "sentinel" value, make sure compiler chooses correct type. prefers signed types, , uses smallest possible integer type, sentinel should largest positive integer corresponding unsigned integer type can describe. example, typedef enum ...
Read more

xslt - Unnest parent nodes by child node -

-
in xml there items 0-n attributes , item should copied each attribute new item 1 attribute. given xml this: <?xml version="1.0" encoding="utf-8" ?> <items> <item> <name>a</name> <attributes> <attribute> <key>attribute1</key> <value>1</value> </attribute> </attributes> </item> <item> <name>b</name> </item> <item> <name>c</name> <attributes> <attribute> <key>attribute1</key> <value>5</value> </attribute> <attribute> <key>attribute2</key> <value>2</value> </attribute> <attribute> <key>attri...
Read more