diff --git a/test/tap/tests/reg_test_stmt_inv_param_offset-t.cpp b/test/tap/tests/reg_test_stmt_inv_param_offset-t.cpp
index 069cb8ce9..963bb68dc 100644
--- a/test/tap/tests/reg_test_stmt_inv_param_offset-t.cpp
+++ b/test/tap/tests/reg_test_stmt_inv_param_offset-t.cpp
@@ -275,7 +275,13 @@ int main(int argc, char** argv) {
 	}
 
 	MYSQL_QUERY(proxy_1, "CREATE DATABASE IF NOT EXISTS test");
+
+	diag("Starting trx in new connection; required for 'max_allowed_packet'   conn=%p", proxy_1);
+	MYSQL_QUERY(proxy_1, "/* create_new_connection=1 */ BEGIN");
+
 	MYSQL_QUERY(proxy_2, "USE test");
+	diag("Starting trx in new connection; required for 'max_allowed_packet'   conn=%p", proxy_2);
+	MYSQL_QUERY(proxy_2, "/* create_new_connection=1 */ BEGIN");
 
 	MYSQL_QUERY(proxy_1,
 		"CREATE TABLE IF NOT EXISTS test.test_stmt_inv__large_col_1 ("
@@ -399,6 +405,9 @@ int main(int argc, char** argv) {
 	}
 
 cleanup:
+	MYSQL_QUERY(proxy_1, "ROLLBACK");
+	MYSQL_QUERY(proxy_2, "ROLLBACK");
+
 	MYSQL_QUERY(proxy_1, "DELETE FROM test.test_stmt_inv__large_col_1");
 	MYSQL_QUERY(proxy_1, "DELETE FROM test.test_stmt_inv__large_col_2");