Skip to content

Commit c5467b4

Browse files
authored
fix(clickpipes): update sorting key handling and update example (#358)
1 parent 9c0753b commit c5467b4

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

examples/clickpipe/kafka_confluent/main.tf

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,8 @@ resource "clickhouse_clickpipe" "kafka_confluent" {
5252
engine = {
5353
type = "MergeTree"
5454
}
55+
56+
sorting_key = ["my_field1", "my_field2"]
5557
}
5658

5759
columns = [
@@ -67,8 +69,12 @@ resource "clickhouse_clickpipe" "kafka_confluent" {
6769

6870
field_mappings = [
6971
{
70-
source_field = "my_field"
72+
source_field = "my_field1"
7173
destination_field = "my_field1"
74+
},
75+
{
76+
source_field = "my_field2"
77+
destination_field = "my_field2"
7278
}
7379
]
7480
}

pkg/resource/clickpipe.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -733,7 +733,7 @@ func (c *ClickPipeResource) Create(ctx context.Context, request resource.CreateR
733733
sortingKey := make([]string, len(tableDefinitionModel.SortingKey.Elements()))
734734

735735
for i, sortingKeyModel := range tableDefinitionModel.SortingKey.Elements() {
736-
sortingKey[i] = sortingKeyModel.String()
736+
sortingKey[i] = sortingKeyModel.(types.String).ValueString()
737737
}
738738

739739
tableEngineModel := models.ClickPipeDestinationTableEngineModel{}

0 commit comments

Comments
 (0)