(seatunnel) branch dev updated: Migrated GraphQL according to issue #11007 (#12273)

[github-bot]

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

github-merge-queue[bot] pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 5694541625 Migrated GraphQL according to issue #11007 (#12273)
5694541625 is described below

commit 56945416254808846852069712728a6feeb23827
Author: Kaustubh Abhinand <154255646+kaustabhin...@users.noreply.github.com>
AuthorDate: Sat Sep 12 09:23:05 2026 +0000

    Migrated GraphQL according to issue #11007 (#12273)
---
 .../connectors/seatunnel/graphql/sink/GraphQLSinkFactory.java  |  4 +++-
 .../seatunnel/graphql/source/GraphQLSourceFactory.java         |  4 +++-
 .../connectors/seatunnel/graphql/util/GraphQLUtil.java         | 10 ----------
 3 files changed, 6 insertions(+), 12 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/sink/GraphQLSinkFactory.java
 
b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/sink/GraphQLSinkFactory.java
index c8adabebed..59249473f7 100644
--- 
a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/sink/GraphQLSinkFactory.java
+++ 
b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/sink/GraphQLSinkFactory.java
@@ -28,6 +28,8 @@ import 
org.apache.seatunnel.connectors.seatunnel.http.sink.HttpSinkFactory;
 
 import com.google.auto.service.AutoService;
 
+import static org.apache.seatunnel.api.configuration.util.Conditions.notBlank;
+
 @AutoService(Factory.class)
 public class GraphQLSinkFactory extends HttpSinkFactory {
     @Override
@@ -43,7 +45,7 @@ public class GraphQLSinkFactory extends HttpSinkFactory {
     @Override
     public OptionRule optionRule() {
         return OptionRule.builder()
-                .required(GraphQLSinkOptions.QUERY)
+                .required(GraphQLSinkOptions.QUERY, 
notBlank(GraphQLSinkOptions.QUERY))
                 .optional(GraphQLSinkOptions.TIMEOUT)
                 .optional(GraphQLSinkOptions.VALUE_COVER)
                 .optional(GraphQLSinkOptions.VARIABLES)
diff --git 
a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/GraphQLSourceFactory.java
 
b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/GraphQLSourceFactory.java
index bef45de3bf..56d9e4e249 100644
--- 
a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/GraphQLSourceFactory.java
+++ 
b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/GraphQLSourceFactory.java
@@ -30,6 +30,8 @@ import com.google.auto.service.AutoService;
 
 import java.io.Serializable;
 
+import static org.apache.seatunnel.api.configuration.util.Conditions.notBlank;
+
 @AutoService(Factory.class)
 public class GraphQLSourceFactory extends HttpSourceFactory {
     @Override
@@ -46,7 +48,7 @@ public class GraphQLSourceFactory extends HttpSourceFactory {
     @Override
     public OptionRule optionRule() {
         return OptionRule.builder()
-                .required(GraphQLSourceOptions.QUERY)
+                .required(GraphQLSourceOptions.QUERY, 
notBlank(GraphQLSourceOptions.QUERY))
                 .optional(GraphQLSourceOptions.VARIABLES)
                 .optional(GraphQLSourceOptions.ENABLE_SUBSCRIPTION)
                 .optional(GraphQLSourceOptions.TIMEOUT)
diff --git 
a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/util/GraphQLUtil.java
 
b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/util/GraphQLUtil.java
index 97eb8f28a2..5d5c78b25e 100644
--- 
a/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/util/GraphQLUtil.java
+++ 
b/seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/util/GraphQLUtil.java
@@ -79,11 +79,6 @@ public class GraphQLUtil {
     }
 
     public static void validateSinkOperation(String query) {
-        if (query == null || query.isEmpty()) {
-            throw new GraphQLConnectorException(
-                    GraphQLConnectorErrorCode.GRAPHQL_SOURCE_PARAMETER_ERROR,
-                    "GraphQL Sink query is required.");
-        }
         OperationDefinition.Operation operationType = 
parseOperationType(query);
         switch (operationType) {
             case MUTATION:
@@ -98,11 +93,6 @@ public class GraphQLUtil {
     }
 
     public static void validateSourceOperation(String query, Boolean 
enableSubscription) {
-        if (query == null) {
-            throw new GraphQLConnectorException(
-                    GraphQLConnectorErrorCode.GRAPHQL_SOURCE_PARAMETER_ERROR,
-                    "GraphQL Source is required.");
-        }
         OperationDefinition.Operation operationType;
         try {
             operationType = parseOperationType(query);