我在分布式模式下启动worker并使用rest api启动一个连接器,在hdfssinkconnector类的start()中有一个print语句:
@Override
public void start(Map<String, String> props) throws ConnectException {
System.out.println("In connector start method()");
}
我看到这个方法被同一个连接器调用了两次,这会导致问题,因为我需要在这个start()方法中包含自定义初始化,我不希望它们被初始化两次。
1) start()方法何时调用?
2) 尽管我只启动了一个连接器,并且检查了同一个辅助服务中没有运行其他连接器,但为什么它会被调用两次?
3) 如何确保每个连接器只调用一次start()方法?
暂无答案!
目前还没有任何答案,快来回答吧!