Flink Task Manager如何预先设置几个设置
我需要下载密钥库并在创建源连接器时使用并使用它,目前,我正在覆盖方法但是,这被我的每个源连接器都要求。
@Override
public void open(Configuration configuration) throws Exception {
// do few things like download Keystore to default path etc
super.open(configuration)
}
一旦任务经理出现,是否可以选择一些预先的东西?
I need to download Keystore and use it while creating the source connector, currently, I am overriding open method but this gets called for each of my source connectors.
@Override
public void open(Configuration configuration) throws Exception {
// do few things like download Keystore to default path etc
super.open(configuration)
}
Is there an option to init a few pre stuff as soon as the task manager came up?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论