diff --git a/pom.xml b/pom.xml index 58915162e1fb4e2f68687ab18de30b060bee6a98..e7e91cef248e3ee3940838ccd51848a4f849f684 100644 --- a/pom.xml +++ b/pom.xml @@ -1696,5 +1696,9 @@ flexible messaging model and an intuitive client API. bintray https://yahoo.bintray.com/maven + + spring-plugins-release + https://repo.spring.io/plugins-release/ + diff --git a/pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/FunctionCommonTest.java b/pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/FunctionCommonTest.java index 2fbb6c0b22d1b3f94c7b4c5be04a9ecbcb715196..0e34e2997c571fce70f274e23564a5f61d5a462b 100644 --- a/pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/FunctionCommonTest.java +++ b/pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/FunctionCommonTest.java @@ -57,7 +57,7 @@ public class FunctionCommonTest { @Test public void testValidateHttpFileUrl() throws Exception { - String jarHttpUrl = "http://central.maven.org/maven2/org/apache/pulsar/pulsar-common/1.22.0-incubating/pulsar-common-1.22.0-incubating.jar"; + String jarHttpUrl = "https://repo1.maven.org/maven2/org/apache/pulsar/pulsar-common/2.4.2/pulsar-common-2.4.2.jar"; FunctionCommon.extractClassLoader(jarHttpUrl); jarHttpUrl = "http://_invalidurl_.com"; @@ -72,7 +72,7 @@ public class FunctionCommonTest { @Test public void testDownloadFile() throws Exception { - String jarHttpUrl = "http://central.maven.org/maven2/org/apache/pulsar/pulsar-common/1.22.0-incubating/pulsar-common-1.22.0-incubating.jar"; + String jarHttpUrl = "https://repo1.maven.org/maven2/org/apache/pulsar/pulsar-common/2.4.2/pulsar-common-2.4.2.jar"; String testDir = FunctionCommonTest.class.getProtectionDomain().getCodeSource().getLocation().getPath(); File pkgFile = new File(testDir, UUID.randomUUID().toString()); FunctionCommon.downloadFromHttpUrl(jarHttpUrl, pkgFile); diff --git a/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2ResourceTest.java b/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2ResourceTest.java index 20988e0cb76466a4ab261d5ec7527e5f18119e08..9865111572a5f3270870c601f1301cb6bdb9db04 100644 --- a/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2ResourceTest.java +++ b/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2ResourceTest.java @@ -1432,7 +1432,7 @@ public class FunctionApiV2ResourceTest { @Test public void testDownloadFunctionHttpUrl() throws Exception { - String jarHttpUrl = "http://central.maven.org/maven2/org/apache/pulsar/pulsar-common/1.22.0-incubating/pulsar-common-1.22.0-incubating.jar"; + String jarHttpUrl = "https://repo1.maven.org/maven2/org/apache/pulsar/pulsar-common/2.4.2/pulsar-common-2.4.2.jar"; String testDir = FunctionApiV2ResourceTest.class.getProtectionDomain().getCodeSource().getLocation().getPath(); FunctionsImplV2 function = new FunctionsImplV2(() -> mockedWorkerService); StreamingOutput streamOutput = (StreamingOutput) function.downloadFunction(jarHttpUrl, null).getEntity(); diff --git a/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionApiV3ResourceTest.java b/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionApiV3ResourceTest.java index 5f90945983e7fa2c436b9ac60f5da70567770df7..b65d5402f7b35bb28ec6c9cb5e3e3c13e24859db 100644 --- a/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionApiV3ResourceTest.java +++ b/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionApiV3ResourceTest.java @@ -1468,7 +1468,7 @@ public class FunctionApiV3ResourceTest { @Test public void testDownloadFunctionHttpUrl() throws Exception { - String jarHttpUrl = "http://central.maven.org/maven2/org/apache/pulsar/pulsar-common/1.22.0-incubating/pulsar-common-1.22.0-incubating.jar"; + String jarHttpUrl = "https://repo1.maven.org/maven2/org/apache/pulsar/pulsar-common/2.4.2/pulsar-common-2.4.2.jar"; String testDir = FunctionApiV3ResourceTest.class.getProtectionDomain().getCodeSource().getLocation().getPath(); WorkerService worker = mock(WorkerService.class); doReturn(true).when(worker).isInitialized(); diff --git a/site2/docs/io-kafka-source.md b/site2/docs/io-kafka-source.md index 615b3728dac960ff1278b708a887b4a6e4393d1d..484cf9dcf686aec48558a8b4ec84d14769689c70 100644 --- a/site2/docs/io-kafka-source.md +++ b/site2/docs/io-kafka-source.md @@ -64,7 +64,7 @@ Here is an example of using the Kafka source connecter with the configuration fi 1. Download a Kafka client and a Kafka connector. ```bash - $ wget http://central.maven.org/maven2/org/apache/kafka/kafka-clients/0.10.2.1/kafka-clients-0.10.2.1.jar + $ wget https://repo1.maven.org/maven2/org/apache/kafka/kafka-clients/0.10.2.1/kafka-clients-0.10.2.1.jar $ wget https://archive.apache.org/dist/pulsar/pulsar-2.4.0/connectors/pulsar-io-kafka-2.4.0.nar ```