Sqoop SQL Server проверка подлинности Windows - PullRequest
0 голосов
/ 10 января 2019

Мы хотим получить данные из MS SQL Server в hadoop, используя SQOOP с аутентификацией Windows.

Я использую приведенную ниже команду sqoop для извлечения информации -

Sqoop eval --connect "jdbc: jtds: sqlserver: // IP: номер порта; databaseName = test; domain = Domain_Name; useNTLMv2 = true" --username XXX --password XXXXXX --query 'SELECT * FROM INFORMATION_SCHEMA. КОЛОННЫ, где $ CONDITIONS '--driver net.sourceforge.jtds.jdbc.Driver

При выполнении вышеупомянутого sqoop cmd выдает ошибку -

       WARN tool.EvalSqlTool: SQL exception executing statement: java.sql.SQLException: I/O Error: DB server closed connection.
        at net.sourceforge.jtds.jdbc.TdsCore.nextToken(TdsCore.java:2388)
        at net.sourceforge.jtds.jdbc.TdsCore.login(TdsCore.java:609)
        at net.sourceforge.jtds.jdbc.JtdsConnection.<init>(JtdsConnection.java:369)
        at net.sourceforge.jtds.jdbc.Driver.connect(Driver.java:183)
        at java.sql.DriverManager.getConnection(DriverManager.java:571)
        at java.sql.DriverManager.getConnection(DriverManager.java:215)
        at org.apache.sqoop.manager.SqlManager.makeConnection(SqlManager.java:904)
        at org.apache.sqoop.manager.GenericJdbcManager.getConnection(GenericJdbcManager.java:52)
        at org.apache.sqoop.tool.EvalSqlTool.run(EvalSqlTool.java:64)
        at org.apache.sqoop.Sqoop.run(Sqoop.java:147)
        at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70)
        at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:183)
        at org.apache.sqoop.Sqoop.runTool(Sqoop.java:234)
        at org.apache.sqoop.Sqoop.runTool(Sqoop.java:243)
        at org.apache.sqoop.Sqoop.main(Sqoop.java:252)
    Caused by: java.io.IOException: DB server closed connection.
        at net.sourceforge.jtds.jdbc.SharedSocket.readPacket(SharedSocket.java:883)
        at net.sourceforge.jtds.jdbc.SharedSocket.getNetPacket(SharedSocket.java:762)
        at net.sourceforge.jtds.jdbc.ResponseStream.getPacket(ResponseStream.java:477)
        at net.sourceforge.jtds.jdbc.ResponseStream.read(ResponseStream.java:114)
        at net.sourceforge.jtds.jdbc.TdsCore.nextToken(TdsCore.java:2282)
...