Как использовать системные таблицы Sqoop CDC с сервера sql

Я могу вытащить таблицы с сервера sql с помощью команды sqoop:

База данных Sql: таблица MyDB sql: dbo.TestTable

sqoop import  
     -connect 'jdbc:sqlserver://xx.xxx.xxx.xxx;database=MyDB' 
     --username Cread -P 
     --table TestTable 
     --hcatalog-database  default 
     --hcatalog-table testTable_hive   
     --create-hcatalog-table  
     --hcatalog-storage-stanza "stored as orc"

Теперь я пытаюсь вытащить таблицу CDC cdc.dbo_TestTable_CT в базу данных MyDB sql.

sqoop import  
     -connect 'jdbc:sqlserver://xx.xxx.xxx.xxx;database=MyDB' 
     --username Cread -P 
     --table cdc.TestTable_CT
     --hcatalog-database  default 
     --hcatalog-table testTable_hive   
     --create-hcatalog-table  
     --hcatalog-storage-stanza "stored as orc"

выдает ошибку недопустимое имя объекта. Похоже, что по умолчанию он ищет в dbo и не может найти таблицы cdc.

Может кто-нибудь, пожалуйста, помогите мне, как вытащить таблицы CDC?

Спасибо.


sql-server hive sqoop
person Naveen    schedule 07.03.2017    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Вы пытались просто передать схему вот так?

 sqoop import  
     -connect 'jdbc:sqlserver://xx.xxx.xxx.xxx;database=MyDB' 
     --username Cread -P 
     --table TestTable_CT
     -- --schema cdc
     --hcatalog-database  default 
     --hcatalog-table testTable_hive   
     --create-hcatalog-table  
     --hcatalog-storage-stanza "stored as orc"
person MPR    schedule 07.03.2017