database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

tmp_partition_qa1

Browse Source
This commit is contained in:
morningman
2020-05-14 15:21:05 +08:00
parent e69e199df1
commit fc02ce8034
1 changed files with 1 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
fe/src/main/java/org/apache/doris/cluster/Cluster.java
View File

@ -17,12 +17,12 @@
package org.apache.doris.cluster;
import com.google.common.base.Preconditions;
import org.apache.doris.catalog.InfoSchemaDb;
import org.apache.doris.common.io.Text;
import org.apache.doris.common.io.Writable;
import org.apache.doris.persist.LinkDbInfo;
import com.google.common.base.Preconditions;
import com.google.common.base.Strings;
import com.google.common.collect.Lists;
@ -128,9 +128,6 @@ public class Cluster implements Writable {
dbNames.add(name);
dbIds.add(id);
dbNameToIDs.put(name, id);
LOG.info("after cluster {} add db: {}-{}, dbIds: {}, dbNames: {}, dbNameToIDs: {}",
this.name, name, id, dbIds, dbNames, dbNameToIDs);
} finally {
unlock();
}
@ -153,8 +150,6 @@ public class Cluster implements Writable {
try {
dbNames.remove(name);
dbIds.remove(id);
LOG.info("after cluster {} remove db: {}-{}, dbIds: {}, dbNames: {}, dbNameToIDs: {}",
this.name, name, id, dbIds, dbNames, dbNameToIDs);
} finally {
unlock();
}
@ -209,8 +204,6 @@ public class Cluster implements Writable {
dbCount--;
}
LOG.info("write cluster: {}, dbIds: {}, dbNames: {}, dbNameToIDs: {}",
this.name, dbIds, dbNames, dbNameToIDs);
out.writeInt(dbCount);
// don't persist InfoSchemaDb meta
for (String name : dbNames) {
@ -277,7 +270,5 @@ public class Cluster implements Writable {
value.readFields(in);
linkDbIds.put(key, value);
}
LOG.info("read cluster: {}, dbIds: {}, dbNames: {}, dbNameToIDs: {}",
this.name, dbIds, dbNames, dbNameToIDs);
}
}