bug修改

src/main/java/com/ihooyah/flume/sink/DAOClass.java

@@ -77,7 +77,7 @@ public class DAOClass {
     }
 
     public void createConnection(String driver, String db_url, String user, String password) throws SQLException {
-        if (this.connection == null || this.connection.isClosed() || this.connection.isValid(1)) {
+        if (this.connection == null || this.connection.isClosed() || !this.connection.isValid(1)) {
             try {
                 Class.forName(driver);
                 this.connection = DriverManager.getConnection(db_url, user, password);