Override getErrorDetailsProviderClassName

Author: psainics

mysql-plugin/src/main/java/io/cdap/plugin/mysql/MysqlSink.java

@@ -109,6 +109,11 @@ String getDbColumns() {
     return dbColumns;
   }
 
+  @Override
+  protected String getErrorDetailsProviderClassName() {
+    return MysqlErrorDetailsProvider.class.getName();
+  }
+
   /**
    * MySQL action configuration.
    */

mysql-plugin/src/main/java/io/cdap/plugin/mysql/MysqlSource.java

@@ -84,6 +84,11 @@ protected SchemaReader getSchemaReader() {
     return new MysqlSchemaReader(null, mysqlSourceConfig.getConnectionArguments());
   }
 
+  @Override
+  protected String getErrorDetailsProviderClassName() {
+    return MysqlErrorDetailsProvider.class.getName();
+  }
+
   /**
    * MySQL source config.
    */