Fixed bk verison

streamnative · Nov 15, 2024 · d36cdf7 · d36cdf7
1 parent 98de70a
commit d36cdf7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/cloud/data_source_pulsar_cluster.go b/cloud/data_source_pulsar_cluster.go
@@ -334,12 +334,12 @@ func dataSourcePulsarClusterRead(ctx context.Context, d *schema.ResourceData, me
 			return diag.FromErr(fmt.Errorf("ERROR_READ_PULSAR_CLUSTER_CONFIG: %w", err))
 		}
 	}
-	if pulsarInstance.Spec.Type != cloudv1alpha1.PulsarInstanceTypeServerless {
-		brokerImage := strings.Split(pulsarCluster.Spec.Broker.Image, ":")
-		_ = d.Set("pulsar_version", brokerImage[1])
+	if pulsarInstance.Spec.Type != cloudv1alpha1.PulsarInstanceTypeServerless && !pulsarCluster.IsUsingUrsaEngine() {
 		bookkeeperImage := strings.Split(pulsarCluster.Spec.BookKeeper.Image, ":")
 		_ = d.Set("bookkeeper_version", bookkeeperImage[1])
 	}
+	brokerImage := strings.Split(pulsarCluster.Spec.Broker.Image, ":")
+	_ = d.Set("pulsar_version", brokerImage[1])
 	_ = d.Set("type", pulsarInstance.Spec.Type)
 	releaseChannel := pulsarCluster.Spec.ReleaseChannel
 	if releaseChannel != "" {