diff --git a/sink/sink20169.c b/sink/sink20169.c
index 714ea9c..3432fca 100644
--- a/sink/sink20169.c
+++ b/sink/sink20169.c
@@ -222,7 +222,7 @@ int initForwarder(t_configHandle *configHandle, t_commonHandle *handle) {
 }
 
 void deinitForwarder(t_commonHandle *handle) {
-
+    PQfinish(handle->conn);
 }
 
 int openDatabaseConnection(t_commonHandle *handle) {