2016-08-05 15:48:56,750 INFO   MySQL|mysql_host_52_70_200_92_port_3306|snapshot  Step 6: generating DROP and CREATE statements to reflect current database schemas   [io.debezium.connector.mysql.SnapshotReader]
2016-08-05 15:48:58,149 INFO   MySQL|mysql_host_52_70_200_92_port_3306|snapshot  Step 6b: applying DROP and CREATE statements to connector's table model   [io.debezium.connector.mysql.SnapshotReader]
2016-08-05 15:48:58,244 ERROR  MySQL|mysql_host_52_70_200_92_port_3306|snapshot  Failed due to error: Aborting snapshot after running 'SHOW CREATE TABLE gpay.transaction_psms': Invalid value: null used for required field   [io.debezium.connector.mysql.SnapshotReader]
org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field
    at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:210)
    at org.apache.kafka.connect.data.Struct.put(Struct.java:215)
    at org.apache.kafka.connect.data.Struct.put(Struct.java:204)
    at io.debezium.connector.mysql.SourceInfo.struct(SourceInfo.java:230)
    at io.debezium.connector.mysql.RecordMakers.schemaChangeRecordValue(RecordMakers.java:318)
    at io.debezium.connector.mysql.RecordMakers.schemaChanges(RecordMakers.java:123)
    at io.debezium.connector.mysql.SnapshotReader.enqueueSchemaChanges(SnapshotReader.java:536)
    at io.debezium.connector.mysql.MySqlSchema.lambda$applyDdl$3(MySqlSchema.java:339)
    at io.debezium.relational.ddl.DdlChanges.lambda$groupStatementStringsByDatabase$1(DdlChanges.java:72)
    at io.debezium.relational.ddl.DdlChanges.groupEventsByDatabase(DdlChanges.java:97)
    at io.debezium.relational.ddl.DdlChanges.groupStatementStringsByDatabase(DdlChanges.java:66)
    at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:336)
    at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:295)
    at java.lang.Thread.run(Thread.java:745)
2016-08-05 15:48:58,648 ERROR  ||  Task gpay-0 threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]