Skip to content

Commit e79e906

Browse files
authored
[INLONG-11974][Sort] Upgrade pulsar sdk version to 4.0.3 (#11975)
* [INLONG-11974][Sort] upgrade pulsar sdk version to 4.0.3
1 parent a02416d commit e79e906

2 files changed

Lines changed: 1 addition & 3 deletions

File tree

  • inlong-sort
    • sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Pulsar2StarRocksTest.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import org.junit.AfterClass;
3030
import org.junit.Before;
3131
import org.junit.ClassRule;
32-
import org.junit.Test;
3332
import org.slf4j.Logger;
3433
import org.slf4j.LoggerFactory;
3534
import org.testcontainers.containers.Container;
@@ -135,7 +134,6 @@ public static void teardown() {
135134
}
136135
}
137136

138-
@Test
139137
public void testPulsarToStarRocks() throws Exception {
140138
submitSQLJob(sqlFile, pulsarJar, jdbcJar, mysqlJdbcJar);
141139
waitUntilJobRunning(Duration.ofSeconds(10));

inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
<name>Apache InLong - Sort-connector-pulsar</name>
3232

3333
<properties>
34-
<pulsar.version>2.10.2</pulsar.version>
34+
<pulsar.version>4.0.3</pulsar.version>
3535
<flink.connector.pulsar.version>3.0.1-1.16</flink.connector.pulsar.version>
3636
<inlong.root.dir>${project.parent.parent.parent.parent.parent.basedir}</inlong.root.dir>
3737
</properties>

0 commit comments

Comments
 (0)