Spark通过JDBC读取数据之前很早写过一篇博客,本以为所有通过jdbc读取的方式都一样,谁知道这次读sqlserver的时候竟然出现的很多异常,这里把异常的问题进行记录。
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;
public class Test {
public static void main(String[] args) {
SparkSession spark = SparkSession.builder().appName("test").master("local").getOrCreate();
String url = "jdbc:sqlserver://;serverName=10.xx.xx.xx;databaseName=db";
String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
String user = "user";
String password = "password";
String query = "select * from tb";
Dataset<Row> ds = spark.read().format("jdbc")
.option(