-
[Spark Streaming] spark-streaming-kafka 실행 오류 해결 (feat. 파일 경로 옮기기)DataProcessing/Spark 2021. 2. 24. 23:21728x90
Spark Streaming App 실행 시 오류:
Spark Streaming's Kafka libraries not found in the class path. Try one of the following.
1. spark-submit 명령어에 spark-streaming-kafka 버전 추가해주기
Include the Kafka library and its dependencies with in the spark-submit command as
$ bin/spark-submit --packages org.apache.spark:spark-streaming-kafka-0-8_2.11:2.4.7 spark_consumer.py(실행파일)2. spark-streaming-kafka-0-8-assembly_2.11-2.4.7.jar 파일 다운로드 후 spark-submit 명령어에 추가하기
Download the JAR of the artifact from Maven Central http://search.maven.org/, Group Id = org.apache.spark, Artifact Id = spark-streaming-kafka-0-8-assembly, Version = 2.4.7.
Then, include the jar in the spark-submit command as
$ bin/spark-submit --jars <spark-streaming-kafka-0-8-assembly.jar>두 가지 방법 모두 실패 => 해결방법:
spark-streaming-kafka-0-8-assembly_2.11-2.4.7.jar 파일을 Spark 프로그램 폴더 안에 jars 폴더로 옮겨주기
$ mv {옮길 파일명} {옮길 경로}
$ mv spark-streaming-kafka-0-8-assembly_2.11-2.4.7.jar ~/programs/Spark/spark-2.4.7-bin-hadoop2.7/jars- 이상 오늘의 삽질일기 끝!
여기저기 삽질도 해보고
날려도 먹으면서
배우는 게
결국 남는거다
- Z.Sabziller
'DataProcessing > Spark' 카테고리의 다른 글
[Spark] Pyspark 데이터프레임을 JSON 딕셔너리로 변환하기 (0) 2021.03.01 [Spark Streaming] PySpark 데이터프레임 모든 컬럼 json으로 변환 & 데이터프레임 딕셔너리 내부 value값 dict 변환 (2) 2021.02.25 [Spark Streaming] Kafka-Spark Streaming-Cassandra 연동 (feat.pyspark) (0) 2021.02.23 [Spark Streaming] Kafka TransformedDStream 변환하기 (0) 2021.02.19 [Spark Streaming] Tutorial #1 트윗 데이터 실시간 스트리밍(feat. Kafka, Pyspark) (0) 2021.02.18