spark读sqlserver出现的异常

发布时间:2024年01月08日

前言

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(
文章来源:https://blog.csdn.net/Android_xue/article/details/135456744
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。