特牛生活网

Java启动sparksql,Java提交sparksql任务及问题分析_身登青云梯的博客-CSDN博客

网友收藏
SparkSession spark = SparkSession.builder().enableHiveSupport() //这个必须加,是获取hivemetastore.getOrCreate();spark.sql("use " + args[0]);//args[0] is database ,args[1]为sql语句, args[2]为输出hdfs目录,格式"/task/data..._unregistering applicationmaster with failed (diag message: driver has been d