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