[GitHub] merlimat closed pull request #2683: [tests] disabled cassandra connector test and python function test

[GitBox <gi...@apache.org>]

merlimat closed pull request #2683: [tests] disabled cassandra connector test and python function test
URL: https://github.com/apache/pulsar/pull/2683
 
 
   

This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:

As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):

diff --git a/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/pojo/Tick.java b/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/pojo/Tick.java
index 8a94a19670..fc16e70fde 100644
--- a/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/pojo/Tick.java
+++ b/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/pojo/Tick.java
@@ -61,6 +61,8 @@ public double getAsk() {
         return ask;
     }
 
+    public Tick() {}
+
     public Tick(long timeStamp, String stockSymbol, double bid, double ask) {
 
         this.timeStamp = timeStamp;
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
index e9ea6186c3..b8a1daefd2 100644
--- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
+++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
@@ -66,12 +66,12 @@ public void testKafkaSink() throws Exception {
         testSink(new KafkaSinkTester(), true, new KafkaSourceTester());
     }
 
-    @Test
+    @Test(enabled = false)
     public void testCassandraSink() throws Exception {
         testSink(CassandraSinkTester.createTester(true), true);
     }
 
-    @Test
+    @Test(enabled = false)
     public void testCassandraArchiveSink() throws Exception {
         testSink(CassandraSinkTester.createTester(false), false);
     }
@@ -579,7 +579,7 @@ protected void getSourceInfoNotFound(String tenant, String namespace, String sou
     // Test CRUD functions on different runtimes.
     //
 
-    @Test
+    @Test(enabled = false)
     public void testPythonExclamationFunction() throws Exception {
         testExclamationFunction(Runtime.PYTHON);
     }
diff --git a/tests/scripts/pre-integ-tests.sh b/tests/scripts/pre-integ-tests.sh
index 1a465db1ab..62b12b555b 100755
--- a/tests/scripts/pre-integ-tests.sh
+++ b/tests/scripts/pre-integ-tests.sh
@@ -30,3 +30,4 @@ docker pull apachepulsar/s3mock:latest
 docker pull alpine/socat:latest
 docker pull cassandra:3
 docker pull confluentinc/cp-kafka:4.0.0
+docker pull mysql:5.7.22


 

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services