Wrap AssertionError in mysql

Author: psainics

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

@@ -16,12 +16,18 @@
 
 package io.cdap.plugin.mysql;
 
+import io.cdap.cdap.api.exception.ErrorCategory;
+import io.cdap.cdap.api.exception.ErrorType;
+import io.cdap.cdap.api.exception.ErrorUtils;
+
 /**
  * MySQL Constants.
  */
 public final class MysqlConstants {
   private MysqlConstants() {
-    throw new AssertionError("Should not instantiate static utility class.");
+    String errorMessage = "Should not instantiate static utility class.";
+    throw ErrorUtils.getProgramFailureException(new ErrorCategory(ErrorCategory.ErrorCategoryEnum.PLUGIN),
+      errorMessage, errorMessage, ErrorType.SYSTEM, false, new AssertionError(errorMessage));
   }
 
   public static final String PLUGIN_NAME = "Mysql";

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

@@ -17,6 +17,9 @@
 package io.cdap.plugin.mysql;
 
 import com.google.common.collect.ImmutableMap;
+import io.cdap.cdap.api.exception.ErrorCategory;
+import io.cdap.cdap.api.exception.ErrorType;
+import io.cdap.cdap.api.exception.ErrorUtils;
 
 import java.sql.Types;
 import java.util.Map;
@@ -26,7 +29,9 @@
  */
 public final class MysqlUtil {
   private MysqlUtil() {
-    throw new AssertionError("Should not instantiate static utility class.");
+    String errorMessage = "Should not instantiate static utility class.";
+    throw ErrorUtils.getProgramFailureException(new ErrorCategory(ErrorCategory.ErrorCategoryEnum.PLUGIN),
+      errorMessage, errorMessage, ErrorType.SYSTEM, false, new AssertionError(errorMessage));
   }
 
   /**