I am using cloud Dataproc as a cloud service for my research. Running Hadoop and spark job on this platform(cloud) is a bit slower than that of running the same job on a lower capacity virtual machine. I am running my Hadoop job on 3-node cluster(each with 7.5gb RAM and 50GB disk) on the cloud which took 4min49sec, while the same job took 3min20sec on the single node virtual machine(my pc) having 3gb RAM and 27GB disk. Why is the result slower in the cloud with multi-node clustering than on normal pc?
Why is the Hadoop job slower in cloud (with multi-node clustering) than on normal pc?
264 Views Asked by santobedi At
2
There are 2 best solutions below
0
kf2
On
to be a bit more detailed here the numbers/facts which are interesting to find out the reason for the "slower" cloud environment:
job type &size:
- size of data 1mb or 1TB
- xml , parquet ....
- what kind of process (e.g wordcount, format change, ml,....) and of course the options (executors and drivers ) for your spark-submit or spark-shell
Hadoop Configuration:
- do you use a distribution (hortonworks or cloudera?)
- spark standalone or in yarn mode
- how are nodemangers configured
Related Questions in HADOOP
- pcap to Avro on Hadoop
- schedule and automate sqoop import/export tasks
- How to diagnose Kafka topics failing globally to be found
- Only 32 bit available in Oracle VM - Hadoop Installation
- Using HDFS with Apache Spark on Amazon EC2
- How to get raw hadoop metrics
- How to output multiple values with the same key in reducer?
- Loading chararray from embedded JSON using Pig
- Oozie Pig action stuck in PREP state and job is in RUNNING state
- InstanceProfile is required for creating cluster - create python function to install module
- mapreduce job not setting compression codec correctly
- What does namespace and block pool mean in MapReduce 2.0 YARN?
- Hadoop distributed mode
- Building apache hadoop 2.6.0 throwing maven error
- I am using Hbase 1.0.0 and Apache phoenix 4.3.0 on CDH5.4. When I restart Hbase regionserver is down
Related Questions in APACHE-SPARK
- Spark .mapValues setup with multiple values
- Where do 'normal' println go in a scala jar, under Spark
- How to query JSON data according to JSON array's size with Spark SQL?
- How do I set the Hive user to something different than the Spark user from within a Spark program?
- How to add a new event to Apache Spark Event Log
- Spark streaming + kafka throughput
- dataframe or sqlctx (sqlcontext) generated "Trying to call a package" error
- Spark pairRDD not working
- How to know which worker a partition is executed at?
- Using HDFS with Apache Spark on Amazon EC2
- How to create a executable jar reading files from local file system
- How to keep a SQLContext instance alive in a spark streaming application's life cycle?
- Cassandra spark connector data loss
- Proper way to provide spark application a parameter/arg with spaces in spark-submit
- sorting RDD elements
Related Questions in CLOUD
- Cloud Connection with Java Window application
- CometCloud installation, and possible alternatives
- Creating a scalable database for android app | cloud hosted
- Arduino NearBus NearbusEther_v16.h: No such file or directory
- how to measure Software as a services performace
- Did google change/update related to vm ssl connections to Cloud SQL?
- Pinging a private IP from one private subnet to another private subnet
- Evernote authentication not working via evernote android sdk
- When upload Bitmap stream to Azure storage, it store zero/empty image
- How to connect Clusterpoint database to an android appliaction
- Installing CouchDB on IaaS?
- Error while creating Instance in gcloud ?. How to create an instance using Google Cloud
- In Spark, does the filter function turn the data into tuples?
- Which language to choose? #suggestions
- Dropbox for local development, Git for cloud
Related Questions in VIRTUAL-MACHINE
- No laravel sync folders in homestead vagrant on windows
- Only 32 bit available in Oracle VM - Hadoop Installation
- Setting Email Notification for Virtual machine whic are down or services that are stopped in Azure Cloud
- Some weird error using Kivy 1.9.1
- How to enable Microsoft Access Driver (*.mdb, *.accdb) in Microsoft Azure windows server 2012 R2?
- scp between two virtual machines in virtualbox
- how to set network configuration for vm in esx host through command?
- List all VM's by their port mirroring settings PowerShell
- Downloading files from Google Cloud Bucket onto Google Compuete Engine Instance Startup (.NET)
- SonarQube not running on CentOS
- Vagrant Port Fowarding on Windows
- Docker inside Windows guest virtual machine
- SSH asking for password in Bluemix
- Running (& compiling) untrusted user code
- ANDY Error Unable to Launch VM Process
Related Questions in GOOGLE-CLOUD-DATAPROC
- I am not finding evidence of NodeInitializationAction for Dataproc having run
- google-fluentd : change severity in Cloud Logging log_level
- Read from BigQuery into Spark in efficient way?
- How to make a pyspark job properly parallelizable on multiple nodes and avoid memory issues?
- YARN Reserved Memory Issue on Dataproc
- Dataproc PySpark Workers Have no Permission to Use gsutil
- What is the solution for the error, “JBlas is not a member of package or apache”?
- Airflow DataProcPySparkOperator not considering cluster other than global region
- How to check if a file exists in Google Storage from Spark Dataproc?
- How can I include additional jars when starting a Google DataProc cluster to use with Jupyter notebooks?
- Why is the Hadoop job slower in cloud (with multi-node clustering) than on normal pc?
- http code 302 when getting file from Spark UI on Dataproc cluster
- NoSuchMethodError while reading from google cloud storage from Dataproc using java
- More number tasks than number vCPUs on dataproc
- Running more than spark streaming job in Google dataproc
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
First of all: not easy to answer without knowing the complete configuration and the type of job your running.
possible reasons are:
http://HOSTNAME:8080 open ressourcemanager webapp and compare available vcores and memory
Job adds more overhead when running parallelized so that it is slower
I would say it is something like 1. and 2.
For more detailed answer let me know:
br