Close encrpted writer in offload

open-gpdb · Sep 11, 2024 · 579131f · 579131f
1 parent a6039d4
commit 579131f
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/pkg/proc/interaction.go b/pkg/proc/interaction.go
@@ -134,6 +134,13 @@ func ProcessPutExtended(
 					return
 				}
 
+				if encrypt {
+					if err := w.Close(); err != nil {
+						ylogger.Zero.Error().Err(err).Msg("failed to close connection")
+						return
+					}
+				}
+
 				ylogger.Zero.Debug().Msg("closing msg writer")
 				return
 			}