【详述】 val starrocksSparkDF = spark.read.format(“starrocks”)
.option(“starrocks.table.identifier”, s"$starRocksName.$tblNameSrc")
.option(“starrocks.fenodes”, s"$srFe:$port")
.option(“user”, userName)
.option(“password”, password)
.load().repartition(partitions)
依赖包是论坛大神的包(https://forum.mirrorship.cn/t/topic/3785)
spark连接starrocks 报错:Exception in thread “main” com.starrocks.connector.spark.exception.ConnectedFailedException: Connect to http://xxx:9030/api/test/student/_schemafailed, status code is -1.
各位大神帮忙看下是什么原因