#1476 add size check and change disable flag checked (#1511)

actiontech · Nov 20, 2019 · 28c8819 · 28c8819
1 parent 24b4a4e
commit 28c8819
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDNPoolSingleWH.java b/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDNPoolSingleWH.java
@@ -182,7 +182,7 @@ public Map<Integer, PhysicalDatasource[]> getStandbyReadSourcesMap() {
     @Override
     void getRWBalanceCon(String schema, boolean autocommit, ResponseHandler handler, Object attachment) throws Exception {
         PhysicalDatasource theNode = getRWBalanceNode();
-        if (theNode.getConfig().isDisabled()) {
+        if (theNode.isDisabled()) {
             if (this.getReadSources().values().size() > 0) {
                 theNode = this.getReadSources().values().iterator().next()[0];
             } else {

diff --git a/src/main/java/com/actiontech/dble/config/util/SchemaWriteJob.java b/src/main/java/com/actiontech/dble/config/util/SchemaWriteJob.java
@@ -78,7 +78,7 @@ private void changeHostInfo(DataHost dh, PhysicalDNPoolSingleWH physicalDNPoolSi
         }
 
         List<ReadHost> newReadList = new ArrayList<ReadHost>();
-        if (physicalDNPoolSingleWH.getReadSourceAll() != null) {
+        if (physicalDNPoolSingleWH.getReadSourceAll().size() > 0) {
             for (PhysicalDatasource rs : physicalDNPoolSingleWH.getReadSourceAll().get(0)) {
                 ReadHost r = new ReadHost();
                 r.setDisabled("" + rs.isDisabled());