Resolved : I managed to find the problem my sql execute query was incorrect. I dropped the schema in the execute query . Also in my jdbc url i added the integrated security = true bit , way better than adding username and password.
Manage to figure out that my query was the problem by playing around with database replication module.
Resolved