This is an automated email from the ASF dual-hosted git repository.
pvillard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 8d262039bce NIFI-15826 Optimized JSON Property Validator Input Reading
(#11125)
8d262039bce is described below
commit 8d262039bce6c125c37b1e5ac8d967f4b4a193e4
Author: David Handermann <[email protected]>
AuthorDate: Sun Apr 12 05:10:58 2026 -0500
NIFI-15826 Optimized JSON Property Validator Input Reading (#11125)
- Renamed nifi-json-utils to nifi-json-validator
- Replaced Jackson ObjectMapper with JsonParser
- Removed jackson-databind dependency
---
nifi-code-coverage/pom.xml | 2 +-
.../apache/nifi/processor/util/JsonValidator.java | 49 ------
.../apache/nifi/processor/TestJsonValidator.java | 105 ------------
.../pom.xml | 6 +-
.../apache/nifi/processor/util/JsonValidator.java | 75 +++++++++
.../apache/nifi/processor/JsonValidatorTest.java | 177 +++++++++++++++++++++
nifi-commons/pom.xml | 2 +-
.../nifi-box-bundle/nifi-box-services/pom.xml | 2 +-
.../nifi-elasticsearch-restapi-processors/pom.xml | 2 +-
.../nifi-gcp-bundle/nifi-gcp-processors/pom.xml | 2 +-
.../nifi-graph-processors/pom.xml | 2 +-
.../nifi-neo4j-cypher-service/pom.xml | 2 +-
.../nifi-other-graph-services/pom.xml | 2 +-
.../nifi-mongodb-processors/pom.xml | 2 +-
.../nifi-mongodb-services/pom.xml | 2 +-
.../nifi-snmp-bundle/nifi-snmp-processors/pom.xml | 2 +-
16 files changed, 264 insertions(+), 170 deletions(-)
diff --git a/nifi-code-coverage/pom.xml b/nifi-code-coverage/pom.xml
index 429284f363b..c0ba263f8a3 100644
--- a/nifi-code-coverage/pom.xml
+++ b/nifi-code-coverage/pom.xml
@@ -280,7 +280,7 @@
</dependency>
<dependency>
<groupId>org.apache.nifi</groupId>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<version>2.10.0-SNAPSHOT</version>
</dependency>
<dependency>
diff --git
a/nifi-commons/nifi-json-utils/src/main/java/org/apache/nifi/processor/util/JsonValidator.java
b/nifi-commons/nifi-json-utils/src/main/java/org/apache/nifi/processor/util/JsonValidator.java
deleted file mode 100644
index 79c68d5afc5..00000000000
---
a/nifi-commons/nifi-json-utils/src/main/java/org/apache/nifi/processor/util/JsonValidator.java
+++ /dev/null
@@ -1,49 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.nifi.processor.util;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.nifi.components.ValidationContext;
-import org.apache.nifi.components.ValidationResult;
-import org.apache.nifi.components.Validator;
-
-import java.util.List;
-import java.util.Map;
-
-public class JsonValidator implements Validator {
- public static final JsonValidator INSTANCE = new JsonValidator();
-
- @Override
- public ValidationResult validate(String subject, String input,
ValidationContext context) {
- ObjectMapper mapper = new ObjectMapper();
- if (context.isExpressionLanguageSupported(subject) &&
context.isExpressionLanguagePresent(input)) {
- return new
ValidationResult.Builder().subject(subject).input(input).explanation("Expression
Language Present").valid(true).build();
- }
-
- try {
- Class clz = input.startsWith("[") ? List.class : Map.class;
- mapper.readValue(input, clz);
- } catch (Exception e) {
- return new
ValidationResult.Builder().subject(subject).input(input).valid(false)
- .explanation(subject + " is not a valid JSON
representation due to " + e.getLocalizedMessage())
- .build();
- }
-
- return new
ValidationResult.Builder().subject(subject).input(input).valid(true).build();
- }
-}
diff --git
a/nifi-commons/nifi-json-utils/src/test/java/org/apache/nifi/processor/TestJsonValidator.java
b/nifi-commons/nifi-json-utils/src/test/java/org/apache/nifi/processor/TestJsonValidator.java
deleted file mode 100644
index 41259408a39..00000000000
---
a/nifi-commons/nifi-json-utils/src/test/java/org/apache/nifi/processor/TestJsonValidator.java
+++ /dev/null
@@ -1,105 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License") you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.processor;
-
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.nifi.components.ValidationContext;
-import org.apache.nifi.components.ValidationResult;
-import org.apache.nifi.components.Validator;
-import org.apache.nifi.processor.util.JsonValidator;
-import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.extension.ExtendWith;
-import org.junit.jupiter.params.ParameterizedTest;
-import org.junit.jupiter.params.provider.ValueSource;
-import org.mockito.Mock;
-import org.mockito.junit.jupiter.MockitoExtension;
-
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.LinkedHashMap;
-import java.util.Map;
-
-import static org.junit.jupiter.api.Assertions.assertFalse;
-import static org.junit.jupiter.api.Assertions.assertTrue;
-
-@ExtendWith(MockitoExtension.class)
-public class TestJsonValidator {
- private static final String JSON_PROPERTY = "JSONProperty";
- private static final ObjectMapper MAPPER = new ObjectMapper();
-
- @Mock
- ValidationContext context;
-
- private final Validator validator = JsonValidator.INSTANCE;
-
- @Test
- public void testFlat() throws JsonProcessingException {
- String msg =
MAPPER.writeValueAsString(Collections.singletonMap("Name", "Crockford,
Douglas"));
- ValidationResult validationResult = validator.validate(JSON_PROPERTY,
msg, context);
-
- assertTrue(validationResult.isValid());
- }
-
- @Test
- public void testNested() throws JsonProcessingException {
- Map<String, Object> outer = new LinkedHashMap<>();
- outer.put("Name", "Crockford, Douglas");
- Map<String, Object> nested = new LinkedHashMap<>();
- nested.put("Mobile", 987654321);
- nested.put("Email", "[email protected]");
- outer.put("ContactInfo", nested);
- String msg = MAPPER.writeValueAsString(outer);
- ValidationResult validationResult = validator.validate(JSON_PROPERTY,
msg, context);
-
- assertTrue(validationResult.isValid());
- }
-
- @Test
- public void testObjectWithArray() throws JsonProcessingException {
- Map<String, Object> outer = new LinkedHashMap<>();
- outer.put("name", "Smith, John");
- outer.put("age", 30);
- outer.put("cars", Arrays.asList("Ford", "BMW", "Fiat"));
- String msg = MAPPER.writeValueAsString(outer);
- ValidationResult validationResult = validator.validate(JSON_PROPERTY,
msg, context);
-
- assertTrue(validationResult.isValid());
- }
-
- @Test
- public void testJSONArray() throws JsonProcessingException {
- String msg = MAPPER.writeValueAsString(Arrays.asList("one", "two",
"three"));
- ValidationResult validationResult = validator.validate(JSON_PROPERTY,
msg, context);
-
- assertTrue(validationResult.isValid());
- }
-
- @Test
- public void testEmpty() {
- ValidationResult validationResult = validator.validate(JSON_PROPERTY,
"{}", context);
- assertTrue(validationResult.isValid());
- }
-
- @ParameterizedTest
- @ValueSource(strings = {"\"Name\" : \"Smith, John\"", "bncjbhjfjhj"})
- public void testInvalidJson(String invalidJson) {
- ValidationResult validationResult = validator.validate(JSON_PROPERTY,
invalidJson, context);
- assertFalse(validationResult.isValid());
- assertTrue(validationResult.getExplanation().contains("not a valid
JSON representation"));
- }
-}
diff --git a/nifi-commons/nifi-json-utils/pom.xml
b/nifi-commons/nifi-json-validator/pom.xml
similarity index 88%
rename from nifi-commons/nifi-json-utils/pom.xml
rename to nifi-commons/nifi-json-validator/pom.xml
index 365bee6d311..a8a112843dd 100644
--- a/nifi-commons/nifi-json-utils/pom.xml
+++ b/nifi-commons/nifi-json-validator/pom.xml
@@ -20,7 +20,7 @@
<artifactId>nifi-commons</artifactId>
<version>2.10.0-SNAPSHOT</version>
</parent>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<packaging>jar</packaging>
<dependencies>
<dependency>
@@ -31,9 +31,5 @@
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-core</artifactId>
</dependency>
- <dependency>
- <groupId>com.fasterxml.jackson.core</groupId>
- <artifactId>jackson-databind</artifactId>
- </dependency>
</dependencies>
</project>
diff --git
a/nifi-commons/nifi-json-validator/src/main/java/org/apache/nifi/processor/util/JsonValidator.java
b/nifi-commons/nifi-json-validator/src/main/java/org/apache/nifi/processor/util/JsonValidator.java
new file mode 100644
index 00000000000..3cfd1d9b732
--- /dev/null
+++
b/nifi-commons/nifi-json-validator/src/main/java/org/apache/nifi/processor/util/JsonValidator.java
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.nifi.processor.util;
+
+import com.fasterxml.jackson.core.JsonFactory;
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonToken;
+import org.apache.nifi.components.ValidationContext;
+import org.apache.nifi.components.ValidationResult;
+import org.apache.nifi.components.Validator;
+
+/**
+ * Property Validator expecting JSON Objects or Arrays with support for
Expression Language when configured
+ */
+public class JsonValidator implements Validator {
+ public static final JsonValidator INSTANCE = new JsonValidator();
+
+ private static final JsonFactory JSON_FACTORY = new JsonFactory();
+
+ @Override
+ public ValidationResult validate(final String subject, final String input,
final ValidationContext context) {
+ final ValidationResult.Builder builder = new ValidationResult.Builder()
+ .subject(subject)
+ .input(input);
+
+ if (input == null || input.isBlank()) {
+ builder.valid(false);
+ builder.explanation("JSON input not found in null or blank
string");
+ } else if (context.isExpressionLanguageSupported(subject) &&
context.isExpressionLanguagePresent(input)) {
+ builder.valid(true);
+ builder.explanation("Expression Language found");
+ } else {
+ try (JsonParser parser = JSON_FACTORY.createParser(input)) {
+ final JsonToken firstToken = parser.nextToken();
+ if (JsonToken.START_OBJECT == firstToken ||
JsonToken.START_ARRAY == firstToken) {
+ parser.skipChildren();
+
+ // Read Next Token expecting end of object or array
+ final JsonToken lastToken = parser.nextToken();
+ if (lastToken == null) {
+ builder.valid(true);
+ builder.explanation("JSON object or array found");
+ } else {
+ builder.valid(false);
+ builder.explanation("Trailing content found after JSON
object or array");
+ }
+ } else {
+ builder.valid(false);
+ builder.explanation("JSON object or array not found");
+ }
+
+ } catch (final Exception e) {
+ builder.valid(false);
+ builder.explanation("JSON input validation failed:
%s".formatted(e.getMessage()));
+ }
+ }
+
+ return builder.build();
+ }
+}
diff --git
a/nifi-commons/nifi-json-validator/src/test/java/org/apache/nifi/processor/JsonValidatorTest.java
b/nifi-commons/nifi-json-validator/src/test/java/org/apache/nifi/processor/JsonValidatorTest.java
new file mode 100644
index 00000000000..58964402d14
--- /dev/null
+++
b/nifi-commons/nifi-json-validator/src/test/java/org/apache/nifi/processor/JsonValidatorTest.java
@@ -0,0 +1,177 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.processor;
+
+import org.apache.nifi.components.ValidationContext;
+import org.apache.nifi.components.ValidationResult;
+import org.apache.nifi.components.Validator;
+import org.apache.nifi.processor.util.JsonValidator;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.Mockito.when;
+
+@ExtendWith(MockitoExtension.class)
+class JsonValidatorTest {
+
+ private static final String JSON_PROPERTY = "JSONProperty";
+
+ @Mock
+ private ValidationContext context;
+
+ private final Validator validator = JsonValidator.INSTANCE;
+
+ @Test
+ void testNullBlank() {
+ assertInvalid(null);
+ assertInvalid("\r\n");
+ }
+
+ @Test
+ void testObject() {
+ final String input = """
+ {
+ "label": "Example, User"
+ }
+ """;
+
+ assertValid(input);
+ }
+
+ @Test
+ void testObjectNested() {
+ final String input = """
+ {
+ "label": "Example, User",
+ "contact": {
+ "phone": 5550100,
+ "email": "[email protected]"
+ }
+ }
+ """;
+
+ assertValid(input);
+ }
+
+ @Test
+ void testObjectArray() {
+ final String input = """
+ {
+ "fullName": "Doe, Jane",
+ "age": 42,
+ "tags": [
+ "tag-a",
+ "tag-b",
+ "tag-c"
+ ]
+ }
+ """;
+
+ assertValid(input);
+ }
+
+ @Test
+ void testArray() {
+ final String input = """
+ [
+ "first",
+ "second",
+ "third"
+ ]
+ """;
+
+ assertValid(input);
+ }
+
+ @Test
+ void testEmptyObject() {
+ final String input = "{}";
+
+ assertValid(input);
+ }
+
+ @Test
+ void testArrayWithLeadingWhitespace() {
+ final String input = """
+ \t[1,2]
+ """;
+
+ assertValid(input);
+ }
+
+ @Test
+ void testScalarNumberInvalid() {
+ final String input = "42";
+
+ assertInvalid(input);
+ }
+
+ @Test
+ void testObjectTrailingArrayInvalid() {
+ final String input = """
+ {
+ "label": "Example, User"
+ }
+ []
+ """;
+
+ assertInvalid(input);
+ }
+
+ @Test
+ void testMalformedObjectInvalid() {
+ final String input = """
+ {
+ "label": "Example, User"
+ """;
+
+ assertInvalid(input);
+ }
+
+ @Test
+ void testMalformedArrayInvalid() {
+ final String input = "[1,2,3";
+
+ assertInvalid(input);
+ }
+
+ @Test
+ void testExpressionLanguageValid() {
+ final String input = "${expression}";
+
+
when(context.isExpressionLanguageSupported(eq(JSON_PROPERTY))).thenReturn(true);
+ when(context.isExpressionLanguagePresent(eq(input))).thenReturn(true);
+
+ final ValidationResult result = validator.validate(JSON_PROPERTY,
input, context);
+ assertTrue(result.isValid());
+
+ assertTrue(result.getExplanation().contains("Expression Language"));
+ }
+
+ private void assertValid(final String input) {
+ assertTrue(validator.validate(JSON_PROPERTY, input,
context).isValid());
+ }
+
+ private void assertInvalid(final String input) {
+ assertFalse(validator.validate(JSON_PROPERTY, input,
context).isValid());
+ }
+}
diff --git a/nifi-commons/pom.xml b/nifi-commons/pom.xml
index ffefb0ad669..a772737bddc 100644
--- a/nifi-commons/pom.xml
+++ b/nifi-commons/pom.xml
@@ -33,7 +33,7 @@
<module>nifi-hl7-query-language</module>
<module>nifi-json-schema-api</module>
<module>nifi-json-schema-shared</module>
- <module>nifi-json-utils</module>
+ <module>nifi-json-validator</module>
<module>nifi-jetty-configuration</module>
<module>nifi-kubernetes-client</module>
<module>nifi-metrics</module>
diff --git a/nifi-extension-bundles/nifi-box-bundle/nifi-box-services/pom.xml
b/nifi-extension-bundles/nifi-box-bundle/nifi-box-services/pom.xml
index 21c1379024b..9c335e80941 100644
--- a/nifi-extension-bundles/nifi-box-bundle/nifi-box-services/pom.xml
+++ b/nifi-extension-bundles/nifi-box-bundle/nifi-box-services/pom.xml
@@ -34,7 +34,7 @@
</dependency>
<dependency>
<groupId>org.apache.nifi</groupId>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<version>2.10.0-SNAPSHOT</version>
</dependency>
<dependency>
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/pom.xml
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/pom.xml
index 57cadc727d2..8f72b06f523 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/pom.xml
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/pom.xml
@@ -40,7 +40,7 @@ language governing permissions and limitations under the
License. -->
</dependency>
<dependency>
<groupId>org.apache.nifi</groupId>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<version>2.10.0-SNAPSHOT</version>
</dependency>
<dependency>
diff --git a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/pom.xml
b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/pom.xml
index d4eb04498df..ba1d47ae303 100644
--- a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/pom.xml
+++ b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/pom.xml
@@ -145,7 +145,7 @@
</dependency>
<dependency>
<groupId>org.apache.nifi</groupId>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<version>2.10.0-SNAPSHOT</version>
<scope>compile</scope>
</dependency>
diff --git
a/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/pom.xml
b/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/pom.xml
index 46a7646c406..7544a1b3c9a 100644
--- a/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/pom.xml
+++ b/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/pom.xml
@@ -67,7 +67,7 @@
</dependency>
<dependency>
<groupId>org.apache.nifi</groupId>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<version>2.10.0-SNAPSHOT</version>
<scope>test</scope>
</dependency>
diff --git
a/nifi-extension-bundles/nifi-graph-bundle/nifi-neo4j-cypher-service/pom.xml
b/nifi-extension-bundles/nifi-graph-bundle/nifi-neo4j-cypher-service/pom.xml
index c6020551e6b..c638271dba9 100644
--- a/nifi-extension-bundles/nifi-graph-bundle/nifi-neo4j-cypher-service/pom.xml
+++ b/nifi-extension-bundles/nifi-graph-bundle/nifi-neo4j-cypher-service/pom.xml
@@ -58,7 +58,7 @@
</dependency>
<dependency>
<groupId>org.apache.nifi</groupId>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<version>2.10.0-SNAPSHOT</version>
<scope>compile</scope>
</dependency>
diff --git
a/nifi-extension-bundles/nifi-graph-bundle/nifi-other-graph-services/pom.xml
b/nifi-extension-bundles/nifi-graph-bundle/nifi-other-graph-services/pom.xml
index ff64a04b339..46a932326e4 100644
--- a/nifi-extension-bundles/nifi-graph-bundle/nifi-other-graph-services/pom.xml
+++ b/nifi-extension-bundles/nifi-graph-bundle/nifi-other-graph-services/pom.xml
@@ -55,7 +55,7 @@
</dependency>
<dependency>
<groupId>org.apache.nifi</groupId>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<version>2.10.0-SNAPSHOT</version>
<scope>compile</scope>
</dependency>
diff --git
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/pom.xml
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/pom.xml
index 2a515b092a6..47cdd275a1a 100644
--- a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/pom.xml
+++ b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/pom.xml
@@ -63,7 +63,7 @@
</dependency>
<dependency>
<groupId>org.apache.nifi</groupId>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<version>2.10.0-SNAPSHOT</version>
</dependency>
<dependency>
diff --git
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-services/pom.xml
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-services/pom.xml
index 76e45946300..9c8221b3989 100644
--- a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-services/pom.xml
+++ b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-services/pom.xml
@@ -62,7 +62,7 @@
</dependency>
<dependency>
<groupId>org.apache.nifi</groupId>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<version>2.10.0-SNAPSHOT</version>
</dependency>
<dependency>
diff --git
a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/pom.xml
b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/pom.xml
index 76e1bcb6225..247fee6a678 100644
--- a/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/pom.xml
+++ b/nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/pom.xml
@@ -48,7 +48,7 @@ language governing permissions and limitations under the
License. -->
</dependency>
<dependency>
<groupId>org.apache.nifi</groupId>
- <artifactId>nifi-json-utils</artifactId>
+ <artifactId>nifi-json-validator</artifactId>
<version>2.10.0-SNAPSHOT</version>
</dependency>
</dependencies>
