You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2018/10/25 11:56:04 UTC
[pulsar] branch master updated: fix python functions context
publish (#2844)
This is an automated email from the ASF dual-hosted git repository.
sijie 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 30351ed fix python functions context publish (#2844)
30351ed is described below
commit 30351edf769ebfde6e823971d5ed16b1d054806c
Author: Boyang Jerry Peng <je...@gmail.com>
AuthorDate: Thu Oct 25 04:55:59 2018 -0700
fix python functions context publish (#2844)
---
pulsar-functions/instance/src/main/python/contextimpl.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-functions/instance/src/main/python/contextimpl.py b/pulsar-functions/instance/src/main/python/contextimpl.py
index a02724f..24246ca 100644
--- a/pulsar-functions/instance/src/main/python/contextimpl.py
+++ b/pulsar-functions/instance/src/main/python/contextimpl.py
@@ -132,7 +132,7 @@ class ContextImpl(pulsar.Context):
batching_enabled=True,
batching_max_publish_delay_ms=1,
max_pending_messages=100000,
- compression_type=compression_type
+ compression_type=pulsar_compression_type
)
if serde_class_name not in self.publish_serializers: