diff --git a/src/main/java/io/cdap/plugin/http/common/HttpErrorDetailsProvider.java b/src/main/java/io/cdap/plugin/http/common/HttpErrorDetailsProvider.java
index 74de0e2..f16dccf 100644
--- a/src/main/java/io/cdap/plugin/http/common/HttpErrorDetailsProvider.java
+++ b/src/main/java/io/cdap/plugin/http/common/HttpErrorDetailsProvider.java
@@ -117,4 +117,4 @@ private ProgramFailureException getProgramFailureException(NoSuchElementExceptio
                 errorMessage,
                 String.format(errorMessageFormat, errorContext.getPhase(), errorMessage), ErrorType.SYSTEM, false, e);
     }
-}
\ No newline at end of file
+}
diff --git a/src/main/java/io/cdap/plugin/http/sink/batch/HTTPSinkConfig.java b/src/main/java/io/cdap/plugin/http/sink/batch/HTTPSinkConfig.java
index 595df36..1e278af 100644
--- a/src/main/java/io/cdap/plugin/http/sink/batch/HTTPSinkConfig.java
+++ b/src/main/java/io/cdap/plugin/http/sink/batch/HTTPSinkConfig.java
@@ -85,8 +85,8 @@ public class HTTPSinkConfig extends BaseHttpConfig {
 
   @Name(URL)
   @Description("The URL to post data to. Additionally, a placeholder like #columnName can be added to the URL that " +
-          "can be substituted with column value at the runtime. E.g. https://customer-url/user/#user_id. Here user_id " +
-          "column should exist in input schema. (Macro Enabled)")
+          "can be substituted with column value at the runtime. E.g. https://customer-url/user/#user_id. " +
+          "Here user_id column should exist in input schema. (Macro Enabled)")
   @Macro
   private final String url;
 
@@ -159,9 +159,9 @@ public class HTTPSinkConfig extends BaseHttpConfig {
   @Nullable
   @Name(PROPERTY_HTTP_ERROR_HANDLING)
   @Description("Defines the error handling strategy to use for certain HTTP response codes." +
-          "The left column contains a regular expression for HTTP status code. The right column contains an action which" +
-          "is done in case of match. If HTTP status code matches multiple regular expressions, " +
-          "the first specified in mapping is matched.")
+          "The left column contains a regular expression for HTTP status code. " +
+          "The right column contains an action which is done in case of match. " +
+          "If HTTP status code matches multiple regular expressions, the first specified in mapping is matched.")
   protected String httpErrorsHandling;
 
   @Nullable
@@ -400,7 +400,8 @@ public List<HttpErrorHandlerEntity> getHttpErrorHandlingEntries() {
         // We embed causing exception message into this one. Since this message is shown on UI when validation fails.
         throw new InvalidConfigPropertyException(
                 String.format(
-                        "Error handling regex '%s' is not valid. %s", regex, e.getMessage()), PROPERTY_HTTP_ERROR_HANDLING);
+                        "Error handling regex '%s' is not valid. %s", regex, e.getMessage()),
+                PROPERTY_HTTP_ERROR_HANDLING);
       }
     }
     return results;
@@ -450,8 +451,8 @@ public void validate(FailureCollector collector) {
 
     if (!containsMacro(METHOD) && !METHODS.contains(method.toUpperCase())) {
       collector.addFailure(
-                      String.format("Invalid request method %s, must be one of %s.", method, Joiner.on(',').join(METHODS)), null)
-              .withConfigProperty(METHOD);
+              String.format("Invalid request method %s, must be one of %s.", method, Joiner.on(',')
+                      .join(METHODS)), null).withConfigProperty(METHOD);
     }
 
     if (!containsMacro(BATCH_SIZE) && batchSize != null && batchSize < 1) {
diff --git a/src/main/java/io/cdap/plugin/http/source/batch/HttpBatchSource.java b/src/main/java/io/cdap/plugin/http/source/batch/HttpBatchSource.java
index 1e7b02d..3171f09 100644
--- a/src/main/java/io/cdap/plugin/http/source/batch/HttpBatchSource.java
+++ b/src/main/java/io/cdap/plugin/http/source/batch/HttpBatchSource.java
@@ -132,4 +132,4 @@ public void transform(KeyValue<NullWritable, PageEntry> input, Emitter<Structure
       }
     }
   }
-}
\ No newline at end of file
+}
diff --git a/src/main/java/io/cdap/plugin/http/source/common/BaseHttpSourceConfig.java b/src/main/java/io/cdap/plugin/http/source/common/BaseHttpSourceConfig.java
index ec8334d..16a7036 100644
--- a/src/main/java/io/cdap/plugin/http/source/common/BaseHttpSourceConfig.java
+++ b/src/main/java/io/cdap/plugin/http/source/common/BaseHttpSourceConfig.java
@@ -163,9 +163,9 @@ public abstract class BaseHttpSourceConfig extends BaseHttpConfig {
   @Nullable
   @Name(PROPERTY_HTTP_ERROR_HANDLING)
   @Description("Defines the error handling strategy to use for certain HTTP response codes." +
-          "The left column contains a regular expression for HTTP status code. The right column contains an action which" +
-          "is done in case of match. If HTTP status code matches multiple regular expressions, " +
-          "the first specified in mapping is matched.")
+          "The left column contains a regular expression for HTTP status code." +
+          " The right column contains an action which is done in case of match." +
+          " If HTTP status code matches multiple regular expressions, the first specified in mapping is matched.")
   protected String httpErrorsHandling;
 
   @Name(PROPERTY_ERROR_HANDLING)
@@ -536,7 +536,8 @@ public List<HttpErrorHandlerEntity> getHttpErrorHandlingEntries() {
         // We embed causing exception message into this one. Since this message is shown on UI when validation fails.
         throw new InvalidConfigPropertyException(
                 String.format(
-                        "Error handling regex '%s' is not valid. %s", regex, e.getMessage()), PROPERTY_HTTP_ERROR_HANDLING);
+                        "Error handling regex '%s' is not valid. %s", regex, e.getMessage()),
+                PROPERTY_HTTP_ERROR_HANDLING);
       }
     }
     return results;
@@ -563,7 +564,7 @@ public List<String> getTransportProtocolsList() {
   public String getReferenceNameOrNormalizedFQN() {
     return Strings.isNullOrEmpty(referenceName) ? ReferenceNames.normalizeFqn(url) : referenceName;
   }
-  
+
   public void validate(FailureCollector failureCollector) {
     super.validate(failureCollector);
 
@@ -798,4 +799,4 @@ public static Map<String, String> getMapFromKeyValueString(String keyValueString
     }
     return result;
   }
-}
\ No newline at end of file
+}
diff --git a/src/main/java/io/cdap/plugin/http/source/common/DelimitedSchemaDetector.java b/src/main/java/io/cdap/plugin/http/source/common/DelimitedSchemaDetector.java
index 7ece051..f78478e 100644
--- a/src/main/java/io/cdap/plugin/http/source/common/DelimitedSchemaDetector.java
+++ b/src/main/java/io/cdap/plugin/http/source/common/DelimitedSchemaDetector.java
@@ -63,7 +63,8 @@ public static Schema detectSchema(HttpBatchSourceConfig config, String delimiter
       return null;
     }
     List<Schema.Field> fields = DataTypeDetectorUtils.detectDataTypeOfEachDatasetColumn(
-            new HashMap<>(), (Objects.nonNull(columnNames) ? columnNames : new String[0]), dataTypeDetectorStatusKeeper);
+            new HashMap<>(), (Objects.nonNull(columnNames) ? columnNames : new String[0]),
+            dataTypeDetectorStatusKeeper);
     return Schema.recordOf("text", fields);
   }