diff --git a/pkg/flowaggregator/s3uploader/s3uploader.go b/pkg/flowaggregator/s3uploader/s3uploader.go index 2f6d98417ea..a5bdb616239 100644 --- a/pkg/flowaggregator/s3uploader/s3uploader.go +++ b/pkg/flowaggregator/s3uploader/s3uploader.go @@ -459,9 +459,10 @@ func writeRecord(w io.Writer, r *flowrecord.FlowRecord, clusterUUID string) { io.WriteString(w, ",") io.WriteString(w, fmt.Sprintf("%d", r.FlowType)) io.WriteString(w, ",") - io.WriteString(w, r.SourcePodLabels) + // Enclose Pod labels with single quote for Snowflake usecases + io.WriteString(w, fmt.Sprintf("'%s'", r.SourcePodLabels)) io.WriteString(w, ",") - io.WriteString(w, r.DestinationPodLabels) + io.WriteString(w, fmt.Sprintf("'%s'", r.DestinationPodLabels)) io.WriteString(w, ",") io.WriteString(w, fmt.Sprintf("%d", r.Throughput)) io.WriteString(w, ",")