前言
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"; Datasetds = spark.read().format("jdbc") .option(
猜你喜欢
网友评论
- 搜索
- 最新文章
- 热门文章