You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2018/12/07 00:59:53 UTC
[pulsar] branch master updated: Use BK v2 protocol from Presto
connector (#3135)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 44f8386 Use BK v2 protocol from Presto connector (#3135)
44f8386 is described below
commit 44f8386bb1bcbab35962e46c162adbc64cd7116c
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Thu Dec 6 16:59:49 2018 -0800
Use BK v2 protocol from Presto connector (#3135)
---
.../main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java | 2 ++
.../main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java | 4 +++-
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java
index b510030..0057d44 100644
--- a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java
+++ b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java
@@ -59,6 +59,8 @@ public class PulsarConnectorCache {
.setZkServers(pulsarConnectorConfig.getZookeeperUri())
.setAllowShadedLedgerManagerFactoryClass(true)
.setShadedLedgerManagerFactoryClassPrefix("org.apache.pulsar.shade.")
+ .setClientTcpNoDelay(false)
+ .setUseV2WireProtocol(true)
.setReadEntryTimeout(60);
return new ManagedLedgerFactoryImpl(bkClientConfiguration);
}
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java
index 45a2e4f..800399e 100644
--- a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java
+++ b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java
@@ -127,7 +127,9 @@ public class PulsarSplitManager implements ConnectorSplitManager {
ClientConfiguration bkClientConfiguration = new ClientConfiguration()
.setZkServers(this.pulsarConnectorConfig.getZookeeperUri())
.setAllowShadedLedgerManagerFactoryClass(true)
- .setShadedLedgerManagerFactoryClassPrefix("org.apache.pulsar.shade.");
+ .setShadedLedgerManagerFactoryClassPrefix("org.apache.pulsar.shade.")
+ .setClientTcpNoDelay(false)
+ .setUseV2WireProtocol(true);
return new ManagedLedgerFactoryImpl(bkClientConfiguration);
}