{
"cells": [
{
"cell_type": "markdown",
"metadata": {
"colab_type": "text",
"id": "view-in-github"
},
"source": [
"![\"Open](\"https://colab.research.google.com/assets/colab-badge.svg\")
"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "ApixyFXs9sJM"
},
"source": [
"\n",
"# Getting to know the Spark Standalone Architecture\n",
"## on Google Colab \n",
"\n",
"This notebook has been created for Google Colab with the goal of getting to know Apache Spark™ and exploring the Spark standalone architecture.\n",
"\n",
"After a quick introduction to Apache Spark™ we are going to start a single-node Spark on the Google Colab infrastructure, explore Spark's components and services and get to know the main configuration parameters.\n",
"\n",
"\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "hwUMDMwmOO1z"
},
"source": [
"## What is Spark\n",
"\n",
"Apache Spark™ is a “*is a multi-language engine for executing data engineering, data science, and machine learning on single-node machines or clusters*” (https://spark.apache.org/).\n",
"\n",
"Spark allows to run parallel/distributed algorithms by taking care of distributing tasks among the available computing resources. Based on the MapReduce programming paradigm, Spark improves on it by operating in memory, thus reducing disk I/O latency in multi-step data processing jobs.\n",
"\n",
"Spark is developed in Scala and this is the language of choice for developing applications but also other programming languages are supported by Spark clients:\n",
"\n",
"* Python ([pyspark](https://spark.apache.org/docs/latest/api/python/))\n",
"* R ([SparkR](https://spark.apache.org/docs/latest/sparkr.html) or [Sparklyr](https://spark.rstudio.com/))\n",
"* Java ([Java API](https://spark.apache.org/docs/latest/api/java/) or [Spark Java](https://sparkjava.com/))\n",
"* Julia ([Spark.jl](https://github.com/dfdx/Spark.jl))\n",
"\n",
"\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "zb-R0RxERENm"
},
"source": [
"### Prerequisites\n",
"\n",
"Spark runs on both Windows and UNIX-like systems (e.g. Linux, Mac OS).\n",
"\n",
"It requires a Java runtime version 8, 11, or 17. `java` should be in your system `PATH`, or the `JAVA_HOME` environment variable pointing to a Java installation.\n",
"\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "Z2j7ierLoN_i"
},
"source": [
"#### Check that the required Java version is available:\n",
"\n",
"On Google Colab the required Java is already installed."
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "FK1wiJtLNbFY"
},
"source": [
"In the next cell we are going to install Java in case it is not already available so that the notebook can be tested on a generic Ubuntu machine."
]
},
{
"cell_type": "code",
"execution_count": 1,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:35:49.519096Z",
"iopub.status.busy": "2024-10-13T09:35:49.518885Z",
"iopub.status.idle": "2024-10-13T09:35:49.529539Z",
"shell.execute_reply": "2024-10-13T09:35:49.528846Z"
},
"id": "xo7wE_TSNaP3",
"outputId": "838cc30c-63d6-49f5-fabc-ff25f5443929"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"Java is already installed: /usr/lib/jvm/temurin-11-jdk-amd64\n"
]
}
],
"source": [
"import os\n",
"import shutil\n",
"import subprocess\n",
"\n",
"\n",
"# set variable JAVA_HOME (install Java if necessary)\n",
"def is_java_installed():\n",
" java = shutil.which(\"java\")\n",
" if java:\n",
" os.environ['JAVA_HOME'] = os.path.realpath(java).split('/bin')[0]\n",
" return True\n",
" else:\n",
" return False\n",
"\n",
"def install_java():\n",
" # Uncomment and modify the desired version\n",
" # java_version= 'openjdk-11-jre-headless'\n",
" # java_version= 'default-jre'\n",
" # java_version= 'openjdk-17-jre-headless'\n",
" # java_version= 'openjdk-18-jre-headless'\n",
" java_version= 'openjdk-19-jre-headless'\n",
" print(f\"Java not found. Installing {java_version} ... (this might take a while)\")\n",
" try:\n",
" cmd = f\"apt install -y {java_version}\"\n",
" subprocess_output = subprocess.run(cmd, shell=True, check=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, text=True)\n",
" stdout_result = subprocess_output.stdout\n",
" # Process the results as needed\n",
" print(\"Done installing Java {}\".format(java_version))\n",
" os.environ['JAVA_HOME'] = os.path.realpath(shutil.which(\"java\")).split('/bin')[0]\n",
" print(\"JAVA_HOME is {}\".format(os.environ['JAVA_HOME']))\n",
" except subprocess.CalledProcessError as e:\n",
" # Handle the error if the command returns a non-zero exit code\n",
" lprint(\"Command failed with return code {}\".format(e.returncode))\n",
" print(\"stdout: {}\".format(e.stdout))\n",
"\n",
"\n",
"# Install Java if not available\n",
"if is_java_installed():\n",
" print(\"Java is already installed: {}\".format(os.environ['JAVA_HOME']))\n",
"else:\n",
" print(\"Installing Java\")\n",
" install_java()\n",
"\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "fNZ37Ymp6ZTU"
},
"source": [
"### Download Spark\n",
"\n",
"Spark can be downloaded from https://spark.apache.org/downloads.html.\n",
"\n",
"There are a few pre-built versions that contain Hadoop distributions, a pre-built version without Hadoop, and the sources to build it yourself.\n",
"\n",
"#### Why we're going to download the pre-built for Apache Hadoop\n",
"\n",
"If you already have Hadoop, you will want to download the pre-built version without Hadoop.\n",
"\n",
"For the sake of this demo, even though we are not planning to use Hadoop, we are going to download a pre-built version that includes Apache Hadoop because this contains some libraries needed by Spark that would otherwise need to be manually installed."
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "oB1Gks4ixdkY"
},
"source": [
""
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "ZF8mrscQNjoR"
},
"source": [
"#### Download pre-built Spark with Hadoop\n",
"\n",
"It might be necessary to change the variable `SPARK_VERSION` to stay on track with the latest Spark version."
]
},
{
"cell_type": "code",
"execution_count": 2,
"metadata": {
"execution": {
"iopub.execute_input": "2024-10-13T09:35:49.561232Z",
"iopub.status.busy": "2024-10-13T09:35:49.561005Z",
"iopub.status.idle": "2024-10-13T09:35:49.564038Z",
"shell.execute_reply": "2024-10-13T09:35:49.563507Z"
},
"id": "mhWxRn3w_cri"
},
"outputs": [],
"source": [
"SPARK_VERSION = '3.5.3'\n",
"SPARK_URL = f'https://dlcdn.apache.org/spark/spark-{SPARK_VERSION}/spark-{SPARK_VERSION}-bin-hadoop3.tgz'\n"
]
},
{
"cell_type": "code",
"execution_count": 3,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:35:49.566098Z",
"iopub.status.busy": "2024-10-13T09:35:49.565688Z",
"iopub.status.idle": "2024-10-13T09:35:51.093240Z",
"shell.execute_reply": "2024-10-13T09:35:51.092626Z"
},
"id": "9pmCmsmAMkyL",
"outputId": "ff34ba7c-8c7c-49e0-f957-2d1198f4098f"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"Downloading spark-3.5.3-bin-hadoop3.tgz\n"
]
}
],
"source": [
"import urllib.request\n",
"\n",
"file_name = os.path.basename(SPARK_URL)\n",
"if os.path.isfile(file_name):\n",
" print(\"{} already exists, not downloading\".format(file_name))\n",
"else:\n",
" print(\"Downloading {}\".format(file_name))\n",
" urllib.request.urlretrieve(SPARK_URL, file_name)"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "BWuzWYGHT3Vf"
},
"source": [
"#### Unpack archive"
]
},
{
"cell_type": "code",
"execution_count": 4,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:35:51.095663Z",
"iopub.status.busy": "2024-10-13T09:35:51.095449Z",
"iopub.status.idle": "2024-10-13T09:35:53.836412Z",
"shell.execute_reply": "2024-10-13T09:35:53.835769Z"
},
"id": "-CiqDr2YT3lu",
"outputId": "e50ade9d-1fef-42b0-95a5-d1ac400dcff0"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"Uncompressing spark-3.5.3-bin-hadoop3.tgz\n"
]
}
],
"source": [
"import tarfile\n",
"\n",
"dir_name = file_name[:-7]\n",
"if os.path.exists(dir_name):\n",
" print(\"{} is already uncompressed\".format(file_name))\n",
"else:\n",
" print(\"Uncompressing {}\".format(file_name))\n",
" tar = tarfile.open(file_name)\n",
" tar.extractall()\n",
" tar.close()"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "drAJB7b-NSg5"
},
"source": [
"#### Check Spark folder\n",
"\n",
"You should now have a directory called `spark-3.5.3-bin-hadoop3`.\n",
"\n",
"\n",
"\n"
]
},
{
"cell_type": "code",
"execution_count": 5,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:35:53.839080Z",
"iopub.status.busy": "2024-10-13T09:35:53.838701Z",
"iopub.status.idle": "2024-10-13T09:35:53.843007Z",
"shell.execute_reply": "2024-10-13T09:35:53.842449Z"
},
"id": "TzQ4YLIpNSsp",
"outputId": "5c2cc0b1-9b34-4af0-fed4-00da22f196da"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"Directory found: spark-3.5.3-bin-hadoop3\n"
]
}
],
"source": [
"dir = os.path.splitext(os.path.basename(SPARK_URL))[0]\n",
"if dir in [d.name for d in os.scandir()]:\n",
" print(\"Directory found: \" + dir)"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "mO-e6Zd9OVbV"
},
"source": [
"## The components of a Spark application\n",
"\n",
"The figure below (source: https://spark.apache.org/docs/latest/cluster-overview.html) depicts the components of a Spark application.\n",
"\n",
"\n",
"\n",
""
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "ToeuDDBNOSxT"
},
"source": [
"### Cluster manager\n",
"\n",
"Spark requires a cluster of one or more computers to run independent sets of tasks. A _cluster manager_ is a software in charge of managing a cluster and allocating the resources needed to run applications.\n",
"The cluster manager used determines Spark's _deploy mode_.\n",
"\n",
"There are currently four deploy modes supported by Spark:\n",
"\n",
" - Standalone\n",
" - Apache Mesos (deprecated)\n",
" - Hadoop YARN\n",
" - Kubernetes\n",
"\n",
"In standalone mode Spark uses a basic cluster manager that comes with the Spark distribution.\n",
"\n",
"Note that “*Spark is agnostic to the underlying cluster manager. As long as it can acquire executor processes, and these communicate with each other, it is relatively easy to run it even on a cluster manager that also supports other applications (e.g. Mesos/YARN/Kubernetes).*” (https://spark.apache.org/docs/latest/cluster-overview.html#cluster-manager-types)\n",
"\n",
"\n",
"\n",
"\n",
"\n",
"\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "40rGNreEnphr"
},
"source": [
"### The Spark driver\n",
"\n",
"When a user submits an application to Spark, a _driver program_ is launched. The driver is a JVM process that runs the main function of the application and creates a `SparkContext`, the access point for the user to the Spark Cluster.\n",
"\n",
"In addition to hosting the SparkContext, the driver is responsible for managing the whole application by distributing and scheduling tasks across executors, responding to worker nodes and to user's input, mantaining information about the Spark application.\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "JmqeYu18TWlR"
},
"source": [
"\n",
"#### Spark driver and deploy mode\n",
"\n",
"The driver process can be deployed on one of the worker nodes or on a distinct machine. This can be configured by setting the `deploy-mode` option to `cluster` (driver runs on a node in the cluster) or `client` (driver runs locally—on the machine where the application is being submitted—as an external client). The default default deploy mode is `client`.\n",
"\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "lXJuaKDJn5Kd"
},
"source": [
"#### Which one to use: `client` or `cluster` `deploy-mode`?\n",
"\n",
"In client deploy mode the driver runs locally while all tasks run on cluster worker nodes. This might affect your application's performance due to network latency because the driver needs to constantly exchange data with the worker nodes.\n",
"\n",
"One solution to overcome network latency when using client mode is to deploy the driver on a machine that is physically co-located with the worker nodes. If that is not possible, then cluster deploy mode is preferable. Note however that the standalone mode does not currently support cluster mode for Python applications.\n",
"\n",
"“_In client mode, the driver is launched directly within the spark-submit process which acts as a client to the cluster. The input and output of the application is attached to the console. Thus, this mode is especially suitable for applications that involve the REPL (e.g. Spark shell)_.” (https://spark.apache.org/docs/latest/submitting-applications.html)\n",
"\n",
"In conclusion, client deploy mode is the better choice for interactive work or whenever the driver is physically co-located with or in the same local-area network as the cluster.\n",
"\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "1FcSsYCsoAMY"
},
"source": [
"#### Application's Web UI\n",
"\n",
"Each SparkContext launches a Web UI, by default on port 4040, that provides useful information about the application. This includes:\n",
"(see https://www.ibm.com/docs/en/izoda/1.1.0?topic=spark-web-interfaces https://spark.apache.org/docs/latest/monitoring.html#web-interfaces\n",
"\n",
"A list of scheduler stages and tasks\n",
"A summary of RDD sizes and memory usage\n",
"Environmental information.\n",
"Information about the running executors\n",
"\n",
"It hosts Web UI for the environment.\n",
"It splits a Spark application into tasks and schedules them to run on executors.\n",
"A driver is where the task scheduler lives and spawns tasks across workers.\n",
"A driver coordinates workers and overall execution of tasks."
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "SnPBSaIn_Fz1"
},
"source": [
"### Spark executors\n",
"\n",
"Executors are JVM processes on worker nodes in charge of running individual tasks of a given Spark job reporting results to the driver. They are launched at the beginning of a Spark application typically run for the entire lifetime of the application.\n",
"\n",
"The Spark standalone follows a very basic resource allocation and job scheduling paradigm:\n",
" - applications run in FIFO (first-in-first-out) order\n",
" - each application will try and use all available nodes\n",
" - by default, each executor uses up all cores available on the worker\n",
"\n",
"(see https://spark.apache.org/docs/latest/job-scheduling.html#scheduling-across-applications and https://spark.apache.org/docs/latest/spark-standalone.html#executors-scheduling)\n",
"\n",
"The default resource allotment in standalone mode can be improved by:\n",
" - limiting the number of nodes an application uses by setting the `spark.cores.max` configuration property\n",
" - setting `spark.deploy.defaultCores`\n",
" - controlling the amount of executor's memory by setting `spark.executor.memory`\n",
" - setting `spark.executor.cores` to allow multiple executors from the same application to be launched on the same worker\n",
"\n",
"To improve resource sharing across applications you can Spark configure _dynamic resource allocation_ (default is static). This provides a mechanism to dynamically adjust the resources your application occupies based on the workload. Resources that are not needed are released and made available to other applications and can be reclaimed as needed according to well defined rules and prioritization.\n",
"\n",
"Dynamic resource allocation is useful for serving multiple users on the cluster and in general for maximizing resource utilization."
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "sf_SoCNQOQJs"
},
"source": [
"#### Only one executor per worker node?\n",
"\n",
"It should be clear by now that in general it is possible to have more than one executor on each worker node.\n",
"\n",
"The image above depicting one executor per worker node reflects the default configuration for Spark standalone mode, where each executor allocates all cores available on the worker."
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "eQlj1_8nUVSp"
},
"source": [
"## Start a standalone master\n",
"\n",
"Back to work after all the theory that can be overwhelming at first if you have never used Spark before.\n",
"\n",
"We're going to define/modify some environment variables:\n",
"\n",
"* `SPARK_HOME` the path of the Spark installation\n",
"* `PATH` is modified to include Spark's `bin` path\n",
"\n",
"**Note:** `JAVA_HOME`, the path of the Java installation, has been defined earlier."
]
},
{
"cell_type": "code",
"execution_count": 6,
"metadata": {
"execution": {
"iopub.execute_input": "2024-10-13T09:35:53.845457Z",
"iopub.status.busy": "2024-10-13T09:35:53.845214Z",
"iopub.status.idle": "2024-10-13T09:35:53.848902Z",
"shell.execute_reply": "2024-10-13T09:35:53.848386Z"
},
"id": "4xdjxjd9U2j2"
},
"outputs": [],
"source": [
"os.environ['SPARK_HOME'] = os.path.join('.', os.path.splitext(os.path.basename(SPARK_URL))[0])\n",
"os.environ['PATH'] = ':'.join([os.path.join(os.environ['SPARK_HOME'], 'bin'), os.environ['PATH']])"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "oodRKgQWpdjc"
},
"source": [
"The Spark _master_ can be started with a simple shell script included in the Spark distribution:\n",
"\n",
"```\n",
"$SPARK_HOME/sbin/start-master.sh\n",
"```"
]
},
{
"cell_type": "code",
"execution_count": 7,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:35:53.850949Z",
"iopub.status.busy": "2024-10-13T09:35:53.850555Z",
"iopub.status.idle": "2024-10-13T09:35:56.536977Z",
"shell.execute_reply": "2024-10-13T09:35:56.536127Z"
},
"id": "gdWDjrOEqTLh",
"outputId": "a35a45fd-9e79-40a4-b231-70b454446978"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"starting org.apache.spark.deploy.master.Master, logging to ./spark-3.5.3-bin-hadoop3/logs/spark-runner-org.apache.spark.deploy.master.Master-1-fv-az837-567.out\r\n"
]
}
],
"source": [
"!$SPARK_HOME/sbin/start-master.sh"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "52NFiOb74KjH"
},
"source": [
"You should see in the output something like:\n",
"\n",
"```\n",
"logging to /content/spark-3.5.0-bin-hadoop3/logs/spark--org.apache.spark.deploy.master.Master ...\n",
"```"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "U12myl5Q467O"
},
"source": [
"For convenience, we're going to funnel the output of the `start-master.sh` shell command to the Python variable `output` using the option `--out` of the `%%bash` magic.\n",
"\n",
"But first, stop the running master with—you guessed it—`stop-master.sh`:"
]
},
{
"cell_type": "code",
"execution_count": 8,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:35:56.539838Z",
"iopub.status.busy": "2024-10-13T09:35:56.539603Z",
"iopub.status.idle": "2024-10-13T09:35:56.693956Z",
"shell.execute_reply": "2024-10-13T09:35:56.693227Z"
},
"id": "Dx4cWnWe57Wc",
"outputId": "5db86e76-2d1e-4644-bac4-0e3c915ea027"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"stopping org.apache.spark.deploy.master.Master\r\n"
]
}
],
"source": [
"!$SPARK_HOME/sbin/stop-master.sh"
]
},
{
"cell_type": "code",
"execution_count": 9,
"metadata": {
"execution": {
"iopub.execute_input": "2024-10-13T09:35:56.696328Z",
"iopub.status.busy": "2024-10-13T09:35:56.696108Z",
"iopub.status.idle": "2024-10-13T09:35:59.273637Z",
"shell.execute_reply": "2024-10-13T09:35:59.272906Z"
},
"id": "fVyj9mrt45Cw"
},
"outputs": [],
"source": [
"%%bash --out output\n",
"$SPARK_HOME/sbin/start-master.sh"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "T3VKK24S64XZ"
},
"source": [
"Extract the logfile name from `output` and print the content of the file:"
]
},
{
"cell_type": "code",
"execution_count": 10,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:35:59.276408Z",
"iopub.status.busy": "2024-10-13T09:35:59.275987Z",
"iopub.status.idle": "2024-10-13T09:35:59.280468Z",
"shell.execute_reply": "2024-10-13T09:35:59.279915Z"
},
"id": "qiP6NkFG6S7i",
"outputId": "cc3dc49e-09ef-421e-a0ed-fca8c61b895f"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"Spark Command: /usr/lib/jvm/temurin-11-jdk-amd64/bin/java -cp ./spark-3.5.3-bin-hadoop3/conf/:/home/runner/work/big_data/big_data/./spark-3.5.3-bin-hadoop3/jars/* -Xmx1g org.apache.spark.deploy.master.Master --host fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net --port 7077 --webui-port 8080\n",
"========================================\n",
"Using Spark's default log4j profile: org/apache/spark/log4j2-defaults.properties\n",
"24/10/13 09:35:58 INFO Master: Started daemon with process name: 2160@fv-az837-567\n",
"24/10/13 09:35:58 INFO SignalUtils: Registering signal handler for TERM\n",
"24/10/13 09:35:58 INFO SignalUtils: Registering signal handler for HUP\n",
"24/10/13 09:35:58 INFO SignalUtils: Registering signal handler for INT\n",
"24/10/13 09:35:58 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable\n",
"24/10/13 09:35:58 INFO SecurityManager: Changing view acls to: runner\n",
"24/10/13 09:35:58 INFO SecurityManager: Changing modify acls to: runner\n",
"24/10/13 09:35:58 INFO SecurityManager: Changing view acls groups to: \n",
"24/10/13 09:35:58 INFO SecurityManager: Changing modify acls groups to: \n",
"24/10/13 09:35:58 INFO SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users with view permissions: runner; groups with view permissions: EMPTY; users with modify permissions: runner; groups with modify permissions: EMPTY\n",
"24/10/13 09:35:58 INFO Utils: Successfully started service 'sparkMaster' on port 7077.\n",
"24/10/13 09:35:58 INFO Master: Starting Spark master at spark://fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net:7077\n",
"24/10/13 09:35:58 INFO Master: Running Spark version 3.5.3\n",
"24/10/13 09:35:58 INFO JettyUtils: Start Jetty 0.0.0.0:8080 for MasterUI\n",
"24/10/13 09:35:58 INFO Utils: Successfully started service 'MasterUI' on port 8080.\n",
"24/10/13 09:35:58 INFO MasterWebUI: Bound MasterWebUI to 0.0.0.0, and started at http://fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net:8080\n",
"24/10/13 09:35:59 INFO Master: I have been elected leader! New state: ALIVE\n",
"\n"
]
}
],
"source": [
"logfile = output.split()[-1]\n",
"logfile_content = open(logfile, 'r').read()\n",
"print(logfile_content)"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "fnqCg3Eb7-bE"
},
"source": [
"If the Spark master has been started successfully, the last line of the file should contain:\n",
"```\n",
"Master: I have been elected leader! New state: ALIVE\n",
"```"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "yGn5OMDu9vl8"
},
"source": [
"I don't know about you, but I enjoy looking at logfiles."
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "_-aAKfha8VJc"
},
"source": [
"## Examine the master\n",
"\n",
"So now we have a cluster manager but no workers. The current status of the Spark master (workers, running applications, etc.) can be viewed in the master's Web UI.\n",
"\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "WpLPzLCd_Hh7"
},
"source": [
"### Spark master's Web UI\n",
"\n",
"The Spark master spawns a Web UI with default port $8080$ (see [services and ports](\n",
"https://spark.apache.org/docs/latest/security.html#configuring-ports-for-network-security)).\n",
"\n",
"If you look closely at the `logfile`, you will see that the `MasterUI` server has actually been bound to port $8081$ because port $8080$ was not available.\n",
"\n",
"Generate a Colab link for the Master Web UI and view it in a separate window.\n",
"\n",
"**Note:** this works only when working on Google Colab. In other environments a different solution can be implemented to serve Web UIs."
]
},
{
"cell_type": "code",
"execution_count": 11,
"metadata": {
"execution": {
"iopub.execute_input": "2024-10-13T09:35:59.282792Z",
"iopub.status.busy": "2024-10-13T09:35:59.282412Z",
"iopub.status.idle": "2024-10-13T09:35:59.285609Z",
"shell.execute_reply": "2024-10-13T09:35:59.285060Z"
},
"id": "BODj99dhH763"
},
"outputs": [],
"source": [
"# true if running on Google Colab\n",
"import sys\n",
"IN_COLAB = 'google.colab' in sys.modules\n",
"if IN_COLAB:\n",
" from google.colab import output"
]
},
{
"cell_type": "code",
"execution_count": 12,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/",
"height": 0
},
"execution": {
"iopub.execute_input": "2024-10-13T09:35:59.287608Z",
"iopub.status.busy": "2024-10-13T09:35:59.287311Z",
"iopub.status.idle": "2024-10-13T09:35:59.290345Z",
"shell.execute_reply": "2024-10-13T09:35:59.289656Z"
},
"id": "0NTjJFSwAnBe",
"outputId": "90e04464-11b3-4388-dade-a0b491c4492a"
},
"outputs": [],
"source": [
"port = 8081\n",
"\n",
"if IN_COLAB:\n",
" output.serve_kernel_port_as_window(port)"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "6dZKzIhaBBtx"
},
"source": [
"In the new window you should see something like:"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "xQtOO4lHBImx"
},
"source": [
""
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "1R3fYl8uY6Rv"
},
"source": [
"Notice the peculiar URL\n",
"\n",
"```\n",
"spark://69eb8e500a52:7077\n",
"```\n",
"\n",
"The random string in the URL is the hostname of the current Google Colab virtual machine.\n",
"\n",
"You can view the current hostname with:"
]
},
{
"cell_type": "code",
"execution_count": 13,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:35:59.292399Z",
"iopub.status.busy": "2024-10-13T09:35:59.292100Z",
"iopub.status.idle": "2024-10-13T09:35:59.416737Z",
"shell.execute_reply": "2024-10-13T09:35:59.416130Z"
},
"id": "JT6_neDMZWB9",
"outputId": "c4ad7f33-9dfc-4dc9-d30e-a493dc9acb7d"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"\r\n"
]
}
],
"source": [
"!echo $HOSTNAME"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "bcP9hTAh6KwK"
},
"source": [
"### How to set alternative ports for the Spark master\n",
"\n",
"The ports used by `start-master.sh` can be configured in several ways:\n",
"\n",
"\n",
"* by using the option \n",
" * `--port` for the service port\n",
" * `--webui-port` for the Web UI port\n",
"\n",
" Example:\n",
"\n",
" `$SPARK_HOME/sbin/start-master.sh --webui-port 8087`\n",
"\n",
"* by setting the variables `SPARK_MASTER_PORT` / `SPARK_MASTER_WEBUI_PORT`\n",
"\n",
" before running the start script. For example:\n",
"\n",
" `export SPARK_MASTER_WEBUI_PORT=8087`\n",
" \n",
"* by creating a file `spark-env.sh` in `$SPARK_HOME/conf/` containing the settings for the two variables `SPARK_MASTER_PORT` and `SPARK_MASTER_WEBUI_PORT` (`$SPARK_HOME/conf/` contains a template file that can be copied and adapted)\n",
"\n",
" before running the start script. For example:\n",
"\n",
" `export SPARK_MASTER_WEBUI_PORT=8087`\n",
"\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "rw-B8F5pMsI8"
},
"source": [
"#### Pick a random free port\n",
"\n",
"Since the Spark master is created on the fly here on Google Colab, for the Web UI we are going to use a random free port selected with `portpicker`. The Spsrk service port 7077 doesn't seem to be reserved, so we are going to keep the default value of $7077$.\n",
"\n",
"In general, if you are running the Spark master on a dedicated machine, you might want to configure the ports in `spark-env.sh`."
]
},
{
"cell_type": "code",
"execution_count": 14,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:35:59.419144Z",
"iopub.status.busy": "2024-10-13T09:35:59.418726Z",
"iopub.status.idle": "2024-10-13T09:35:59.423474Z",
"shell.execute_reply": "2024-10-13T09:35:59.422935Z"
},
"id": "0ddqs3CXMxah",
"outputId": "828d06fb-7377-4884-aff5-2581654549c7"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"Port picked is: 34725\n"
]
}
],
"source": [
"import portpicker\n",
"port = portpicker.pick_unused_port()\n",
"os.environ['SPARK_MASTER_WEBUI_PORT'] = str(port)\n",
"print(\"Port picked is: {}\".format(port))"
]
},
{
"cell_type": "code",
"execution_count": 15,
"metadata": {
"execution": {
"iopub.execute_input": "2024-10-13T09:35:59.425493Z",
"iopub.status.busy": "2024-10-13T09:35:59.425110Z",
"iopub.status.idle": "2024-10-13T09:36:02.026791Z",
"shell.execute_reply": "2024-10-13T09:36:02.026047Z"
},
"id": "17U-E0byUVeo"
},
"outputs": [],
"source": [
"%%bash --out bash_output\n",
"$SPARK_HOME/sbin/stop-master.sh\n",
"$SPARK_HOME/sbin/start-master.sh --webui-port $SPARK_MASTER_WEBUI_PORT"
]
},
{
"cell_type": "code",
"execution_count": 16,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:36:02.029411Z",
"iopub.status.busy": "2024-10-13T09:36:02.029034Z",
"iopub.status.idle": "2024-10-13T09:36:02.033078Z",
"shell.execute_reply": "2024-10-13T09:36:02.032561Z"
},
"id": "QL3R-xw1QThD",
"outputId": "9bb2b65e-ee34-4ffa-ce7b-b5fbd7dcd607"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"Spark Command: /usr/lib/jvm/temurin-11-jdk-amd64/bin/java -cp ./spark-3.5.3-bin-hadoop3/conf/:/home/runner/work/big_data/big_data/./spark-3.5.3-bin-hadoop3/jars/* -Xmx1g org.apache.spark.deploy.master.Master --host fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net --port 7077 --webui-port 34725 --webui-port 34725\n",
"========================================\n",
"Using Spark's default log4j profile: org/apache/spark/log4j2-defaults.properties\n",
"24/10/13 09:36:00 INFO Master: Started daemon with process name: 2254@fv-az837-567\n",
"24/10/13 09:36:00 INFO SignalUtils: Registering signal handler for TERM\n",
"24/10/13 09:36:00 INFO SignalUtils: Registering signal handler for HUP\n",
"24/10/13 09:36:00 INFO SignalUtils: Registering signal handler for INT\n",
"24/10/13 09:36:01 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable\n",
"24/10/13 09:36:01 INFO SecurityManager: Changing view acls to: runner\n",
"24/10/13 09:36:01 INFO SecurityManager: Changing modify acls to: runner\n",
"24/10/13 09:36:01 INFO SecurityManager: Changing view acls groups to: \n",
"24/10/13 09:36:01 INFO SecurityManager: Changing modify acls groups to: \n",
"24/10/13 09:36:01 INFO SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users with view permissions: runner; groups with view permissions: EMPTY; users with modify permissions: runner; groups with modify permissions: EMPTY\n",
"24/10/13 09:36:01 INFO Utils: Successfully started service 'sparkMaster' on port 7077.\n",
"24/10/13 09:36:01 INFO Master: Starting Spark master at spark://fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net:7077\n",
"24/10/13 09:36:01 INFO Master: Running Spark version 3.5.3\n",
"24/10/13 09:36:01 INFO JettyUtils: Start Jetty 0.0.0.0:34725 for MasterUI\n",
"24/10/13 09:36:01 INFO Utils: Successfully started service 'MasterUI' on port 34725.\n",
"24/10/13 09:36:01 INFO MasterWebUI: Bound MasterWebUI to 0.0.0.0, and started at http://fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net:34725\n",
"24/10/13 09:36:01 INFO Master: I have been elected leader! New state: ALIVE\n",
"\n"
]
}
],
"source": [
"logfile = bash_output.split()[-1]\n",
"logfile_content = open(logfile, 'r').read()\n",
"print(logfile_content)"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "pllu6yWrQAi9"
},
"source": [
"Now the Spark master's Web UI can be reached at the new `port`."
]
},
{
"cell_type": "code",
"execution_count": 17,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/",
"height": 0
},
"execution": {
"iopub.execute_input": "2024-10-13T09:36:02.035203Z",
"iopub.status.busy": "2024-10-13T09:36:02.034875Z",
"iopub.status.idle": "2024-10-13T09:36:02.037821Z",
"shell.execute_reply": "2024-10-13T09:36:02.037269Z"
},
"id": "umHV4x0bQI5v",
"outputId": "bdb324df-534c-4fdf-a139-16a916fe49d1"
},
"outputs": [],
"source": [
"if IN_COLAB:\n",
" webUI = output.serve_kernel_port_as_window(port)"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "0KmfngZiXUN_"
},
"source": [
"### Port $7077$\n",
"\n",
"Port $7077$ is the default port for submitting Spark applications.\n",
"\n",
"When a user submits an application to the Spark master at port $7077$, this starts a driver program that runs the application on the Spark cluster.\n",
"\n",
"Next we are going to submit a Spark application but before that it is necessary to create one or more workers."
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "Da8RMzkSYfn9"
},
"source": [
"## Start one worker\n",
"\n",
"In order to start a worker you need the URL for the running master node, that is something like `spark://${HOSTNAME}:7077`.\n",
"\n",
"This is a simple command:\n",
"\n",
"```\n",
"$SPARK_HOME/sbin/start-worker.sh spark://${HOSTNAME}:7077\n",
"```"
]
},
{
"cell_type": "code",
"execution_count": 18,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:36:02.040160Z",
"iopub.status.busy": "2024-10-13T09:36:02.039675Z",
"iopub.status.idle": "2024-10-13T09:36:04.716001Z",
"shell.execute_reply": "2024-10-13T09:36:04.715083Z"
},
"id": "LA4LUDm7abqS",
"outputId": "be59e513-d6ca-48f9-d7c2-b15dce10f105"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"starting org.apache.spark.deploy.worker.Worker, logging to ./spark-3.5.3-bin-hadoop3/logs/spark-runner-org.apache.spark.deploy.worker.Worker-1-fv-az837-567.out\r\n"
]
}
],
"source": [
"!$SPARK_HOME/sbin/start-worker.sh spark://$(hostname):7077\n"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "N4Exc-yya-um"
},
"source": [
"In the master's Web UI you should now see the newly created worker."
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "bETDHBONbXwv"
},
"source": [
""
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "DD5xg7ep-6EQ"
},
"source": [
"## Submit a Spark application with `spark-submit`\n",
"\n",
"This step might take some time.\n",
"\n",
"We are going to run the SparkPi demo from the examples in the Spark distribution contained in `spark-examples*.jar`.\n",
"\n",
"We are submitting the job with [`spark-submit`](https://spark.apache.org/docs/latest/submitting-applications.html). The output of this job is an approximation of π computed with a Montecarlo method (see also https://spark.apache.org/examples.html).\n",
"\n",
"While the application is running you can check its progress on the Spark master Web UI."
]
},
{
"cell_type": "code",
"execution_count": 19,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:36:04.719852Z",
"iopub.status.busy": "2024-10-13T09:36:04.719239Z",
"iopub.status.idle": "2024-10-13T09:36:12.146599Z",
"shell.execute_reply": "2024-10-13T09:36:12.145800Z"
},
"id": "Y6a2H7efcZJY",
"outputId": "5737741b-2c83-410a-a3b5-a99449260e8b"
},
"outputs": [
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SparkContext: Running Spark version 3.5.3\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SparkContext: OS info Linux, 6.5.0-1025-azure, amd64\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SparkContext: Java version 11.0.24\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO ResourceUtils: ==============================================================\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO ResourceUtils: No custom resources configured for spark.driver.\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO ResourceUtils: ==============================================================\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SparkContext: Submitted application: Spark Pi\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO ResourceProfile: Default ResourceProfile created, executor resources: Map(memory -> name: memory, amount: 1024, script: , vendor: , offHeap -> name: offHeap, amount: 0, script: , vendor: ), task resources: Map(cpus -> name: cpus, amount: 1.0)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO ResourceProfile: Limiting resource is cpu\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO ResourceProfileManager: Added ResourceProfile id: 0\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SecurityManager: Changing view acls to: runner\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SecurityManager: Changing modify acls to: runner\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SecurityManager: Changing view acls groups to: \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SecurityManager: Changing modify acls groups to: \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users with view permissions: runner; groups with view permissions: EMPTY; users with modify permissions: runner; groups with modify permissions: EMPTY\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO Utils: Successfully started service 'sparkDriver' on port 35049.\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SparkEnv: Registering MapOutputTracker\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SparkEnv: Registering BlockManagerMaster\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO BlockManagerMasterEndpoint: Using org.apache.spark.storage.DefaultTopologyMapper for getting topology information\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO BlockManagerMasterEndpoint: BlockManagerMasterEndpoint up\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SparkEnv: Registering BlockManagerMasterHeartbeat\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO DiskBlockManager: Created local directory at /tmp/blockmgr-6aff4905-1572-4187-b6db-de72c5fd96d2\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO MemoryStore: MemoryStore started with capacity 434.4 MiB\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:06 INFO SparkEnv: Registering OutputCommitCoordinator\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO JettyUtils: Start Jetty 0.0.0.0:4040 for SparkUI\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO Utils: Successfully started service 'SparkUI' on port 4040.\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO SparkContext: Added JAR file:/home/runner/work/big_data/big_data/spark-3.5.3-bin-hadoop3/examples/jars/spark-examples_2.12-3.5.3.jar at spark://fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net:35049/jars/spark-examples_2.12-3.5.3.jar with timestamp 1728812166441\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO StandaloneAppClient$ClientEndpoint: Connecting to master spark://fv-az837-567:7077...\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO TransportClientFactory: Successfully created connection to fv-az837-567/10.1.1.7:7077 after 22 ms (0 ms spent in bootstraps)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO StandaloneSchedulerBackend: Connected to Spark cluster with app ID app-20241013093607-0000\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO StandaloneAppClient$ClientEndpoint: Executor added: app-20241013093607-0000/0 on worker-20241013093604-10.1.1.7-42205 (10.1.1.7:42205) with 4 core(s)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO StandaloneSchedulerBackend: Granted executor ID app-20241013093607-0000/0 on hostPort 10.1.1.7:42205 with 4 core(s), 1024.0 MiB RAM\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO Utils: Successfully started service 'org.apache.spark.network.netty.NettyBlockTransferService' on port 38051.\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO NettyBlockTransferService: Server created on fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net:38051\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO BlockManager: Using org.apache.spark.storage.RandomBlockReplicationPolicy for block replication policy\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO BlockManagerMaster: Registering BlockManager BlockManagerId(driver, fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net, 38051, None)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO BlockManagerMasterEndpoint: Registering block manager fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net:38051 with 434.4 MiB RAM, BlockManagerId(driver, fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net, 38051, None)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO BlockManagerMaster: Registered BlockManager BlockManagerId(driver, fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net, 38051, None)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO BlockManager: Initialized BlockManager: BlockManagerId(driver, fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net, 38051, None)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO StandaloneAppClient$ClientEndpoint: Executor updated: app-20241013093607-0000/0 is now RUNNING\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:07 INFO StandaloneSchedulerBackend: SchedulerBackend is ready for scheduling beginning after reached minRegisteredResourcesRatio: 0.0\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO SparkContext: Starting job: reduce at SparkPi.scala:38\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO DAGScheduler: Got job 0 (reduce at SparkPi.scala:38) with 100 output partitions\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO DAGScheduler: Final stage: ResultStage 0 (reduce at SparkPi.scala:38)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO DAGScheduler: Parents of final stage: List()\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO DAGScheduler: Missing parents: List()\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO DAGScheduler: Submitting ResultStage 0 (MapPartitionsRDD[1] at map at SparkPi.scala:34), which has no missing parents\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO MemoryStore: Block broadcast_0 stored as values in memory (estimated size 4.0 KiB, free 434.4 MiB)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO MemoryStore: Block broadcast_0_piece0 stored as bytes in memory (estimated size 2.3 KiB, free 434.4 MiB)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO BlockManagerInfo: Added broadcast_0_piece0 in memory on fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net:38051 (size: 2.3 KiB, free: 434.4 MiB)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO SparkContext: Created broadcast 0 from broadcast at DAGScheduler.scala:1585\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO DAGScheduler: Submitting 100 missing tasks from ResultStage 0 (MapPartitionsRDD[1] at map at SparkPi.scala:34) (first 15 tasks are for partitions Vector(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14))\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:08 INFO TaskSchedulerImpl: Adding task set 0.0 with 100 tasks resource profile 0\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO StandaloneSchedulerBackend$StandaloneDriverEndpoint: Registered executor NettyRpcEndpointRef(spark-client://Executor) (10.1.1.7:60644) with ID 0, ResourceProfileId 0\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO BlockManagerMasterEndpoint: Registering block manager 10.1.1.7:33041 with 434.4 MiB RAM, BlockManagerId(0, 10.1.1.7, 33041, None)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 0.0 in stage 0.0 (TID 0) (10.1.1.7, executor 0, partition 0, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 1.0 in stage 0.0 (TID 1) (10.1.1.7, executor 0, partition 1, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 2.0 in stage 0.0 (TID 2) (10.1.1.7, executor 0, partition 2, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 3.0 in stage 0.0 (TID 3) (10.1.1.7, executor 0, partition 3, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO BlockManagerInfo: Added broadcast_0_piece0 in memory on 10.1.1.7:33041 (size: 2.3 KiB, free: 434.4 MiB)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 4.0 in stage 0.0 (TID 4) (10.1.1.7, executor 0, partition 4, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 5.0 in stage 0.0 (TID 5) (10.1.1.7, executor 0, partition 5, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 6.0 in stage 0.0 (TID 6) (10.1.1.7, executor 0, partition 6, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 7.0 in stage 0.0 (TID 7) (10.1.1.7, executor 0, partition 7, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 8.0 in stage 0.0 (TID 8) (10.1.1.7, executor 0, partition 8, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 9.0 in stage 0.0 (TID 9) (10.1.1.7, executor 0, partition 9, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 3.0 in stage 0.0 (TID 3) in 521 ms on 10.1.1.7 (executor 0) (1/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 5.0 in stage 0.0 (TID 5) in 39 ms on 10.1.1.7 (executor 0) (2/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 6.0 in stage 0.0 (TID 6) in 30 ms on 10.1.1.7 (executor 0) (3/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 2.0 in stage 0.0 (TID 2) in 534 ms on 10.1.1.7 (executor 0) (4/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 1.0 in stage 0.0 (TID 1) in 539 ms on 10.1.1.7 (executor 0) (5/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 0.0 in stage 0.0 (TID 0) in 570 ms on 10.1.1.7 (executor 0) (6/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 10.0 in stage 0.0 (TID 10) (10.1.1.7, executor 0, partition 10, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 11.0 in stage 0.0 (TID 11) (10.1.1.7, executor 0, partition 11, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 4.0 in stage 0.0 (TID 4) in 81 ms on 10.1.1.7 (executor 0) (7/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 8.0 in stage 0.0 (TID 8) in 49 ms on 10.1.1.7 (executor 0) (8/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 12.0 in stage 0.0 (TID 12) (10.1.1.7, executor 0, partition 12, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 7.0 in stage 0.0 (TID 7) in 61 ms on 10.1.1.7 (executor 0) (9/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 13.0 in stage 0.0 (TID 13) (10.1.1.7, executor 0, partition 13, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 9.0 in stage 0.0 (TID 9) in 61 ms on 10.1.1.7 (executor 0) (10/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 14.0 in stage 0.0 (TID 14) (10.1.1.7, executor 0, partition 14, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 15.0 in stage 0.0 (TID 15) (10.1.1.7, executor 0, partition 15, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 10.0 in stage 0.0 (TID 10) in 57 ms on 10.1.1.7 (executor 0) (11/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 13.0 in stage 0.0 (TID 13) in 41 ms on 10.1.1.7 (executor 0) (12/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 12.0 in stage 0.0 (TID 12) in 56 ms on 10.1.1.7 (executor 0) (13/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 16.0 in stage 0.0 (TID 16) (10.1.1.7, executor 0, partition 16, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 17.0 in stage 0.0 (TID 17) (10.1.1.7, executor 0, partition 17, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 11.0 in stage 0.0 (TID 11) in 77 ms on 10.1.1.7 (executor 0) (14/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 15.0 in stage 0.0 (TID 15) in 27 ms on 10.1.1.7 (executor 0) (15/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 18.0 in stage 0.0 (TID 18) (10.1.1.7, executor 0, partition 18, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 19.0 in stage 0.0 (TID 19) (10.1.1.7, executor 0, partition 19, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 16.0 in stage 0.0 (TID 16) in 21 ms on 10.1.1.7 (executor 0) (16/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 20.0 in stage 0.0 (TID 20) (10.1.1.7, executor 0, partition 20, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 19.0 in stage 0.0 (TID 19) in 34 ms on 10.1.1.7 (executor 0) (17/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 21.0 in stage 0.0 (TID 21) (10.1.1.7, executor 0, partition 21, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 14.0 in stage 0.0 (TID 14) in 90 ms on 10.1.1.7 (executor 0) (18/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Starting task 22.0 in stage 0.0 (TID 22) (10.1.1.7, executor 0, partition 22, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:10 INFO TaskSetManager: Finished task 18.0 in stage 0.0 (TID 18) in 62 ms on 10.1.1.7 (executor 0) (19/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 23.0 in stage 0.0 (TID 23) (10.1.1.7, executor 0, partition 23, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 17.0 in stage 0.0 (TID 17) in 109 ms on 10.1.1.7 (executor 0) (20/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 24.0 in stage 0.0 (TID 24) (10.1.1.7, executor 0, partition 24, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 20.0 in stage 0.0 (TID 20) in 74 ms on 10.1.1.7 (executor 0) (21/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 21.0 in stage 0.0 (TID 21) in 57 ms on 10.1.1.7 (executor 0) (22/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 25.0 in stage 0.0 (TID 25) (10.1.1.7, executor 0, partition 25, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 22.0 in stage 0.0 (TID 22) in 61 ms on 10.1.1.7 (executor 0) (23/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 26.0 in stage 0.0 (TID 26) (10.1.1.7, executor 0, partition 26, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 23.0 in stage 0.0 (TID 23) in 44 ms on 10.1.1.7 (executor 0) (24/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 27.0 in stage 0.0 (TID 27) (10.1.1.7, executor 0, partition 27, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 28.0 in stage 0.0 (TID 28) (10.1.1.7, executor 0, partition 28, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 25.0 in stage 0.0 (TID 25) in 33 ms on 10.1.1.7 (executor 0) (25/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 24.0 in stage 0.0 (TID 24) in 39 ms on 10.1.1.7 (executor 0) (26/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 29.0 in stage 0.0 (TID 29) (10.1.1.7, executor 0, partition 29, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 30.0 in stage 0.0 (TID 30) (10.1.1.7, executor 0, partition 30, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 26.0 in stage 0.0 (TID 26) in 37 ms on 10.1.1.7 (executor 0) (27/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 31.0 in stage 0.0 (TID 31) (10.1.1.7, executor 0, partition 31, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 28.0 in stage 0.0 (TID 28) in 45 ms on 10.1.1.7 (executor 0) (28/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 32.0 in stage 0.0 (TID 32) (10.1.1.7, executor 0, partition 32, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 29.0 in stage 0.0 (TID 29) in 48 ms on 10.1.1.7 (executor 0) (29/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 33.0 in stage 0.0 (TID 33) (10.1.1.7, executor 0, partition 33, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 30.0 in stage 0.0 (TID 30) in 52 ms on 10.1.1.7 (executor 0) (30/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 34.0 in stage 0.0 (TID 34) (10.1.1.7, executor 0, partition 34, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 27.0 in stage 0.0 (TID 27) in 68 ms on 10.1.1.7 (executor 0) (31/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 35.0 in stage 0.0 (TID 35) (10.1.1.7, executor 0, partition 35, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 32.0 in stage 0.0 (TID 32) in 32 ms on 10.1.1.7 (executor 0) (32/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 36.0 in stage 0.0 (TID 36) (10.1.1.7, executor 0, partition 36, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 31.0 in stage 0.0 (TID 31) in 56 ms on 10.1.1.7 (executor 0) (33/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 37.0 in stage 0.0 (TID 37) (10.1.1.7, executor 0, partition 37, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 38.0 in stage 0.0 (TID 38) (10.1.1.7, executor 0, partition 38, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 34.0 in stage 0.0 (TID 34) in 44 ms on 10.1.1.7 (executor 0) (34/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 33.0 in stage 0.0 (TID 33) in 47 ms on 10.1.1.7 (executor 0) (35/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 39.0 in stage 0.0 (TID 39) (10.1.1.7, executor 0, partition 39, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 37.0 in stage 0.0 (TID 37) in 23 ms on 10.1.1.7 (executor 0) (36/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 40.0 in stage 0.0 (TID 40) (10.1.1.7, executor 0, partition 40, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 35.0 in stage 0.0 (TID 35) in 57 ms on 10.1.1.7 (executor 0) (37/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 41.0 in stage 0.0 (TID 41) (10.1.1.7, executor 0, partition 41, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 38.0 in stage 0.0 (TID 38) in 52 ms on 10.1.1.7 (executor 0) (38/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 42.0 in stage 0.0 (TID 42) (10.1.1.7, executor 0, partition 42, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 43.0 in stage 0.0 (TID 43) (10.1.1.7, executor 0, partition 43, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 44.0 in stage 0.0 (TID 44) (10.1.1.7, executor 0, partition 44, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 40.0 in stage 0.0 (TID 40) in 38 ms on 10.1.1.7 (executor 0) (39/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 39.0 in stage 0.0 (TID 39) in 49 ms on 10.1.1.7 (executor 0) (40/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 36.0 in stage 0.0 (TID 36) in 84 ms on 10.1.1.7 (executor 0) (41/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 45.0 in stage 0.0 (TID 45) (10.1.1.7, executor 0, partition 45, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 41.0 in stage 0.0 (TID 41) in 32 ms on 10.1.1.7 (executor 0) (42/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 46.0 in stage 0.0 (TID 46) (10.1.1.7, executor 0, partition 46, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 45.0 in stage 0.0 (TID 45) in 25 ms on 10.1.1.7 (executor 0) (43/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 47.0 in stage 0.0 (TID 47) (10.1.1.7, executor 0, partition 47, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 44.0 in stage 0.0 (TID 44) in 62 ms on 10.1.1.7 (executor 0) (44/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 48.0 in stage 0.0 (TID 48) (10.1.1.7, executor 0, partition 48, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 43.0 in stage 0.0 (TID 43) in 76 ms on 10.1.1.7 (executor 0) (45/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 49.0 in stage 0.0 (TID 49) (10.1.1.7, executor 0, partition 49, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 42.0 in stage 0.0 (TID 42) in 80 ms on 10.1.1.7 (executor 0) (46/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 46.0 in stage 0.0 (TID 46) in 45 ms on 10.1.1.7 (executor 0) (47/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 50.0 in stage 0.0 (TID 50) (10.1.1.7, executor 0, partition 50, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 51.0 in stage 0.0 (TID 51) (10.1.1.7, executor 0, partition 51, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 47.0 in stage 0.0 (TID 47) in 54 ms on 10.1.1.7 (executor 0) (48/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 52.0 in stage 0.0 (TID 52) (10.1.1.7, executor 0, partition 52, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 49.0 in stage 0.0 (TID 49) in 31 ms on 10.1.1.7 (executor 0) (49/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 53.0 in stage 0.0 (TID 53) (10.1.1.7, executor 0, partition 53, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 54.0 in stage 0.0 (TID 54) (10.1.1.7, executor 0, partition 54, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 55.0 in stage 0.0 (TID 55) (10.1.1.7, executor 0, partition 55, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 51.0 in stage 0.0 (TID 51) in 30 ms on 10.1.1.7 (executor 0) (50/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 48.0 in stage 0.0 (TID 48) in 61 ms on 10.1.1.7 (executor 0) (51/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 50.0 in stage 0.0 (TID 50) in 32 ms on 10.1.1.7 (executor 0) (52/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 56.0 in stage 0.0 (TID 56) (10.1.1.7, executor 0, partition 56, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 57.0 in stage 0.0 (TID 57) (10.1.1.7, executor 0, partition 57, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 52.0 in stage 0.0 (TID 52) in 64 ms on 10.1.1.7 (executor 0) (53/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 53.0 in stage 0.0 (TID 53) in 43 ms on 10.1.1.7 (executor 0) (54/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 58.0 in stage 0.0 (TID 58) (10.1.1.7, executor 0, partition 58, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 55.0 in stage 0.0 (TID 55) in 45 ms on 10.1.1.7 (executor 0) (55/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 59.0 in stage 0.0 (TID 59) (10.1.1.7, executor 0, partition 59, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 54.0 in stage 0.0 (TID 54) in 67 ms on 10.1.1.7 (executor 0) (56/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 60.0 in stage 0.0 (TID 60) (10.1.1.7, executor 0, partition 60, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 59.0 in stage 0.0 (TID 59) in 24 ms on 10.1.1.7 (executor 0) (57/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 61.0 in stage 0.0 (TID 61) (10.1.1.7, executor 0, partition 61, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 56.0 in stage 0.0 (TID 56) in 45 ms on 10.1.1.7 (executor 0) (58/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 62.0 in stage 0.0 (TID 62) (10.1.1.7, executor 0, partition 62, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 57.0 in stage 0.0 (TID 57) in 61 ms on 10.1.1.7 (executor 0) (59/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 63.0 in stage 0.0 (TID 63) (10.1.1.7, executor 0, partition 63, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 58.0 in stage 0.0 (TID 58) in 65 ms on 10.1.1.7 (executor 0) (60/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 64.0 in stage 0.0 (TID 64) (10.1.1.7, executor 0, partition 64, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 61.0 in stage 0.0 (TID 61) in 33 ms on 10.1.1.7 (executor 0) (61/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 65.0 in stage 0.0 (TID 65) (10.1.1.7, executor 0, partition 65, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 60.0 in stage 0.0 (TID 60) in 54 ms on 10.1.1.7 (executor 0) (62/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 66.0 in stage 0.0 (TID 66) (10.1.1.7, executor 0, partition 66, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 64.0 in stage 0.0 (TID 64) in 27 ms on 10.1.1.7 (executor 0) (63/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 67.0 in stage 0.0 (TID 67) (10.1.1.7, executor 0, partition 67, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 68.0 in stage 0.0 (TID 68) (10.1.1.7, executor 0, partition 68, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 63.0 in stage 0.0 (TID 63) in 55 ms on 10.1.1.7 (executor 0) (64/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 62.0 in stage 0.0 (TID 62) in 66 ms on 10.1.1.7 (executor 0) (65/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 69.0 in stage 0.0 (TID 69) (10.1.1.7, executor 0, partition 69, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 65.0 in stage 0.0 (TID 65) in 47 ms on 10.1.1.7 (executor 0) (66/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 70.0 in stage 0.0 (TID 70) (10.1.1.7, executor 0, partition 70, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 66.0 in stage 0.0 (TID 66) in 45 ms on 10.1.1.7 (executor 0) (67/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 71.0 in stage 0.0 (TID 71) (10.1.1.7, executor 0, partition 71, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 72.0 in stage 0.0 (TID 72) (10.1.1.7, executor 0, partition 72, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 73.0 in stage 0.0 (TID 73) (10.1.1.7, executor 0, partition 73, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 74.0 in stage 0.0 (TID 74) (10.1.1.7, executor 0, partition 74, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 68.0 in stage 0.0 (TID 68) in 71 ms on 10.1.1.7 (executor 0) (68/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 70.0 in stage 0.0 (TID 70) in 50 ms on 10.1.1.7 (executor 0) (69/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 67.0 in stage 0.0 (TID 67) in 74 ms on 10.1.1.7 (executor 0) (70/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 69.0 in stage 0.0 (TID 69) in 60 ms on 10.1.1.7 (executor 0) (71/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 75.0 in stage 0.0 (TID 75) (10.1.1.7, executor 0, partition 75, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 72.0 in stage 0.0 (TID 72) in 44 ms on 10.1.1.7 (executor 0) (72/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 76.0 in stage 0.0 (TID 76) (10.1.1.7, executor 0, partition 76, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 73.0 in stage 0.0 (TID 73) in 48 ms on 10.1.1.7 (executor 0) (73/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 77.0 in stage 0.0 (TID 77) (10.1.1.7, executor 0, partition 77, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 74.0 in stage 0.0 (TID 74) in 47 ms on 10.1.1.7 (executor 0) (74/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 78.0 in stage 0.0 (TID 78) (10.1.1.7, executor 0, partition 78, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 71.0 in stage 0.0 (TID 71) in 63 ms on 10.1.1.7 (executor 0) (75/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 79.0 in stage 0.0 (TID 79) (10.1.1.7, executor 0, partition 79, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 80.0 in stage 0.0 (TID 80) (10.1.1.7, executor 0, partition 80, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 81.0 in stage 0.0 (TID 81) (10.1.1.7, executor 0, partition 81, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 77.0 in stage 0.0 (TID 77) in 47 ms on 10.1.1.7 (executor 0) (76/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 78.0 in stage 0.0 (TID 78) in 36 ms on 10.1.1.7 (executor 0) (77/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 76.0 in stage 0.0 (TID 76) in 50 ms on 10.1.1.7 (executor 0) (78/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 82.0 in stage 0.0 (TID 82) (10.1.1.7, executor 0, partition 82, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 75.0 in stage 0.0 (TID 75) in 70 ms on 10.1.1.7 (executor 0) (79/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 83.0 in stage 0.0 (TID 83) (10.1.1.7, executor 0, partition 83, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 79.0 in stage 0.0 (TID 79) in 21 ms on 10.1.1.7 (executor 0) (80/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 84.0 in stage 0.0 (TID 84) (10.1.1.7, executor 0, partition 84, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 80.0 in stage 0.0 (TID 80) in 44 ms on 10.1.1.7 (executor 0) (81/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 85.0 in stage 0.0 (TID 85) (10.1.1.7, executor 0, partition 85, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 82.0 in stage 0.0 (TID 82) in 28 ms on 10.1.1.7 (executor 0) (82/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 86.0 in stage 0.0 (TID 86) (10.1.1.7, executor 0, partition 86, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 83.0 in stage 0.0 (TID 83) in 30 ms on 10.1.1.7 (executor 0) (83/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 87.0 in stage 0.0 (TID 87) (10.1.1.7, executor 0, partition 87, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 84.0 in stage 0.0 (TID 84) in 20 ms on 10.1.1.7 (executor 0) (84/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 88.0 in stage 0.0 (TID 88) (10.1.1.7, executor 0, partition 88, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 81.0 in stage 0.0 (TID 81) in 65 ms on 10.1.1.7 (executor 0) (85/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 89.0 in stage 0.0 (TID 89) (10.1.1.7, executor 0, partition 89, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 88.0 in stage 0.0 (TID 88) in 12 ms on 10.1.1.7 (executor 0) (86/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 90.0 in stage 0.0 (TID 90) (10.1.1.7, executor 0, partition 90, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 91.0 in stage 0.0 (TID 91) (10.1.1.7, executor 0, partition 91, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 87.0 in stage 0.0 (TID 87) in 48 ms on 10.1.1.7 (executor 0) (87/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 89.0 in stage 0.0 (TID 89) in 34 ms on 10.1.1.7 (executor 0) (88/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 92.0 in stage 0.0 (TID 92) (10.1.1.7, executor 0, partition 92, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 86.0 in stage 0.0 (TID 86) in 84 ms on 10.1.1.7 (executor 0) (89/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 93.0 in stage 0.0 (TID 93) (10.1.1.7, executor 0, partition 93, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 90.0 in stage 0.0 (TID 90) in 33 ms on 10.1.1.7 (executor 0) (90/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 94.0 in stage 0.0 (TID 94) (10.1.1.7, executor 0, partition 94, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 91.0 in stage 0.0 (TID 91) in 44 ms on 10.1.1.7 (executor 0) (91/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 95.0 in stage 0.0 (TID 95) (10.1.1.7, executor 0, partition 95, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 92.0 in stage 0.0 (TID 92) in 26 ms on 10.1.1.7 (executor 0) (92/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 96.0 in stage 0.0 (TID 96) (10.1.1.7, executor 0, partition 96, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 85.0 in stage 0.0 (TID 85) in 119 ms on 10.1.1.7 (executor 0) (93/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 97.0 in stage 0.0 (TID 97) (10.1.1.7, executor 0, partition 97, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 95.0 in stage 0.0 (TID 95) in 22 ms on 10.1.1.7 (executor 0) (94/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 98.0 in stage 0.0 (TID 98) (10.1.1.7, executor 0, partition 98, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 96.0 in stage 0.0 (TID 96) in 17 ms on 10.1.1.7 (executor 0) (95/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Starting task 99.0 in stage 0.0 (TID 99) (10.1.1.7, executor 0, partition 99, PROCESS_LOCAL, 9368 bytes) \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 97.0 in stage 0.0 (TID 97) in 24 ms on 10.1.1.7 (executor 0) (96/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 94.0 in stage 0.0 (TID 94) in 51 ms on 10.1.1.7 (executor 0) (97/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 93.0 in stage 0.0 (TID 93) in 62 ms on 10.1.1.7 (executor 0) (98/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 98.0 in stage 0.0 (TID 98) in 29 ms on 10.1.1.7 (executor 0) (99/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSetManager: Finished task 99.0 in stage 0.0 (TID 99) in 37 ms on 10.1.1.7 (executor 0) (100/100)\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSchedulerImpl: Removed TaskSet 0.0, whose tasks have all completed, from pool \n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO DAGScheduler: ResultStage 0 (reduce at SparkPi.scala:38) finished in 3.585 s\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO DAGScheduler: Job 0 is finished. Cancelling potential speculative or zombie tasks for this job\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO TaskSchedulerImpl: Killing all running tasks in stage 0: Stage finished\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO DAGScheduler: Job 0 finished: reduce at SparkPi.scala:38, took 3.680019 s\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"Pi is roughly 3.1423875142387514\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO SparkContext: SparkContext is stopping with exitCode 0.\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO SparkUI: Stopped Spark web UI at http://fv-az837-567.ymagj3ilz1se1nskuisabcixse.ex.internal.cloudapp.net:4040\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO StandaloneSchedulerBackend: Shutting down all executors\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO StandaloneSchedulerBackend$StandaloneDriverEndpoint: Asking each executor to shut down\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:11 INFO MapOutputTrackerMasterEndpoint: MapOutputTrackerMasterEndpoint stopped!\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:12 INFO MemoryStore: MemoryStore cleared\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:12 INFO BlockManager: BlockManager stopped\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:12 INFO BlockManagerMaster: BlockManagerMaster stopped\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:12 INFO OutputCommitCoordinator$OutputCommitCoordinatorEndpoint: OutputCommitCoordinator stopped!\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:12 INFO SparkContext: Successfully stopped SparkContext\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:12 INFO ShutdownHookManager: Shutdown hook called\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:12 INFO ShutdownHookManager: Deleting directory /tmp/spark-119dd964-db66-4a99-9a7f-11689d187e34\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"24/10/13 09:36:12 INFO ShutdownHookManager: Deleting directory /tmp/spark-5191283c-bbae-48f9-b92e-1b4424bddf5f\n"
]
}
],
"source": [
"%%bash\n",
"\n",
"export EXAMPLES_JAR=$(find $SPARK_HOME/examples/jars/ -name \"spark-examples_2*\")\n",
"\n",
"$SPARK_HOME/bin/spark-submit \\\n",
" --class org.apache.spark.examples.SparkPi \\\n",
" --master spark://${HOSTNAME}:7077 \\\n",
" $EXAMPLES_JAR \\\n",
" 100"
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "qE1C7PHKd8UX"
},
"source": [
"What is the estimated value of $\\pi$? (look for the line \"Pi is roughly...\" in the previous output)."
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "xIRE42ruiIUh"
},
"source": [
""
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "pfok0VX5kQtF"
},
"source": [
"## Stop all services"
]
},
{
"cell_type": "code",
"execution_count": 20,
"metadata": {
"colab": {
"base_uri": "https://localhost:8080/"
},
"execution": {
"iopub.execute_input": "2024-10-13T09:36:12.149242Z",
"iopub.status.busy": "2024-10-13T09:36:12.148980Z",
"iopub.status.idle": "2024-10-13T09:36:12.459336Z",
"shell.execute_reply": "2024-10-13T09:36:12.458658Z"
},
"id": "HgXfC0KtiQXH",
"outputId": "2f537c89-9365-4dc1-9db2-86bde0143a76"
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"stopping org.apache.spark.deploy.worker.Worker\r\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"stopping org.apache.spark.deploy.master.Master\r\n"
]
}
],
"source": [
"!$SPARK_HOME/sbin/stop-worker.sh\n",
"!$SPARK_HOME/sbin/stop-master.sh"
]
}
],
"metadata": {
"colab": {
"collapsed_sections": [
"hwUMDMwmOO1z",
"zb-R0RxERENm",
"Z2j7ierLoN_i",
"fNZ37Ymp6ZTU",
"mO-e6Zd9OVbV",
"eQlj1_8nUVSp",
"_-aAKfha8VJc",
"WpLPzLCd_Hh7",
"bcP9hTAh6KwK",
"Da8RMzkSYfn9",
"DD5xg7ep-6EQ"
],
"include_colab_link": true,
"provenance": [],
"toc_visible": true
},
"kernelspec": {
"display_name": "Python 3",
"name": "python3"
},
"language_info": {
"codemirror_mode": {
"name": "ipython",
"version": 3
},
"file_extension": ".py",
"mimetype": "text/x-python",
"name": "python",
"nbconvert_exporter": "python",
"pygments_lexer": "ipython3",
"version": "3.8.18"
}
},
"nbformat": 4,
"nbformat_minor": 0
}
![\"Logo](\"https://github.com/groda/big_data/blob/master/logo_bdb.png?raw=true\"){kind=logo}