如何从 sql 服务器 Sqoop CDC 系统表

Question

我可以使用 sqoop 命令从 sql 服务器中提取 tables:

Sql数据库：MyDB sql table: 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"

现在我正在尝试在 MyDB sql 数据库中提取 CDC table cdc.dbo_TestTable_CT。

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 tables。

有人可以帮我拉 CDC tables 吗？

谢谢。

Answer 1

您试过像这样传递架构吗？

 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"

如何从 sql 服务器 Sqoop CDC 系统表

How to Sqoop CDC system tables from sql server

sql-server

hive

sqoop