stalary commented on a change in pull request #3454:
URL: https://github.com/apache/incubator-doris/pull/3454#discussion_r427005963
##########
File path: fe/src/main/java/org/apache/doris/external/EsStateStore.java
##########
@@ -74,37 +59,48 @@ public void registerTable(EsTable esTable) {
return;
}
esTables.put(esTable.getId(), esTable);
- LOG.info("register a new table [{}] to sync list", esTable.toString());
+ LOG.info("register a new table [{}] to sync list", esTable);
}
public void deRegisterTable(long tableId) {
esTables.remove(tableId);
LOG.info("deregister table [{}] from sync list", tableId);
}
-
+
@Override
protected void runAfterCatalogReady() {
for (EsTable esTable : esTables.values()) {
try {
- EsRestClient client = new EsRestClient(esTable.getSeeds(),
- esTable.getUserName(), esTable.getPasswd());
- // if user not specify the es version, try to get the remote
cluster versoin
- // in the future, we maybe need this version
- String indexMetaData =
client.getIndexMetaData(esTable.getIndexName());
- if (indexMetaData == null) {
+ EsRestClient client = new EsRestClient(esTable.getSeeds(),
esTable.getUserName(),
Review comment:
I think this is ok, I will modify it later
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
