无法使用azure-activedirectory-library-for-java库连接Spark YARN集群中使用Java的Azure SQL DB

Question

https://github.com/azure/azure-sqldb-spark

https://docs.microsoft.com/en-us/azure/sql-database/sql-database-spark-connector

提前谢了。

18/10/08 10:07:16警告sparksession$builder：使用现有的sparksession；某些配置可能无法生效。18/10/08 10:07:16错误ApplicationMaster：用户类引发异常：com.microsoft.sqlserver.jdbc.sqlserverException：用户“”登录失败。ClientConnectionID:8ecbc2ae-cede-4b1d-8eba-f362010f71e6 com.microsoft.sqlserver.jdbc.sqlserverException:用户“”登录失败。ClientConnectionID:8ECBC2AE-CEDE-4B1D-8EBA-F362010F71E6 at com.microsoft.sqlServer.jdbc.sqlServerException.MakefromDatabaseError(SqlServerException.java:217)at com.microsoft.sqlServer.jdbc.tdStokenHandler.One(TdSparser.java:251)at com.microsoft.sqlServer.jdbc.tdSparser.parse(TdSparser.java:81)at.jdbc.sqlserverconnection.logon(sqlserverconnection.java:2360)在com.microsoft.sqlserver.jdbc.sqlserverconnection.access$100(sqlserverconnection.java:43)在.com.microsoft.sqlserver.jdbc.sqlserverconnection.log的。connectHelper(SqlServerConnection.java:1404)在(sqlserverconnection.java:1068)的com.microsoft.sqlserver.jdbc.sqlserverconnection.connectintern(sqlserverconnection.java:904)的com.microsoft.sqlserver.jdbc.sqlserverconnection.connect(sqlserverconnection.java:451)的com.microsoft.sqlserver.jdbc.sqlserverdriver.connect(sqlserverconnection.java:451)的connect datasources.jdbc.jdbcutils$$anonfun$createConnectionFactory$1.Applic(jdbcutils.scala:52)在org.apache.spark.sql.execution.datasources.jdbc.jdbcrdd$.resolvetable(jdbcrd.scala:58)在org.apache.spark.sql.execution.datasources.jdbc.jdbcrelation.(jdbcrelation.scala:114)在org.apache.spark.sql.execution.datasources.datasource.resolverelation（datasource.scala:309)位于org.apache.spark.sql.dataframereader.load（DataFrameReader.scala:178)在org.apache.spark.sql.dataframereader.load（dataframereader.scala:146)在org.apache.spark.sql.dataframereader.jdbc（dataframereader.scala:193)在com.microsoft.azure.sqldb.spark.connect.dataframereader.scala:44)在com.sew.data.dataframereader.sqlderfunctions.sqldb（nativeMethodAccessorImpl.Invoke0（原生方法）在sun.reflect.nativeMethodAccessorImpl.Invoke(nativeMethodAccessorImpl.java:62)在sun.reflect.DelegatingMethodAccessorImpl.Invoke(DelegatingMethodAccessorImpl.java:43)在java.lang.reflect.Method.Invoke(Method.java:498)在异常：用户“|”登录失败。ClientConnectionID:8ecbc2ae-cede-4b1d-8eba-f362010f71e6)18/10/08 10:07:16 INFO sparkcontext：从关机钩子调用stop（）18/10/08 10:07:16 INFO abstractConnector：Stopped spark@683861d4{http/1.1,[http/1.1]}{0.0.0.0:0}

Answer 1

问题是用户“”登录失败。没有看到登录试图使用的用户名？

18/10/08 10:07:16错误ApplicationMaster：用户类引发异常：com.microsoft.sqlserver.jdbc.sqlserverException：用户“”登录失败。ClientConnectionID:8ecbc2ae-cede-4b1d-8eba-f362010f71e6 com.microsoft.sqlserver.jdbc.sqlserverException:用户“”登录失败。ClientConnectionID:8ECBC2AE-Cede-4B1D-8EBA-F362010F71E6 at com.microsoft.sqlserver.jdbc.sqlserverException.MakefromDatabaseError

您试图以哪个用户的身份连接？是否根据创建Azure Active Directory的说明将此标识添加为“包含的数据库用户”：

设置要求

如果使用基于访问令牌的身份验证模式，则需要下载azure-activedirectory-library-for-java及其依赖项，并将它们包含在Java构建路径中。

请参见使用Azure Active Directory身份验证对SQL数据库进行身份验证，以了解如何获取对Azure SQL数据库的访问令牌。