src/main/java/org/embulk/input/MySQLInputPlugin.java in embulk-input-mysql-0.8.2 vs src/main/java/org/embulk/input/MySQLInputPlugin.java in embulk-input-mysql-0.8.3

@@ -10,14 +10,16 @@
 import com.google.common.base.Throwables;
 import com.mysql.jdbc.TimeUtil;
 import org.embulk.config.Config;
 import org.embulk.config.ConfigDefault;
 import org.embulk.input.jdbc.AbstractJdbcInputPlugin;
+import org.embulk.input.jdbc.JdbcInputConnection;
 import org.embulk.input.jdbc.getter.ColumnGetterFactory;
 import org.embulk.input.mysql.MySQLInputConnection;
 import org.embulk.input.mysql.getter.MySQLColumnGetterFactory;
 import org.embulk.spi.PageBuilder;
+import org.embulk.spi.Schema;
 import org.joda.time.DateTimeZone;
 
 public class MySQLInputPlugin
         extends AbstractJdbcInputPlugin
 {
@@ -161,6 +163,15 @@
             if (f != null) {
                 f.setAccessible(false);
             }
         }
     }
+
+    @Override
+    protected Schema setupTask(JdbcInputConnection con, PluginTask task) throws SQLException
+    {
+        MySQLInputConnection mySQLCon = (MySQLInputConnection)con;
+        mySQLCon.compareTimeZone();
+        return super.setupTask(con,task);
+    }
+
 }