From 864a7e27021f03e7a583bde712c21543e04e7d4e Mon Sep 17 00:00:00 2001
From: Rui Fu <rfu@apache.org>
Date: Mon, 8 Jan 2024 21:10:08 +0800
Subject: [PATCH] fix ci

---
 pulsar/resource_pulsar_sink_test.go   | 8 ++++----
 pulsar/resource_pulsar_source_test.go | 2 +-
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/pulsar/resource_pulsar_sink_test.go b/pulsar/resource_pulsar_sink_test.go
index e3c0b91..1f94fd7 100644
--- a/pulsar/resource_pulsar_sink_test.go
+++ b/pulsar/resource_pulsar_sink_test.go
@@ -142,8 +142,8 @@ func testSinkImported() resource.ImportStateCheckFunc {
 			return fmt.Errorf("expected %d states, got %d: %#v", 1, len(s), s)
 		}
 
-		if len(s[0].Attributes) != 27 {
-			return fmt.Errorf("expected %d attrs, got %d: %#v", 24, len(s[0].Attributes), s[0].Attributes)
+		if len(s[0].Attributes) != 30 {
+			return fmt.Errorf("expected %d attrs, got %d: %#v", 30, len(s[0].Attributes), s[0].Attributes)
 		}
 
 		return nil
@@ -173,7 +173,7 @@ func createSampleSink(name string) error {
 
 	config := &utils.SinkConfig{
 		CleanupSubscription:        false,
-		RetainOrdering:             false,
+		RetainOrdering:             true,
 		AutoAck:                    true,
 		Parallelism:                1,
 		Tenant:                     "public",
@@ -223,7 +223,7 @@ resource "pulsar_sink" "test" {
   max_redeliver_count = 5
   negative_ack_redelivery_delay_ms = 3000
   retain_key_ordering = false 
-	retain_ordering = false
+	retain_ordering = true
   secrets ="{\"SECRET1\": {\"path\": \"sectest\", \"key\": \"hello\"}}"
 
   processing_guarantees = "EFFECTIVELY_ONCE"
diff --git a/pulsar/resource_pulsar_source_test.go b/pulsar/resource_pulsar_source_test.go
index 52bf8b0..9822d6c 100644
--- a/pulsar/resource_pulsar_source_test.go
+++ b/pulsar/resource_pulsar_source_test.go
@@ -159,7 +159,7 @@ func testSourceImported() resource.ImportStateCheckFunc {
 			return fmt.Errorf("expected %d states, got %d: %#v", 1, len(s), s)
 		}
 
-		count := 20
+		count := 19
 		if len(s[0].Attributes) != count {
 			return fmt.Errorf("expected %d attrs, got %d: %#v", count, len(s[0].Attributes), s[0].Attributes)
 		}