diff --git a/build/run_integration_group.sh b/build/run_integration_group.sh index 3c62880bbfef2..b44f62d12f122 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 "$@" -fail-at-end -DintegrationTestSuiteFile=pulsar-io-sinks.xml -DintegrationTests -Dgroups=sink + mvn_run_integration_test "$@" -DintegrationTestSuiteFile=pulsar-io-sources.xml -DintegrationTests -Dgroups=source + mvn_run_integration_test "$@" -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 d8e4512423256..4e5b960d477a8 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); + } }