sijie commented on issue #2879: Failed to write entry (11, 0): Bookie handle is
not available
URL: https://github.com/apache/pulsar/issues/2879#issuecomment-434571965
@nanguawu :
> But the bookie process is already up
the process is running, but
from the jstack, I didn't s
sijie commented on issue #2872: Update to use use new vagrant images
URL: https://github.com/apache/pulsar/pull/2872#issuecomment-434564497
@merlimat can you review this?
This is an automated message from the Apache Git Servic
merlimat commented on a change in pull request #2893: Issue #2890: Dependencies
for using Pulsar in Storm topologies
URL: https://github.com/apache/pulsar/pull/2893#discussion_r229537084
##
File path: pulsar-storm/pom.xml
##
@@ -121,7 +127,7 @@
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 2591ccd Add KeyValueSchema to satisfy
org.apach
sijie closed pull request #2885: Add KeyValueSchema to satisfy
org.apache.kafka.connect.connector.ConnectRecord
URL: https://github.com/apache/pulsar/pull/2885
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of p
sijie opened a new pull request #2893: Issue #2890: Dependencies for using
Pulsar in Storm topologies
URL: https://github.com/apache/pulsar/pull/2893
*Motivation*
Fixes #2890
The shading plugin used in pulsar-storm is promoting transitive dependencies
to the dependency-redu
This is an automated email from the ASF dual-hosted git repository.
sanjeevrk 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 649c6ca Hooked up secrets function api with
srkukarni closed pull request #2875: Hooked up secrets function api with secret
function implementations
URL: https://github.com/apache/pulsar/pull/2875
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenan
srkukarni opened a new pull request #2892: Remove runtime dependency from
pulsar-admin
URL: https://github.com/apache/pulsar/pull/2892
### Motivation
As part of dependency cleanup, this pr makes a separate utility to actually
run functions/sources/sinks locally. The pulsar-admin uti
srkukarni commented on a change in pull request #2875: Hooked up secrets
function api with secret function implementations
URL: https://github.com/apache/pulsar/pull/2875#discussion_r229529195
##
File path: pulsar-functions/instance/src/main/python/secretsprovider.py
##
@@
srkukarni commented on a change in pull request #2875: Hooked up secrets
function api with secret function implementations
URL: https://github.com/apache/pulsar/pull/2875#discussion_r229529195
##
File path: pulsar-functions/instance/src/main/python/secretsprovider.py
##
@@
jerrypeng commented on a change in pull request #2875: Hooked up secrets
function api with secret function implementations
URL: https://github.com/apache/pulsar/pull/2875#discussion_r229528759
##
File path: pulsar-functions/instance/src/main/python/secretsprovider.py
##
@@
sijie commented on issue #2890: Dependencies for using Pulsar in Storm
topologies
URL: https://github.com/apache/pulsar/issues/2890#issuecomment-434436700
@jnioche I think there is a problem in the pulsar-storm pom file:
https://search.maven.org/artifact/org.apache.pulsar/pulsar-storm/2.2.
merlimat commented on a change in pull request #2883: Add healthcheck for broker
URL: https://github.com/apache/pulsar/pull/2883#discussion_r229445292
##
File path: pulsar-broker/src/main/java/org/apache/pulsar/PulsarHealthcheck.java
##
@@ -0,0 +1,204 @@
+/**
+ * Licensed t
sijie commented on issue #2885: Add KeyValueSchema to satisfy
org.apache.kafka.connect.connector.ConnectRecord
URL: https://github.com/apache/pulsar/pull/2885#issuecomment-434427028
run integration tests
This is an automated
sijie commented on a change in pull request #2883: Add healthcheck for broker
URL: https://github.com/apache/pulsar/pull/2883#discussion_r229438532
##
File path: pulsar-broker/src/main/java/org/apache/pulsar/PulsarHealthcheck.java
##
@@ -0,0 +1,204 @@
+/**
+ * Licensed to t
sijie commented on issue #2879: Failed to write entry (11, 0): Bookie handle is
not available
URL: https://github.com/apache/pulsar/issues/2879#issuecomment-434422410
@nanguawu it seems that the bookie doesn't finish starting up. is your
bookie still running? can you take a jstack trace?
aahmed-se commented on issue #2872: Update to use use new vagrant images
URL: https://github.com/apache/pulsar/pull/2872#issuecomment-434416303
run java8 tests
This is an automated message from the Apache Git Service.
To respo
sijie commented on issue #2890: Dependencies for using Pulsar in Storm
topologies
URL: https://github.com/apache/pulsar/issues/2890#issuecomment-434415244
@jnioche thank you for reporting this. will work on a fix.
This is an
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 0a7c64b [zookeeper] remove hardcoded zookeeper s
sijie closed pull request #2889: [zookeeper] remove hardcoded zookeeper session
timeout
URL: https://github.com/apache/pulsar/pull/2889
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
david-streamlio commented on a change in pull request #2869: Added Pulsar IO
connector for local files
URL: https://github.com/apache/pulsar/pull/2869#discussion_r229427751
##
File path:
pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileConsumerThread.java
##
@@
david-streamlio commented on a change in pull request #2869: Added Pulsar IO
connector for local files
URL: https://github.com/apache/pulsar/pull/2869#discussion_r229423371
##
File path:
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/AbstractFileTests.java
##
@@ -
david-streamlio commented on a change in pull request #2869: Added Pulsar IO
connector for local files
URL: https://github.com/apache/pulsar/pull/2869#discussion_r229418862
##
File path:
pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSource.java
##
@@ -0,0 +1,
david-streamlio commented on a change in pull request #2869: Added Pulsar IO
connector for local files
URL: https://github.com/apache/pulsar/pull/2869#discussion_r229418717
##
File path: pulsar-io/file/src/test/resources/sinkConfig.yaml
##
@@ -0,0 +1,33 @@
+#
+# Licensed t
david-streamlio commented on a change in pull request #2869: Added Pulsar IO
connector for local files
URL: https://github.com/apache/pulsar/pull/2869#discussion_r229417742
##
File path: pulsar-io/file/pom.xml
##
@@ -0,0 +1,71 @@
+
+http://maven.apache.org/POM/4.0.0";
xml
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229406154
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/OffloadIndexBlock.java
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229403424
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/DataBlockUtils.jav
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229403532
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/OffloadIndexBlock.java
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229394130
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/DataBlockUtils.jav
jerrypeng commented on issue #2887: How to get user config at windowing function
URL: https://github.com/apache/pulsar/issues/2887#issuecomment-434380134
@ngjaying for version 2.1.1-incubating only java.util.function is supported
e.g.
```
public class WindowFunction implements Fun
srkukarni commented on issue #2887: How to get user config at windowing function
URL: https://github.com/apache/pulsar/issues/2887#issuecomment-434362752
We need to cleanup WindowContext. It has several methods that don't exist
anymore in a normal Context and does not have others that have
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229369098
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlockAwareSegmentI
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229368463
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedInp
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229367955
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/OffloadIndexBlockBuilde
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229368198
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/OffloadIndexEntry.java
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229367363
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/OffloadIndexBlock.java
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229366807
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/DataBlockHeader.java
#
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229366686
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/BlockAwareSegmentInputS
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229366751
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/BlockAwareSegmentInputS
david-streamlio commented on a change in pull request #2865: Refactored JCloud
Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229366289
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/BackedInputStream.java
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229353978
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/OffloadIndexBlock.java
#
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229353854
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/DataBlockHeader.java
###
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229353636
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/BlockAwareSegmentInputStream.
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229354880
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/DataBlockHeaderImpl.java
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229354754
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlockAwareSegmentInputSt
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229354236
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/OffloadIndexEntry.java
#
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229353483
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/BackedInputStream.java
#
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229354077
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/OffloadIndexBlockBuilder.java
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229357238
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/DataBlockUtils.java
###
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229352612
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/OffloadIndexBlock.java
#
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229353573
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/BlockAwareSegmentInputStream.
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r229354462
##
File path:
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedInputStre
ivankelly commented on a change in pull request #2888: PIP-25: Token based
authentication
URL: https://github.com/apache/pulsar/pull/2888#discussion_r229325406
##
File path:
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderToken.java
ivankelly commented on a change in pull request #2888: PIP-25: Token based
authentication
URL: https://github.com/apache/pulsar/pull/2888#discussion_r229348595
##
File path:
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderToken.java
ivankelly commented on a change in pull request #2888: PIP-25: Token based
authentication
URL: https://github.com/apache/pulsar/pull/2888#discussion_r229325800
##
File path:
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderToken.java
ivankelly commented on a change in pull request #2888: PIP-25: Token based
authentication
URL: https://github.com/apache/pulsar/pull/2888#discussion_r229333834
##
File path: pom.xml
##
@@ -726,6 +727,22 @@ flexible messaging model and an intuitive client
API.
ivankelly commented on a change in pull request #2888: PIP-25: Token based
authentication
URL: https://github.com/apache/pulsar/pull/2888#discussion_r229336845
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/utils/auth/tokens/TokensCliUtils.java
##
@@ -0,0 +1,
maskit commented on a change in pull request #2888: PIP-25: Token based
authentication
URL: https://github.com/apache/pulsar/pull/2888#discussion_r229342190
##
File path:
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderToken.java
##
ivankelly commented on a change in pull request #2883: Add healthcheck for
broker
URL: https://github.com/apache/pulsar/pull/2883#discussion_r229321054
##
File path: pulsar-broker/src/main/java/org/apache/pulsar/PulsarHealthcheck.java
##
@@ -0,0 +1,204 @@
+/**
+ * Licensed
ivankelly opened a new issue #2891: Expose read and connect timeout in
PulsarAdmin
URL: https://github.com/apache/pulsar/issues/2891
When connecting to a pulsar broker endpoint which is not responding, the
PulsarAdmin client will hang forever, because this is the default behaviour of
the
ivankelly commented on a change in pull request #2883: Add healthcheck for
broker
URL: https://github.com/apache/pulsar/pull/2883#discussion_r229315227
##
File path: pulsar-broker/src/main/java/org/apache/pulsar/PulsarHealthcheck.java
##
@@ -0,0 +1,204 @@
+/**
+ * Licensed
nanguawu edited a comment on issue #2879: Failed to write entry (11, 0): Bookie
handle is not available
URL: https://github.com/apache/pulsar/issues/2879#issuecomment-434266320
Bookie server startup log has been added to the attachment
[pulsar-bookie-server057.opsadmin.cn.log](https
nanguawu commented on issue #2879: Failed to write entry (11, 0): Bookie handle
is not available
URL: https://github.com/apache/pulsar/issues/2879#issuecomment-434266320
Bookie server startup log has been added to the attachment，path of
log：/ssd/pulsar/logs/pulsar-bookie-gpu057.aibee.c
jnioche commented on issue #2890: Dependencies for using Pulsar in Storm
topologies
URL: https://github.com/apache/pulsar/issues/2890#issuecomment-434264001
Got it to work by excluding pulsar-client
```
org.apache.pulsar
jnioche commented on issue #2890: Dependencies for using Pulsar in Storm
topologies
URL: https://github.com/apache/pulsar/issues/2890#issuecomment-434259898
I tried reproducing the content of
https://github.com/apache/pulsar/blob/b6a25f034bd8a9c3b30aa4a90eefdd45a0f0ee67/pom.xml
by s
jnioche commented on issue #2890: Dependencies for using Pulsar in Storm
topologies
URL: https://github.com/apache/pulsar/issues/2890#issuecomment-434257707
The exception is thrown here
https://github.com/apache/pulsar/blob/b6a25f034bd8a9c3b30aa4a90eefdd45a0f0ee67/pulsar-client/src/
jnioche opened a new issue #2890: Dependencies for using Pulsar in Storm
topologies
URL: https://github.com/apache/pulsar/issues/2890
**Pulsar version**: 2.2.0
I build an uber jar for a Storm toplogy containing the following dependency
as per http://pulsar.apache.org/docs/latest/ada
sijie opened a new pull request #2889: [zookeeper] remove hardcoded zookeeper
session timeout
URL: https://github.com/apache/pulsar/pull/2889
*Motivation*
If zookeeper hostname resolution takes longer time (e.g. more than 10s).
both initing cluster and starting broker will fail du
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 95f4385 Upgrade jackson version to 2.9.7 (#2884
merlimat closed pull request #2884: Upgrade jackson version to 2.9.7
URL: https://github.com/apache/pulsar/pull/2884
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull reques
merlimat opened a new pull request #2888: PIP-25: Token based authentication
URL: https://github.com/apache/pulsar/pull/2888
### Motivation
This is the first PR for the implementation of token based authentication
### Modifications
* Added client & broker auth providers
ngjaying opened a new issue #2887: How to get user config at windowing function
URL: https://github.com/apache/pulsar/issues/2887
Pulsar functions SDK is not supported for windowing function, then how can
we get the user config?
Expected behavior
Allow to access context objec
sijie commented on a change in pull request #2885: Add KeyValueSchema to
satisfy org.apache.kafka.connect.connector.ConnectRecord
URL: https://github.com/apache/pulsar/pull/2885#discussion_r229196979
##
File path:
pulsar-client-schema/src/main/java/org/apache/pulsar/client/impl/sch
sijie commented on issue #2879: Failed to write entry (11, 0): Bookie handle is
not available
URL: https://github.com/apache/pulsar/issues/2879#issuecomment-434195598
yeah. it seems that bookie doesn't advertised itself to zookeeper. do you
mind sharing the logs of bookies? @nanguawu
---
75 matches
Mail list logo
