This is an automated email from the ASF dual-hosted git repository.

chaitalithombare pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git


The following commit(s) were added to refs/heads/master by this push:
     new d400fed61 ATLAS-4984: Option to ignore spark_process attributes 
details and sparkPlanDescription (#376)
d400fed61 is described below

commit d400fed61141f0dffdf83398932357197e418b54
Author: chaitalicod <36201417+chaitali...@users.noreply.github.com>
AuthorDate: Thu Jun 12 16:28:15 2025 +0530

    ATLAS-4984: Option to ignore spark_process attributes details and 
sparkPlanDescription (#376)
    
    Co-authored-by: chaitalithombare <chaitalithomb...@apache.org>
---
 .../apache/atlas/notification/preprocessor/EntityPreprocessor.java | 2 +-
 .../apache/atlas/notification/preprocessor/SparkPreprocessor.java  | 1 +
 .../atlas/notification/preprocessor/SparkPreprocessorTest.java     | 7 +++----
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/webapp/src/main/java/org/apache/atlas/notification/preprocessor/EntityPreprocessor.java
 
b/webapp/src/main/java/org/apache/atlas/notification/preprocessor/EntityPreprocessor.java
index b801615f4..a950a43a6 100644
--- 
a/webapp/src/main/java/org/apache/atlas/notification/preprocessor/EntityPreprocessor.java
+++ 
b/webapp/src/main/java/org/apache/atlas/notification/preprocessor/EntityPreprocessor.java
@@ -183,7 +183,7 @@ public abstract class EntityPreprocessor {
                 new AWSS3V2Preprocessor.AWSS3V2DirectoryPreprocessor()
         };
 
-        EntityPreprocessor[] sparkPreprocessors = new EntityPreprocessor[]{
+        EntityPreprocessor[] sparkPreprocessors = new EntityPreprocessor[] {
                 new SparkPreprocessor.SparkProcessPreprocessor()
         };
 
diff --git 
a/webapp/src/main/java/org/apache/atlas/notification/preprocessor/SparkPreprocessor.java
 
b/webapp/src/main/java/org/apache/atlas/notification/preprocessor/SparkPreprocessor.java
index 266ce3790..7091d2e56 100644
--- 
a/webapp/src/main/java/org/apache/atlas/notification/preprocessor/SparkPreprocessor.java
+++ 
b/webapp/src/main/java/org/apache/atlas/notification/preprocessor/SparkPreprocessor.java
@@ -24,6 +24,7 @@ import org.slf4j.LoggerFactory;
 
 public class SparkPreprocessor {
     private static final Logger LOG = 
LoggerFactory.getLogger(SparkPreprocessor.class);
+
     static class SparkProcessPreprocessor extends EntityPreprocessor {
         public SparkProcessPreprocessor() {
             super(TYPE_SPARK_PROCESS);
diff --git 
a/webapp/src/test/java/org/apache/atlas/notification/preprocessor/SparkPreprocessorTest.java
 
b/webapp/src/test/java/org/apache/atlas/notification/preprocessor/SparkPreprocessorTest.java
index ec8927364..42940592f 100644
--- 
a/webapp/src/test/java/org/apache/atlas/notification/preprocessor/SparkPreprocessorTest.java
+++ 
b/webapp/src/test/java/org/apache/atlas/notification/preprocessor/SparkPreprocessorTest.java
@@ -27,11 +27,10 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.testng.annotations.Test;
 
-import java.util.Map;
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
-import java.util.ArrayList;
-
+import java.util.Map;
 import java.util.regex.Pattern;
 
 import static org.testng.Assert.assertEquals;
@@ -80,7 +79,7 @@ public class SparkPreprocessorTest {
         attributes.put(ATTRIBUTE_QUERYTEXT, null);
         attributes.put(ATTRIBUTE_CURRUSER, "spark");
 
-        return new Object[][] { { attributes } };
+        return new Object[][] {{attributes}};
     }
 
     @Test

Reply via email to