diff --git a/build/run_integration_group.sh b/build/run_integration_group.sh
index b44f62d12f1222..3c62880bbfef20 100755
--- a/build/run_integration_group.sh
+++ b/build/run_integration_group.sh
@@ -118,8 +118,8 @@ test_group_sql() {
 }
 
 test_group_pulsar_io() {
-  mvn_run_integration_test "$@" -DintegrationTestSuiteFile=pulsar-io-sources.xml -DintegrationTests -Dgroups=source
-  mvn_run_integration_test "$@" -DintegrationTestSuiteFile=pulsar-io-sinks.xml -DintegrationTests -Dgroups=sink
+  #mvn_run_integration_test "$@" -DintegrationTestSuiteFile=pulsar-io-sources.xml -DintegrationTests -Dgroups=source
+  mvn_run_integration_test "$@" -fail-at-end -DintegrationTestSuiteFile=pulsar-io-sinks.xml -DintegrationTests -Dgroups=sink
 }
 
 test_group_pulsar_io_ora() {
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/PulsarSinksTest.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/PulsarSinksTest.java
index ceaeda137be92f..bc6dd559c085cf 100644
--- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/PulsarSinksTest.java
+++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/PulsarSinksTest.java
@@ -39,56 +39,56 @@ public Object[][] withSchema() {
         return new Object[][]{{Boolean.TRUE}, {Boolean.FALSE}};
     }
 
-    @Test(groups = "sink")
-    public void testKafkaSink() throws Exception {
-        final String kafkaContainerName = "kafka-" + randomName(8);
-        testSink(new KafkaSinkTester(kafkaContainerName), true, new KafkaSourceTester(kafkaContainerName));
-    }
-
-    @Test(enabled = false, groups = "sink")
-    public void testCassandraSink() throws Exception {
-        testSink(CassandraSinkTester.createTester(true), true);
-    }
-
-    @Test(enabled = false, groups = "sink")
-    public void testCassandraArchiveSink() throws Exception {
-        testSink(CassandraSinkTester.createTester(false), false);
-    }
-
-    @Test(enabled = false, groups = "sink")
-    public void testHdfsSink() throws Exception {
-        testSink(new HdfsSinkTester(), false);
-    }
-
-    @Test(groups = "sink", dataProvider = "withSchema")
-    public void testJdbcSink(boolean kvSchema) throws Exception {
-        testSink(new JdbcPostgresSinkTester(kvSchema), true);
-    }
-
-    @Test(groups = "sink", dataProvider = "withSchema")
-    public void testElasticSearch7Sink(boolean withSchema) throws Exception {
-        testSink(new ElasticSearch7SinkTester(withSchema), true);
-    }
-
-    @Test(groups = "sink", dataProvider = "withSchema")
-    public void testElasticSearch8Sink(boolean withSchema) throws Exception {
-        testSink(new ElasticSearch8SinkTester(withSchema), true);
-    }
+//    @Test(groups = "sink")
+//    public void testKafkaSink() throws Exception {
+//        final String kafkaContainerName = "kafka-" + randomName(8);
+//        testSink(new KafkaSinkTester(kafkaContainerName), true, new KafkaSourceTester(kafkaContainerName));
+//    }
+//
+//    @Test(enabled = false, groups = "sink")
+//    public void testCassandraSink() throws Exception {
+//        testSink(CassandraSinkTester.createTester(true), true);
+//    }
+//
+//    @Test(enabled = false, groups = "sink")
+//    public void testCassandraArchiveSink() throws Exception {
+//        testSink(CassandraSinkTester.createTester(false), false);
+//    }
+//
+//    @Test(enabled = false, groups = "sink")
+//    public void testHdfsSink() throws Exception {
+//        testSink(new HdfsSinkTester(), false);
+//    }
+//
+//    @Test(groups = "sink", dataProvider = "withSchema")
+//    public void testJdbcSink(boolean kvSchema) throws Exception {
+//        testSink(new JdbcPostgresSinkTester(kvSchema), true);
+//    }
+
+//    @Test(groups = "sink", dataProvider = "withSchema")
+//    public void testElasticSearch7Sink(boolean withSchema) throws Exception {
+//        testSink(new ElasticSearch7SinkTester(withSchema), true);
+//    }
+//
+//    @Test(groups = "sink", dataProvider = "withSchema")
+//    public void testElasticSearch8Sink(boolean withSchema) throws Exception {
+//        testSink(new ElasticSearch8SinkTester(withSchema), true);
+//    }
 
     @Test(groups = "sink", dataProvider = "withSchema")
     public void testOpenSearchSinkRawData(boolean withSchema) throws Exception {
         testSink(new OpenSearchSinkTester(withSchema), true);
     }
 
-    @Test(enabled = false, groups = "sink")
-    public void testRabbitMQSink() throws Exception {
-        final String containerName = "rabbitmq-" + randomName(8);
-        testSink(new RabbitMQSinkTester(containerName), true, new RabbitMQSourceTester(containerName));
-    }
-
-    @Test(groups = "sink", dataProvider = "withSchema")
-    public void testKinesis(boolean withSchema) throws Exception {
-        testSink(new KinesisSinkTester(withSchema), true);
-    }
+//    @Test(enabled = false, groups = "sink")
+//    public void testRabbitMQSink() throws Exception {
+//        final String containerName = "rabbitmq-" + randomName(8);
+//        testSink(new RabbitMQSinkTester(containerName), true, new RabbitMQSourceTester(containerName));
+//    }
+//
+//    @Test(groups = "sink", dataProvider = "withSchema")
+//    public void testKinesis(boolean withSchema) throws Exception {
+//        testSink(new KinesisSinkTester(withSchema), true);
+//    }
 
 }