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 <[email protected]>
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 <[email protected]>
---
.../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