代码和报错如下
代码片段:
public static void main(String[] args) throws Exception {
//String ip = "137.0.253.6";
String url = "http://137.0.253.70:12000/sqoop/";
SqoopClient client = new SqoopClient(url);
//1 源端连接
// long connectorId = 1;
MLink fromLink = client.createLink("oracle-jdbc-connector");
fromLink.setName("jdbcLink");
fromLink.setCreationUser("Buffy");
MLinkConfig fLinkConfig = fromLink.getConnectorLinkConfig();
// 填入连接配置的值
fLinkConfig.getStringInput("linkConfig.connectionString").setValue("jdbc:oracle:thin:@136.10.223.14:1921:cm");
报错:
Caused by: org.apache.sqoop.common.SqoopException: MODEL_010:Config do not exist - config name: linkConfig
配置中没有“linkConfig”,检查一下