Apache Spark에서 debug 기능을 사용해 보았습니다.

5051 단어 스파크Scala
Apache Spark에서 IntelliJ의 debug 기능을 사용해 보았습니다.

spark-submit 명령

hisashinoMacBook-Pro:apache-spark-csv-sample hisashi$ sudo $SPARK_HOME/bin/spark-submit --class com.sample.csv.spark.SparkCSVSample --master "local[2]" --driver-java-options "-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5005" target/scala-2.11/spark_csv_sample_2.11-1.0.0.jar logs/ tmp/spark_csv_sample.csv /hoge,/piyo

コンソール上にこんなメッセージがでてきた
Listening for transport dt_socket at address: 5005

spark-submit 명령

$SPARK_HOME/bin/spark-submit 
  --class com.sample.csv.spark.SparkCSVSample 
  --master "local[2]" 
  --driver-java-options "-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5005" ←(ここを IntelliJのCommand line arguments for running remote JVM の定義に合わせるらしい)
  target/scala-2.11/spark_csv_sample_2.11-1.0.0.jar 
  logs/ tmp/spark_csv_sample.csv /hoge,/piyo


미리 IntelliJ의 디버그 모드를 설정해 두어.


벌레의 표시를 켭니다.


오! . 포인터를 둔 곳에 머물렀다.


참고 사이트: 죄송합니다. 다음 사이트의 프로그램을 기반으로합니다.
Apache Spark를 사용하여 액세스 로그를 구문 분석하고 결과를 CSV 파일로 출력했습니다.

좋은 웹페이지 즐겨찾기