How do I get the IP of the master and slave files programmatically in Flink?

[Felipe Gutierrez]

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