[pulsar] branch master updated: [cleanup][tests] Use TestNG instead of JUnit (#15575)

[eolivelli]

This is an automated email from the ASF dual-hosted git repository.

eolivelli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 0d6e82af80f [cleanup][tests] Use TestNG instead of JUnit (#15575)
0d6e82af80f is described below

commit 0d6e82af80f5c3491c1be164fa2702d4386677f1
Author: Zixuan Liu <node...@gmail.com>
AuthorDate: Fri May 13 13:18:40 2022 +0800

    [cleanup][tests] Use TestNG instead of JUnit (#15575)
    
    Signed-off-by: Zixuan Liu <node...@gmail.com>
---
 .../integration/io/sources/debezium/DebeziumMsSqlSourceTester.java      | 2 +-
 .../integration/io/sources/debezium/DebeziumPostgreSqlSourceTester.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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 f1bd8a824c0..5894d4f0ecb 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
@@ -26,8 +26,8 @@ import 
org.apache.pulsar.tests.integration.containers.PulsarContainer;
 import org.apache.pulsar.tests.integration.docker.ContainerExecResult;
 import org.apache.pulsar.tests.integration.io.sources.SourceTester;
 import org.apache.pulsar.tests.integration.topologies.PulsarCluster;
-import org.junit.Assert;
 import org.testcontainers.shaded.com.google.common.base.Preconditions;
+import org.testng.Assert;
 import org.testng.util.Strings;
 
 import java.io.Closeable;
diff --git 
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumPostgreSqlSourceTester.java
 
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumPostgreSqlSourceTester.java
index 80401c60b6e..318c57fab63 100644
--- 
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumPostgreSqlSourceTester.java
+++ 
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumPostgreSqlSourceTester.java
@@ -139,7 +139,7 @@ public class DebeziumPostgreSqlSourceTester extends 
SourceTester<DebeziumPostgre
             String lastConfirmedFlushLsn = res.getStdout();
             log.info("Current confirmedFlushLsn: \n{} \nLast 
confirmedFlushLsn: \n{}",
                     confirmedFlushLsn.get(), lastConfirmedFlushLsn);
-            org.junit.Assert.assertNotEquals(confirmedFlushLsn.get(), 
lastConfirmedFlushLsn);
+            Assert.assertNotEquals(confirmedFlushLsn.get(), 
lastConfirmedFlushLsn);
             confirmedFlushLsn.set(lastConfirmedFlushLsn);
         } catch (Exception e) {
             Assert.fail("failed to get flush lsn", e);