apache-zeppelin

0열

1답변

최근 Mac OS Siera 10.2에 apache zeppelin 0.6.2를 설치했는데, 불꽃 및 파이썬 예제를 실행할 수 있지만 %r 또는 %spark.r을 사용하여 R 코드를 실행하려고합니다. 오류가 발생했습니다. .bash_profile에 이미 SPARK_HOME과 SCALA_HOME을 설정했습니다. 오류 로그를 부착 : 그냥 .bash_profi

3열

1답변

Zep Notebooks의 동적 폼 + SparkSQL 변수 바인딩

Zep Notebook에서 SparkSQL을 사용하여 dynamic form의 입력을 받아들이면 Angular interpreter과 같은 방식으로 바인딩 할 수 있습니까? 나는 Zep Notebook에서 SparkSQL을 사용하여 대시 보드를 만들려고하는데, 사용자가 노트북의 시작 부분에 범용 변수 값을 입력하고 여러 단락을 적용 할 수있게하려고합니다.

0열

1답변

Zeppelin의 scala/python 환경에서 변수 'z'로 ZeppelinContext를 주입하는 방법은 무엇입니까? 나에게 제플린에 스칼라/파이썬 환경에서 변수 'Z'로 ZeppelinContext 주입하는 방법을 비행선을 알 수

, 나는 그것이 내부 원리를 알고 싶습니다.

0열

1답변

펠린 : 스파크 인터프리터 사용`Isolated` 모드는

제플린은 3 통역 옵션을 제공합니다 Shared: 단일 통역 및 스파크 컨텍스트 (그리고 당신이 볼 대기) Isolated: 모든 노트북은 자신의 통역 및 스파크 컨텍스트를 가지고 내가 Shared 모드를 사용했다 Scoped: 모든 노트북은 자신의 통역을 가지고 있지만 스파크 상황을 지금까지 을 공유하는 잘 작동했다. 하지만 문제는 두 개의 노트북을 동시

0열

1답변

제 플린의 모든 노트를 하나로 병합하는 방법은 무엇입니까?

나는 zeppelin의 notebook1과 notebook2를 가지고 있는데, 하나는 mongodb에서 왔고 다른 하나는 sql에서 왔습니다. 두 노트북을 병합하는 방법, pls 도움.

1열

1답변

Spotify/kafka (Windows 10에서 실행)로 실행중인 로컬 Docker Container가 있으므로 Zockppelin에서 Spark with Spark를 사용하여 Docker

에서 실행하십시오. 이 컨테이너에는 "데이터"라는 주제로 게시 된 데이터가 있습니다. 나는과 같이 이클립스에서 실행되는 자바 응용 프로그램에서 데이터를 사용할 수 있습니다이 private String topicName; private ConsumerConfig config; public KafkaConsumer() throws Excep

1열

2답변

Zeppelin : zeppelin에서 sparkContext를 다시 시작하는 방법

격리 모드의 zeppelins spark 인터프리터를 사용하고 있습니다.이 모드에서는 spark 클러스터의 각 노트북에 대해 새로운 작업이 시작됩니다. 노트북 실행이 완료되면 제플린 (zeppelin)을 통해 작업을 종료하고 싶습니다. 이를 위해 sc.stop이 sparkContext를 중지했으며 작업도 spark cluster에서 중지되었습니다. 그러나

0열

1답변

Zeppelin에서 양식 zeppelin.x.y의 매개 변수 값을 어떻게 변경할 수 있습니까?

특히, 의 값을 어떻게 변경할 수 있습니까? zeppelin.spark.sql.stacktrace? '.' ''X '를 선택'근처 입력을 인식 할 수 없습니다 : 오류 메시지는 다음과 같은 설명을 제공합니다 표현 규격에서; 본선 64 POS (10) 설정 zeppelin.spark.sql.stacktrace은 = 전체 스택 트레이스를 볼 수 하지만, 정확히

0열

1답변

Apache Zeppelin이 집계 데이터를 반환하지 않습니다.

Apache Spark 2.0.1 및 Apache Zeppelin 0.6.2를 실행하고 있습니다.이 val df = sqlContext .read .format("org.apache.spark.sql.cassandra") .options(Map("table" -> "iot_data2", "keyspace" -> "iot"))

0열

1답변

Zeppelin을 통해 Spark에서 사용할 로컬 드라이브에서 VMWare HDP 2.5 Sandbox로 파일을 가져올 수 있습니까?

VMWare의 HDP 2.5 샌드 박스에서 실행중인 Spark 프로그램에서 로컬 텍스트 파일을 사용하고 싶습니다. 1) VM의 HDFS에서 직접 가져 오는 드래그 앤 드롭 방식이 있습니까? 2) Zeppelin을 사용하여 가져올 수 있습니까? 그렇다면 Spark에서 절대 경로 (위치)를 얻는 방법은 무엇입니까? 3) 다른 방법이 있습니까? 그렇다면 어떻게하