Skip to content

Commit

Permalink
Update Pulsar version to 3.1.0.6 (#109)
Browse files Browse the repository at this point in the history
* Update Pulsar version to 3.0.1.6

* Fixed compile issue
  • Loading branch information
merlimat authored Jan 16, 2024
1 parent 9db6bc2 commit 14a9236
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 4 deletions.
8 changes: 4 additions & 4 deletions pulsar-metadatastore-oxia/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<shade.relocation.package>io.streamnative.pulsarmetadatastoreoxia.shaded</shade.relocation.package>

<pulsar.version>2.11.0.3</pulsar.version>
<pulsar.version>3.0.2</pulsar.version>

<checkstyle.version>10.3.3</checkstyle.version>
<testng.version>7.7.0</testng.version>
Expand All @@ -61,7 +61,7 @@
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>io.streamnative</groupId>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-metadata</artifactId>
<version>${pulsar.version}</version>
<scope>provided</scope>
Expand All @@ -79,13 +79,13 @@
<scope>test</scope>
</dependency>
<dependency>
<groupId>io.streamnative</groupId>
<groupId>org.apache.pulsar</groupId>
<artifactId>buildtools</artifactId>
<version>${pulsar.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>io.streamnative</groupId>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-metadata</artifactId>
<version>${pulsar.version}</version>
<type>test-jar</type>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,8 @@ public class OxiaMetadataStore extends AbstractMetadataStore {
@NonNull MetadataStoreConfig metadataStoreConfig,
boolean enableSessionWatcher)
throws Exception {
super("oxia-metadata");

var linger = metadataStoreConfig.getBatchingMaxDelayMillis();
if (!metadataStoreConfig.isBatchingEnabled()) {
linger = 0;
Expand Down

0 comments on commit 14a9236

Please sign in to comment.