Merge pull request #542 from cloudsufi/cherry-pick/6de940cb40bf9dc23e2579dc40609147270ecadf

[🍒][PLUGIN-1845] Return null for ErrorDetailsProvider by default

Author: psainics

database-commons/src/main/java/io/cdap/plugin/db/sink/AbstractDBSink.java

@@ -176,7 +176,7 @@ public void validateOperations(FailureCollector collector, T dbSinkConfig, @Null
    * @return ErrorDetailsProvider class name
    */
   protected String getErrorDetailsProviderClassName() {
-    return DBErrorDetailsProvider.class.getName();
+    return null;
   }
 
   /**
@@ -254,7 +254,9 @@ public void prepareRun(BatchSinkContext context) {
                         context.getArguments().get(ETLDBOutputFormat.COMMIT_BATCH_SIZE));
     }
     // set error details provider
-    context.setErrorDetailsProvider(new ErrorDetailsProviderSpec(getErrorDetailsProviderClassName()));
+    if (!Strings.isNullOrEmpty(getErrorDetailsProviderClassName())) {
+      context.setErrorDetailsProvider(new ErrorDetailsProviderSpec(getErrorDetailsProviderClassName()));
+    }
     addOutputContext(context);
   }
   protected void addOutputContext(BatchSinkContext context) {

database-commons/src/main/java/io/cdap/plugin/db/source/AbstractDBSource.java

@@ -239,7 +239,7 @@ protected SchemaReader getSchemaReader() {
    * @return ErrorDetailsProvider class name
    */
   protected String getErrorDetailsProviderClassName() {
-    return DBErrorDetailsProvider.class.getName();
+    return null;
   }
 
   private DriverCleanup loadPluginClassAndGetDriver(Class<? extends Driver> driverClass)
@@ -299,7 +299,9 @@ public void prepareRun(BatchSourceContext context) throws Exception {
                                  schema.getFields().stream().map(Schema.Field::getName).collect(Collectors.toList()));
     }
     // set error details provider
-    context.setErrorDetailsProvider(new ErrorDetailsProviderSpec(getErrorDetailsProviderClassName()));
+    if (!Strings.isNullOrEmpty(getErrorDetailsProviderClassName())) {
+      context.setErrorDetailsProvider(new ErrorDetailsProviderSpec(getErrorDetailsProviderClassName()));
+    }
     context.setInput(Input.of(sourceConfig.getReferenceName(), new SourceInputFormatProvider(
       DataDrivenETLDBInputFormat.class, connectionConfigAccessor.getConfiguration())));
   }