obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/ObHbaseReader.java [212:246]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            if (configUrl == null) {
                try {
                    Connection conn = null;
                    int retry = 0;
                    final String sysJDBCUrl = serverInfo.jdbcUrl.replace(serverInfo.databaseName, "oceanbase");
                    do {
                        try {
                            if (retry > 0) {
                                int sleep = retry > 9 ? 500 : 1 << retry;
                                try {
                                    TimeUnit.SECONDS.sleep(sleep);
                                } catch (InterruptedException e) {
                                }
                                LOG.warn("retry fetch RsUrl the {} times", retry);
                            }
                            conn = DBUtil.getConnection(DataBaseType.OceanBase, sysJDBCUrl, serverInfo.sysUser, serverInfo.sysPass);
                            String sql = "show parameters like 'obconfig_url'";
                            LOG.info("query param: {}", sql);
                            PreparedStatement stmt = conn.prepareStatement(sql);
                            ResultSet result = stmt.executeQuery();
                            if (result.next()) {
                                configUrl = result.getString("Value");
                            }
                            if (StringUtils.isNotBlank(configUrl)) {
                                break;
                            }
                        } catch (Exception e) {
                            ++retry;
                            LOG.warn("fetch root server list(rsList) error {}", e.getMessage());
                        } finally {
                            DBUtil.closeDBResources(null, conn);
                        }
                    } while (retry < 3);

                    LOG.info("configure url is: " + configUrl);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



obhbasewriter/src/main/java/com/alibaba/datax/plugin/writer/obhbasewriter/ObHbaseWriter.java [123:157]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            if (configUrl == null) {
                try {
                    Connection conn = null;
                    int retry = 0;
                    final String sysJDBCUrl = serverInfo.jdbcUrl.replace(serverInfo.databaseName, "oceanbase");
                    do {
                        try {
                            if (retry > 0) {
                                int sleep = retry > 9 ? 500 : 1 << retry;
                                try {
                                    TimeUnit.SECONDS.sleep(sleep);
                                } catch (InterruptedException e) {
                                }
                                LOG.warn("retry fetch RsUrl the {} times", retry);
                            }
                            conn = DBUtil.getConnection(DataBaseType.OceanBase, sysJDBCUrl, serverInfo.sysUser, serverInfo.sysPass);
                            String sql = "show parameters like 'obconfig_url'";
                            LOG.info("query param: {}", sql);
                            PreparedStatement stmt = conn.prepareStatement(sql);
                            ResultSet result = stmt.executeQuery();
                            if (result.next()) {
                                configUrl = result.getString("Value");
                            }
                            if (StringUtils.isNotBlank(configUrl)) {
                                break;
                            }
                        } catch (Exception e) {
                            ++retry;
                            LOG.warn("fetch root server list(rsList) error {}", e.getMessage());
                        } finally {
                            DBUtil.closeDBResources(null, conn);
                        }
                    } while (retry < 3);

                    LOG.info("configure url is: " + configUrl);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -