Spark-远程调试

Spark-远程调试

第一种方法：

1、启动需要调试项目jar命令：（参考原始命令）

./bin/spark-submit --master yarn --deploy-mode cluster 
--num-executors 8 
--executor-cores 4 
--executor-memory 12G 
--driver-java-options "Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=18888" 
--class com.proj.user_behavior.UserBehaviorCleaner UserBehaviorCleaner.jar 
hdfs://linux102:9000/user/hive/warehouse/ods.db/origin_user_behavior/${day}  
hdfs://linux102:9000/user/hive/warehouse/tmp.db/user_behavior_${day}

（测试通过命令）

./bin/spark-submit 
--driver-java-options "-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=18888" 
--class com.proj.user_behavior.UserBehaviorCleaner UserBehaviorCleaner.jar 
hdfs://linux102:9000/user/hive/warehouse/ods.db/origin_user_behavior/20220101  
hdfs://linux102:9000/user/hive/warehouse/tmp.db/user_behavior_20220101

2、之后，程序就会阻塞，接着去Idea debug运行项目即可。

第二种方法：

1、直接运行spark-shell命令

./bin/spark-shell --jars ./UserBehaviorCleaner.jar

2、之后把项目中的代码直接扔进去执行即可

scala> def repairUsername(event: String) = {
     |     val fields = event.split("t")
     |     // 取出用户昵称
     |     val username = fields(1)
     |     // 用户昵称不为空时替代"n"
     |     if (username) != null && !"".equals(username)) {
     |       fields(1) = username.replace("n","")  
     |     }
     |     fields.mkString("t")
     | }
repairUsername： (event: String) String