fixing up.

Author: AbhishekKumar9984

amazon-redshift-plugin/src/main/java/io/cdap/plugin/amazon/redshift/RedshiftSource.java

@@ -118,20 +118,21 @@ public void prepareRun(BatchSourceContext context) throws Exception {
 
       if (isImportQuerySelected && !sourceConfig.containsMacro(IMPORT_QUERY) &&
               Strings.isNullOrEmpty(sourceConfig.getImportQuery())) {
-        collector.addFailure("Import Query cannot be empty", null)
+        collector.addFailure("Import Query is empty.", "Specify the Import Query.")
                 .withConfigProperty(IMPORT_QUERY);
 
       } else if (!isImportQuerySelected && !sourceConfig.containsMacro(TABLE_NAME) &&
               Strings.isNullOrEmpty(sourceConfig.getTableName())) {
-        collector.addFailure("Table Name cannot be empty", null)
+        collector.addFailure("Table Name cannot be empty", "Specify the Table Name.")
                 .withConfigProperty(TABLE_NAME);
       }
     } else {
       if (!sourceConfig.containsMacro(IMPORT_QUERY) &&
               Strings.isNullOrEmpty(sourceConfig.getImportQuery()) &&
               !sourceConfig.containsMacro(TABLE_NAME) &&
               Strings.isNullOrEmpty(sourceConfig.getTableName())) {
-        collector.addFailure("Either 'Import Query' or 'Table Name' must be provided.", null)
+        collector.addFailure("Either 'Import Query' or 'Table Name' must be provided.",
+                        "Please provide Either 'Import Query' or 'Table Name'")
                 .withConfigProperty(IMPORT_QUERY)
                 .withConfigProperty(TABLE_NAME);
       }

database-commons/src/main/java/io/cdap/plugin/db/config/AbstractDBSpecificSourceConfig.java

@@ -155,18 +155,18 @@ public void validate(FailureCollector collector) {
       boolean isImportQuerySelected = importQueryType == ImportQueryType.IMPORT_QUERY;
       if (isImportQuerySelected && !containsMacro(IMPORT_QUERY) &&
               Strings.isNullOrEmpty(importQuery)) {
-        collector.addFailure("Import Query cannot be empty.", null)
+        collector.addFailure("Import Query is empty.", "Specify the Import Query.")
                 .withConfigProperty(IMPORT_QUERY);
 
       } else if (!isImportQuerySelected && !containsMacro(TABLE_NAME) &&
               Strings.isNullOrEmpty(tableName)) {
-        collector.addFailure("Import Query cannot be empty", null)
+        collector.addFailure("Import Query is empty.", "Specify the Import Query.")
                 .withConfigProperty(TABLE_NAME);
       }
     } else {
       if (!containsMacro(IMPORT_QUERY) && Strings.isNullOrEmpty(importQuery) &&
               !containsMacro(TABLE_NAME) && Strings.isNullOrEmpty(tableName)) {
-        collector.addFailure("Import Query cannot be empty", null)
+        collector.addFailure("Import Query is empty.", "Specify the Import Query.")
                 .withConfigProperty(IMPORT_QUERY)
                 .withConfigProperty(TABLE_NAME);
       }

postgresql-plugin/src/main/java/io/cdap/plugin/postgres/PostgresSource.java

@@ -80,19 +80,20 @@ public void configurePipeline(PipelineConfigurer pipelineConfigurer) {
       boolean isImportQuerySelected = importQueryType == ImportQueryType.IMPORT_QUERY;
       if (isImportQuerySelected && !sourceConfig.containsMacro(IMPORT_QUERY) &&
               Strings.isNullOrEmpty(sourceConfig.getImportQuery())) {
-        collector.addFailure("Import Query cannot be empty", null)
+        collector.addFailure("Import Query is empty.", "Specify the Import Query.")
                 .withConfigProperty(IMPORT_QUERY);
 
       } else if (!isImportQuerySelected && !sourceConfig.containsMacro(TABLE_NAME) &&
               Strings.isNullOrEmpty(sourceConfig.getTableName())) {
-        collector.addFailure("Table Name cannot be empty", null)
+        collector.addFailure("Table Name cannot be empty", "Specify the Table Name.")
                 .withConfigProperty(TABLE_NAME);
       }
     } else {
       if (!sourceConfig.containsMacro(IMPORT_QUERY) &&
               Strings.isNullOrEmpty(sourceConfig.getImportQuery()) && !sourceConfig.containsMacro(TABLE_NAME) &&
               Strings.isNullOrEmpty(sourceConfig.getTableName())) {
-        collector.addFailure("Either 'Import Query' or 'Table Name' must be provided.", null)
+        collector.addFailure("Either 'Import Query' or 'Table Name' must be provided.",
+                        " Please provide Either 'Import Query' or 'Table Name'")
                 .withConfigProperty(IMPORT_QUERY)
                 .withConfigProperty(TABLE_NAME);
       }