From e290b76b4f99c0ee0874ac6fbb876c2b0d81b84c Mon Sep 17 00:00:00 2001
From: Lari Hotari <lhotari@users.noreply.github.com>
Date: Thu, 19 Sep 2024 09:45:46 +0300
Subject: [PATCH] [fix][io] Upgrade mssql server docker tag in
 DebeziumMsSqlContainer (#23318)

(cherry picked from commit a875debe9144e69764bde8f04ada36a5302519e5)
(cherry picked from commit 4a05d519ee25ea640c3fbdca9dfe1aab8706e2a9)
---
 .../tests/integration/containers/DebeziumMsSqlContainer.java    | 2 +-
 .../io/sources/debezium/DebeziumMsSqlSourceTester.java          | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/DebeziumMsSqlContainer.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/DebeziumMsSqlContainer.java
index 357fd8724d738..61acdae37696b 100644
--- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/DebeziumMsSqlContainer.java
+++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/DebeziumMsSqlContainer.java
@@ -37,7 +37,7 @@ public class DebeziumMsSqlContainer extends ChaosContainer<DebeziumMsSqlContaine
     // "You may install and use copies of the software on any device,
     // including third party shared devices, to design, develop, test and demonstrate your programs.
     // You may not use the software on a device or server in a production environment."
-    private static final String IMAGE_NAME = "mcr.microsoft.com/mssql/server:2019-CU12-ubuntu-20.04";
+    private static final String IMAGE_NAME = "mcr.microsoft.com/mssql/server:2019-CU28-ubuntu-20.04";
 
     public DebeziumMsSqlContainer(String clusterName) {
         super(clusterName, IMAGE_NAME);
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMsSqlSourceTester.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMsSqlSourceTester.java
index 45ec00ef66817..5fb0f38c623d8 100644
--- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMsSqlSourceTester.java
+++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMsSqlSourceTester.java
@@ -103,7 +103,7 @@ private ContainerExecResult runSqlCmd(String cmd, boolean useTestDb) throws Exce
         log.info("Executing \"{}\"", cmd);
         ContainerExecResult response = this.debeziumMsSqlContainer
                 .execCmd("/bin/bash", "-c",
-                "/opt/mssql-tools/bin/sqlcmd -S localhost -U sa -P \""
+                "/opt/mssql-tools18/bin/sqlcmd -C -S localhost -U sa -P \""
                         + DebeziumMsSqlContainer.SA_PASSWORD + "\" -Q \""
                         + (useTestDb ? "USE TestDB; " : "")
                         + cmd