quick fix to check the hypothesis

yb-voyager/cmd/importData.go

@@ -512,6 +512,7 @@ func importData(importFileTasks []*ImportFileTask) {
 	if err != nil {
 		utils.ErrExit("Failed to initialize the target DB connection pool: %s", err)
 	}
+	defer tdb.CloseConnPool()
 
 	var adaptiveParallelismStarted bool
 	if tconf.EnableYBAdaptiveParallelism {

yb-voyager/src/tgtdb/conn_pool.go

@@ -92,6 +92,15 @@ func NewConnectionPool(params *ConnectionParams) *ConnectionPool {
 	return pool
 }
 
+func (pool *ConnectionPool) CloseConnectionPool() {
+	for i := 0; i < pool.params.NumConnections; i++ {
+		c := <-pool.idleConns
+		if c != nil {
+			c.Close(context.Background())
+		}
+	}
+}
+
 func (pool *ConnectionPool) GetNumConnections() int {
 	return pool.size
 }

yb-voyager/src/tgtdb/oracle.go

@@ -554,6 +554,10 @@ func (tdb *TargetOracleDB) InitConnPool() error {
 	return nil
 }
 
+func (tdb *TargetOracleDB) CloseConnPool() error {
+	return nil
+}
+
 func (tdb *TargetOracleDB) PrepareForStreaming() {}
 
 func (tdb *TargetOracleDB) getConnectionUri(tconf *TargetConf) string {

yb-voyager/src/tgtdb/postgres.go

@@ -246,6 +246,11 @@ func (pg *TargetPostgreSQL) InitConnPool() error {
 	return nil
 }
 
+func (pg *TargetPostgreSQL) CloseConnPool() error {
+	pg.connPool.CloseConnectionPool()
+	return nil
+}
+
 func (pg *TargetPostgreSQL) GetCallhomeTargetDBInfo() *callhome.TargetDBDetails {
 	totalCores, _ := fetchCores([]*TargetConf{pg.tconf})
 	return &callhome.TargetDBDetails{

yb-voyager/src/tgtdb/target_db_interface.go

@@ -32,6 +32,7 @@ type TargetDB interface {
 	Init() error
 	Finalize()
 	InitConnPool() error
+	CloseConnPool() error
 	PrepareForStreaming()
 	GetVersion() string
 	CreateVoyagerSchema() error

yb-voyager/src/tgtdb/yugabytedb.go

@@ -246,6 +246,11 @@ func (yb *TargetYugabyteDB) InitConnPool() error {
 	return nil
 }
 
+func (yb *TargetYugabyteDB) CloseConnPool() error {
+	yb.connPool.CloseConnectionPool()
+	return nil
+}
+
 func (yb *TargetYugabyteDB) GetAllSchemaNamesRaw() ([]string, error) {
 	query := "SELECT schema_name FROM information_schema.schemata"
 	rows, err := yb.Query(query)