无法在火花流应用程序的首选位置启动接收器

Question

我打算在首选位置启动接收器。我有一个有10个工作节点的火花独立群集。我想按照我的规范在所有工作节点中启动4个接收器。为此，我在客户接收器中使用以下代码。

@Override 
public scala.Option<String> preferredLocation(){ 
    scala.Option<String> test = null; 
    if(this.id == 0 || this.id == 1 || this.id == 2){ 
     test = scala.Option.apply("abc1"); 
    } 
    else if(this.id == 3 || this.id == 4 || this.id == 5){ 
     test = scala.Option.apply("abc2"); 
    } 
    else if(this.id == 6 || this.id == 7){ 
     test = scala.Option.apply("abc3"); 
    }else{ 
     test = scala.Option.apply("abc4"); 
    } 
    return test; 
} 

上面的id变量将在启动接收器时由驱动程序设置。 截至目前我硬编码的主机名。但我观察到，接收器不在指定位置（主机）启动。 Spark版本是2.0.1。

Answer 1

我用IP地址替换了主机名。然后问题得到解决。