question: returns a flinkclient that uses the configured config #nimbus_host and config #nimbus_thrift_port as jobmanager address . concode_field_sep int jobManagerPort concode_elem_sep Map<?,?> conf concode_elem_sep String jobManagerHost concode_elem_sep String timeout concode_field_sep void killTopology concode_elem_sep FiniteDuration getTimeout concode_elem_sep void submitTopologyWithOpts concode_elem_sep void killTopologyWithOpts concode_elem_sep FlinkClient getClient concode_elem_sep JobID getTopologyJobId concode_elem_sep ActorRef getJobManager concode_elem_sep void submitTopology
target: FlinkClient function ( final Map arg0 ) { final String loc0 = ( String ) arg0 . get ( Config . NIMBUS_HOST ) ; final int loc1 = Utils . getInt ( arg0 . get ( Config . NIMBUS_THRIFT_PORT ) ) . intValue ( ) ; return new FlinkClient ( arg0 , loc0 , loc1 ) ; }