Only one SparkContext may be running in this JVM (see SPARK-2243). To ignore this error, set spark.d
1660 단어 SparkStreaming
해결: 이 오류는 여러 개의 sparkContext를 만들었기 때문입니다. 일반적으로 StreamingContext를 만들 때 SparkContext를 사용했기 때문입니다.
val conf = new SparkConf().setAppName("SparkStreamingAndKafka").setMaster("local[2]")
val sc = new SparkContext(conf)
val ssc = new StreamingContext(conf, Seconds(5))
val sc = new SparkContext 주석 삭제하기
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
SparkStreaming+Kafka는 캐시 기반의 실시간 wordcount 프로그램을 실현합니다내 오리지널 주소:https://dongkelun.com/2018/06/14/updateStateBykeyWordCount/ 전언 본고는 SparkStreaming과 Kafka를 이용하여 캐시 기반의 실시간 word...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
