diff --git a/pkg/apis/sinks/v1alpha1/integration_sink_validation.go b/pkg/apis/sinks/v1alpha1/integration_sink_validation.go
index 9a0ae4dd7a8..7f24d9ca5a0 100644
--- a/pkg/apis/sinks/v1alpha1/integration_sink_validation.go
+++ b/pkg/apis/sinks/v1alpha1/integration_sink_validation.go
@@ -66,7 +66,7 @@ func (spec *IntegrationSinkSpec) Validate(ctx context.Context) *apis.FieldError
 		// Additional validation for AWS S3 required fields
 		if spec.Aws.S3 != nil {
 			if spec.Aws.S3.Arn == "" {
-				errs = errs.Also(apis.ErrMissingField("aws.s3.bucketNameOrArn"))
+				errs = errs.Also(apis.ErrMissingField("aws.s3.arn"))
 			}
 			if spec.Aws.S3.Region == "" {
 				errs = errs.Also(apis.ErrMissingField("aws.s3.region"))
@@ -76,7 +76,7 @@ func (spec *IntegrationSinkSpec) Validate(ctx context.Context) *apis.FieldError
 		// Additional validation for AWS SQS required fields
 		if spec.Aws.SQS != nil {
 			if spec.Aws.SQS.Arn == "" {
-				errs = errs.Also(apis.ErrMissingField("aws.sqs.queueNameOrArn"))
+				errs = errs.Also(apis.ErrMissingField("aws.sqs.arn"))
 			}
 			if spec.Aws.SQS.Region == "" {
 				errs = errs.Also(apis.ErrMissingField("aws.sqs.region"))
diff --git a/pkg/apis/sinks/v1alpha1/integration_sink_validation_test.go b/pkg/apis/sinks/v1alpha1/integration_sink_validation_test.go
index a976307d3ed..704262505d7 100644
--- a/pkg/apis/sinks/v1alpha1/integration_sink_validation_test.go
+++ b/pkg/apis/sinks/v1alpha1/integration_sink_validation_test.go
@@ -147,7 +147,7 @@ func TestIntegrationSinkSpecValidation(t *testing.T) {
 					},
 				},
 			},
-			want: apis.ErrMissingField("aws.sqs.queueNameOrArn"),
+			want: apis.ErrMissingField("aws.sqs.arn"),
 		},
 		{
 			name: "AWS SNS sink without TopicNameOrArn (invalid)",
diff --git a/pkg/apis/sources/v1alpha1/integration_validation.go b/pkg/apis/sources/v1alpha1/integration_validation.go
index 3b412998460..935e18e384f 100644
--- a/pkg/apis/sources/v1alpha1/integration_validation.go
+++ b/pkg/apis/sources/v1alpha1/integration_validation.go
@@ -76,7 +76,7 @@ func (spec *IntegrationSourceSpec) Validate(ctx context.Context) *apis.FieldErro
 		// Additional validation for AWS SQS required fields
 		if spec.Aws.SQS != nil {
 			if spec.Aws.SQS.Arn == "" {
-				errs = errs.Also(apis.ErrMissingField("aws.sqs.queueNameOrArn"))
+				errs = errs.Also(apis.ErrMissingField("aws.sqs.arn"))
 			}
 			if spec.Aws.SQS.Region == "" {
 				errs = errs.Also(apis.ErrMissingField("aws.sqs.region"))
diff --git a/pkg/apis/sources/v1alpha1/integration_validation_test.go b/pkg/apis/sources/v1alpha1/integration_validation_test.go
index 9b263426b61..5894376feab 100644
--- a/pkg/apis/sources/v1alpha1/integration_validation_test.go
+++ b/pkg/apis/sources/v1alpha1/integration_validation_test.go
@@ -170,7 +170,7 @@ func TestIntegrationSourceSpecValidation(t *testing.T) {
 					},
 				},
 			},
-			want: apis.ErrMissingField("aws.sqs.queueNameOrArn"),
+			want: apis.ErrMissingField("aws.sqs.arn"),
 		},
 		{
 			name: "AWS DDBStreams source without Table (invalid)",