[ https://issues.apache.org/jira/browse/HDFS-14079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701856#comment-16701856 ]
Brahma Reddy Battula commented on HDFS-14079: --------------------------------------------- [~surendrasingh] thanks for reporting and working on this. * As [~linyiqun] pointed consistency will be problem.we might need to retry till state store refreshed ( which is by default 60 Sec).looks you used TRY_ONCE_THEN_FAIL. Please add testcases for that. Ideally admin operations will be rare(add,ls,safemode..),May be because of this it was not implemented.? * @ProtocolInfo(protocolName = HdfsConstants.CLIENT_NAMENODE_PROTOCOL_NAME, Not sure whether this intened.[~elgoiri] can you confirm same.Even this can be done in seperate jira. * IMO, Instead of exposing config for admin address(which needs additional validation),RouterStateManager has admin address like below.SO we can use that? {code:java} List<RouterState> cachedRecords = router.getRouterStateManager().getCachedRecords(); String adminAddress = routerState.getAdminAddress(); {code} > RBF: RouterAdmin should have failover concept for router > -------------------------------------------------------- > > Key: HDFS-14079 > URL: https://issues.apache.org/jira/browse/HDFS-14079 > Project: Hadoop HDFS > Issue Type: Sub-task > Affects Versions: 3.1.1 > Reporter: Surendra Singh Lilhore > Assignee: Surendra Singh Lilhore > Priority: Major > Attachments: HDFS-14079-HDFS-13891.01.patch, > HDFS-14079-HDFS-13891.02.patch > > > Currenlty {{RouterAdmin}} connect with only one router for admin operation, > if the configured router is down then router admin command is failing. It > should allow to configure all the router admin address. > {code} > // Initialize RouterClient > try { > String address = getConf().getTrimmed( > RBFConfigKeys.DFS_ROUTER_ADMIN_ADDRESS_KEY, > RBFConfigKeys.DFS_ROUTER_ADMIN_ADDRESS_DEFAULT); > InetSocketAddress routerSocket = NetUtils.createSocketAddr(address); > client = new RouterClient(routerSocket, getConf()); > } catch (RPC.VersionMismatch v) { > System.err.println( > "Version mismatch between client and server... command aborted"); > return exitCode; > } > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005) --------------------------------------------------------------------- To unsubscribe, e-mail: hdfs-issues-unsubscr...@hadoop.apache.org For additional commands, e-mail: hdfs-issues-h...@hadoop.apache.org