메뉴 건너뛰기

Bigdata, Semantic IoT, Hadoop, NoSQL

Bigdata, Hadoop ecosystem, Semantic IoT등의 프로젝트를 진행중에 습득한 내용을 정리하는 곳입니다.
필요한 분을 위해서 공개하고 있습니다. 문의사항은 gooper@gooper.com로 메일을 보내주세요.


spark spark notebook 0.7.0설치및 설정

총관리자 2016.11.14 10:51 조회 수 : 160

*참고 : http://sungsoo.github.io/2015/04/24/sparknotebook.html

1. spark-notebook.io에서 다운로드 받아 압축을 푼다.
(Build: |  buildTime-Mon Oct 31 17:22:51 UTC 2016 | formattedShaVersion-0.7.0-c955e71d0204599035f603109527e679aa3bd570 | sbtVersion-0.13.8 | scalaVersion-2.11.8 | sparkNotebookVersion-0.7.0 | hadoopVersion-2.7.2 | jets3tVersion-0.7.1 | jlineDef-(jline,2.12) | sparkVersion-2.0.1 | withHive-true |.)

2. conf/밑에 있는 profiles을 아래와 같이 수정해준다.
(spark가 설치되어 있고 spark의 standalone모드로 사용하는 경우임)

3. ./bin/spark-notebook을 띄워준다.
4. http://localhost:9001로 접근하여 사용한다.

----------------------profiles
-bash-4.1$ vi profiles
{
  "local" : {
    "id" : "local",
    "name" : "Local",
    "template" : {
      "customLocalRepo" : null,
      "customRepos" : null,
      "customDeps" : null,
      "customImports" : null,
      "customSparkConf" : {
        "spark.app.name" : "Notebook",
        "spark.master" : "local[8]",
        "spark.executor.memory" : "1G"
      }
    }
  },
  "standalone" : {
    "id" : "standalone",
    "name" : "Standalone",
    "template" : {
      "customLocalRepo" : null,
      "customRepos" : null,
      "customDeps" : null,
      "customImports" : null,
      "customSparkConf" : {
        "spark.app.name" : "Notebook",
        "spark.master" : "spark://sda1:7077,sda2:7077",
        "spark.executor.memory" : "5G"
      }
    }
  },
  "mesos" : {
    "id" : "mesos",
    "name" : "Mesos",
    "template" : {
      "customLocalRepo" : null,
      "customRepos" : null,
      "customDeps" : null,
      "customImports" : null,
"profiles" 66L, 1712C                                                                                                                                                                                         1,1        꼭대기
{
  "local" : {
    "id" : "local",
    "name" : "Local",
    "template" : {
      "customLocalRepo" : null,
      "customRepos" : null,
      "customDeps" : null,
      "customImports" : null,
      "customSparkConf" : {
        "spark.app.name" : "Notebook",
        "spark.master" : "local[8]",
        "spark.executor.memory" : "1G"
      }
    }
  },
  "standalone" : {
    "id" : "standalone",
    "name" : "Standalone",
    "template" : {
      "customLocalRepo" : null,
      "customRepos" : null,
      "customDeps" : null,
      "customImports" : null,
      "customSparkConf" : {
        "spark.app.name" : "Notebook",
        "spark.master" : "spark://sda1:7077,sda2:7077",
        "spark.executor.memory" : "5G"
      }
    }
  },
  "mesos" : {
    "id" : "mesos",
    "name" : "Mesos",
    "template" : {
      "customLocalRepo" : null,
      "customRepos" : null,
      "customDeps" : null,
      "customImports" : null,
      "customSparkConf" : {
        "spark.app.name" : "Notebook",
        "spark.master" : "mesos://<master>:<port>",
        "spark.executor.memory" : "512m",
        "spark.executor.uri" : "hdfs://<spark>.tgz",
        "spark.driver.host" : "<host>",
        "spark.local.dir" : "<path>"
      }
    }
  },
  "yarn" : {
      "id" : "yarn-client",
                                                                                                                     
번호 제목 글쓴이 날짜 조회 수
21 spark 2.0.0의 api를 이용하는 예제 프로그램 총관리자 2017.03.15 199
20 Scala에서 countByWindow를 이용하기(예제) 총관리자 2018.03.08 235
19 Windows7 64bit 환경에서 Apache Spark 2.2.0 설치하기 총관리자 2017.07.26 260
18 Caused by: java.lang.ClassNotFoundException: org.apache.spark.Logging 발생시 조치사항 총관리자 2017.04.19 284
17 Spark에서 KafkaUtils.createStream()를 이용하여 이용하여 kafka topic에 접근하여 객채로 저장된 값을 가져오고 처리하는 예제 소스 총관리자 2017.04.26 292
16 spark-submit으로 spark application실행하는 다양한 방법 총관리자 2016.05.25 303
15 Apache Spark와 Drools를 이용한 CEP구현 테스트 총관리자 2016.07.15 342
14 Spark 1.6.1 설치후 HA구성 총관리자 2016.05.24 455
13 spark-sql실행시 The specified datastore driver ("com.mysql.jdbc.Driver") was not found in the CLASSPATH오류 발생시 조치사항 총관리자 2016.06.09 455
12 java.lang.OutOfMemoryError: unable to create new native thread오류 발생지 조치사항 총관리자 2016.10.17 469
11 spark-submit 실행시 "java.lang.OutOfMemoryError: Java heap space"발생시 조치사항 총관리자 2018.02.01 517
10 spark client프로그램 기동시 "Error initializing SparkContext"오류 발생할때 조치사항 총관리자 2016.05.27 539
9 spark-shell실행시 "A read-only user or a user in a read-only database is not permitted to disable read-only mode on a connection."오류가 발생하는 경우 해결방법 총관리자 2016.05.20 551
8 spark-env.sh에서 사용할 수있는 항목. 총관리자 2016.05.24 568
7 kafka로 부터 메세지를 stream으로 받아 처리하는 spark샘플소스(spark의 producer와 consumer를 sbt로 컴파일 하고 서버에서 spark-submit하는 방법) 총관리자 2016.07.13 630
6 "Initial job has not accepted any resources; check your cluster UI to ensure that workers are registered and have sufficient resources"오류 발생시 조치사항 총관리자 2016.05.25 1030
5 spark stream처리할때 두개의 client프로그램이 동일한 checkpoint로 접근할때 발생하는 오류 내용 총관리자 2018.01.16 1115
4 Spark 2.1.1 clustering(5대) 설치(YARN기반) 총관리자 2016.04.22 1882
3 VisualVM 1.3.9을 이용한 spark-submit JVM 모니터링을 위한 설정및 spark-submit실행 옵션 총관리자 2016.10.28 1891
2 spark-sql실행시 Caused by: java.lang.NumberFormatException: For input string: "0s" 오류발생시 조치사항 총관리자 2016.06.09 2802

A personal place to organize information learned during the development of such Hadoop, Hive, Hbase, Semantic IoT, etc.
We are open to the required minutes. Please send inquiries to gooper@gooper.com.

위로