Hi Felippe, could you clarify in some more details what you are trying to achieve?
Best regards, -- Alexander Fedulov | Solutions Architect +49 1514 6265796 <https://www.ververica.com/> Follow us @VervericaData -- Join Flink Forward <https://flink-forward.org/> - The Apache Flink Conference Stream Processing | Event Driven | Real Time -- Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany -- Ververica GmbH Registered at Amtsgericht Charlottenburg: HRB 158244 B Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji (Tony) Cheng On Wed, May 20, 2020 at 1:14 PM Felipe Gutierrez < felipe.o.gutier...@gmail.com> wrote: > Hi all, > > I have my own operator that extends the AbstractUdfStreamOperator > class and I want to issue some messages to it. Sometimes the operator > instances are deployed on different TaskManagers and I would like to > set some attributes like the master and slave IPs on it. > > I am trying to use these values but they only return localhost, not > the IP configured at flink-conf.yaml file. (jobmanager.rpc.address: > 192.168.56.1). > > ConfigOption<String> restAddressOption = ConfigOptions > .key("rest.address") > .stringType() > .noDefaultValue(); > System.out.println("DefaultJobManagerRunnerFactory rest.address: " + > jobMasterConfiguration.getConfiguration().getValue(restAddressOption)); > System.out.println("rpcService: " + rpcService.getAddress()); > > > Thanks, > Felipe > > -- > -- Felipe Gutierrez > -- skype: felipe.o.gutierrez > -- https://felipeogutierrez.blogspot.com >
