[GitHub] skyrocknroll commented on issue #3671: pulsar-admin topics list public/default fails

skyrocknroll commented on issue #3671: pulsar-admin topics list public/default fails URL: https://github.com/apache/pulsar/issues/3671#issuecomment-466907987 @jiazhai 3 node zookeeper , 3 nodes with broker and bookeeper servers . Once the cluster is up after clust initialize metadata execu

[GitHub] skyrocknroll commented on issue #3671: pulsar-admin topics list public/default fails

skyrocknroll commented on issue #3671: pulsar-admin topics list public/default fails URL: https://github.com/apache/pulsar/issues/3671#issuecomment-466923891 @jiazhai Call to this url fails with timeout. `http://pulsar-node-1.bm.infra:8080/admin/v2/non-persistent/public/default` . Call to

[GitHub] skyrocknroll commented on issue #3671: pulsar-admin topics list public/default fails

skyrocknroll commented on issue #3671: pulsar-admin topics list public/default fails URL: https://github.com/apache/pulsar/issues/3671#issuecomment-466924894 is this issue related to this https://github.com/apache/pulsar/pull/3348 ?

[GitHub] sijie commented on issue #3678: [Pulsar Functions] Add support for multiple sinks/sources in a single NAR file.

sijie commented on issue #3678: [Pulsar Functions] Add support for multiple sinks/sources in a single NAR file. URL: https://github.com/apache/pulsar/pull/3678#issuecomment-466937865 @jerrypeng @david-streamlio - did you have any conclusions in #3576? It would be worth that you guys can co

[GitHub] jiazhai commented on issue #3675: Replce Junit with testng

jiazhai commented on issue #3675: Replce Junit with testng URL: https://github.com/apache/pulsar/pull/3675#issuecomment-466945626 rerun java8 tests This is an automated message from the Apache Git Service. To respond to the me

[GitHub] Tevic opened a new issue #3680: go static build error

Tevic opened a new issue #3680: go static build error URL: https://github.com/apache/pulsar/issues/3680 **Describe the bug** Pulsar version: 2.3.0 dpkg -i apache-pulsar-client*.deb **To Reproduce** go build -a -ldflags '-extldflags "-static"' . **Expected behavior*

[GitHub] matansh opened a new issue #3681: Via the python client I am unable to consume messages with a multi-topic regex consumer

matansh opened a new issue #3681: Via the python client I am unable to consume messages with a multi-topic regex consumer URL: https://github.com/apache/pulsar/issues/3681 **Describe the bug** Via the python client I am unable to consume messages with a multi-topic regex consumer

[GitHub] skyrocknroll edited a comment on issue #3671: pulsar-admin topics list public/default fails

skyrocknroll edited a comment on issue #3671: pulsar-admin topics list public/default fails URL: https://github.com/apache/pulsar/issues/3671#issuecomment-466907987 @jiazhai 3 node zookeeper , 3 nodes with broker and bookeeper servers . Once the cluster is up after clust initialize metadat

[GitHub] skyrocknroll edited a comment on issue #3671: pulsar-admin topics list public/default fails

skyrocknroll edited a comment on issue #3671: pulsar-admin topics list public/default fails URL: https://github.com/apache/pulsar/issues/3671#issuecomment-466923891 @jiazhai Call to this url fails with timeout. `http://pulsar-node-1.xx.com:8080/admin/v2/non-persistent/public/default` . Ca

[GitHub] matansh commented on issue #3681: Via the python client I am unable to consume messages with a multi-topic regex consumer

matansh commented on issue #3681: Via the python client I am unable to consume messages with a multi-topic regex consumer URL: https://github.com/apache/pulsar/issues/3681#issuecomment-467032862 update: just found a workaround! if i change my code to contain the full topic path it wo

[GitHub] sijie commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication

sijie commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication URL: https://github.com/apache/pulsar/pull/3677#discussion_r259900039 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java ## @@ -1

[GitHub] sijie commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication

sijie commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication URL: https://github.com/apache/pulsar/pull/3677#discussion_r259895483 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java ## @@

[GitHub] sijie commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication

sijie commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication URL: https://github.com/apache/pulsar/pull/3677#discussion_r259893309 ## File path: pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationSt

[pulsar] branch master updated: Replace Junit with testng (#3675)

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 fe7311c Replace Junit with testng (#3675) fe7311

[GitHub] sijie closed issue #3663: Change junit methods usage into testng methods

sijie closed issue #3663: Change junit methods usage into testng methods URL: https://github.com/apache/pulsar/issues/3663 This is an automated message from the Apache Git Service. To respond to the message, please log on Git

[GitHub] sijie merged pull request #3675: Replace Junit with testng

sijie merged pull request #3675: Replace Junit with testng URL: https://github.com/apache/pulsar/pull/3675 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the

[GitHub] sijie opened a new pull request #3682: [schema] Introduce schema builder to build schema.

sijie opened a new pull request #3682: [schema] Introduce schema builder to build schema. URL: https://github.com/apache/pulsar/pull/3682 ### Motivation Currently we are supporting POJO based schema in java clients. POJO schema is only useful when the POJO is predefined. However

[GitHub] massakam commented on issue #3630: Broker can not respond to client requests

massakam commented on issue #3630: Broker can not respond to client requests URL: https://github.com/apache/pulsar/issues/3630#issuecomment-467081440 Each time a broker hung, one thread named `ForkJoinPool.commonPool-worker-x` always stopped in the following state: ``` "ForkJoinPool.c

[GitHub] sijie opened a new pull request #3683: [schema] Introduce `GenericSchema` interface

sijie opened a new pull request #3683: [schema] Introduce `GenericSchema` interface URL: https://github.com/apache/pulsar/pull/3683 ### Motivation In order to introduce `GenericRecordBuilder`, we need to know the fields in a `GenericSchema`. Otherwise, there is no way for us

[GitHub] jerrypeng commented on issue #3679: Pulsar SQL queries fail with "failed: refCnt: 0"

jerrypeng commented on issue #3679: Pulsar SQL queries fail with "failed: refCnt: 0" URL: https://github.com/apache/pulsar/issues/3679#issuecomment-467136705 @ofaz was able to reproduce the error with a python pulsar client but everything works fine with the java pulsar client. Will inves

[GitHub] jerrypeng commented on issue #3679: Pulsar SQL queries fail with "failed: refCnt: 0"

jerrypeng commented on issue #3679: Pulsar SQL queries fail with "failed: refCnt: 0" URL: https://github.com/apache/pulsar/issues/3679#issuecomment-467137767 The source exception is actually the following which causes the split to close and the exceptions in the close method ```

[GitHub] jerrypeng commented on issue #3157: Refactored PulsarRecordCursor to avoid intermediate thread

jerrypeng commented on issue #3157: Refactored PulsarRecordCursor to avoid intermediate thread URL: https://github.com/apache/pulsar/pull/3157#issuecomment-467150293 rerun java8 tests This is an automated message from the Apa

[GitHub] david-streamlio commented on issue #3678: [Pulsar Functions] Add support for multiple sinks/sources in a single NAR file.

david-streamlio commented on issue #3678: [Pulsar Functions] Add support for multiple sinks/sources in a single NAR file. URL: https://github.com/apache/pulsar/pull/3678#issuecomment-467156746 @jerrypeng If you submit the pulsar-aws-nar-0.0.1.nar without specifying a classname, then the si

[GitHub] jerrypeng commented on issue #3678: [Pulsar Functions] Add support for multiple sinks/sources in a single NAR file.

jerrypeng commented on issue #3678: [Pulsar Functions] Add support for multiple sinks/sources in a single NAR file. URL: https://github.com/apache/pulsar/pull/3678#issuecomment-467157593 @david-streamlio ok that sounds good to me. Just making sure all code paths are covered. -

[GitHub] jerrypeng commented on issue #3678: [Pulsar Functions] Add support for multiple sinks/sources in a single NAR file.

jerrypeng commented on issue #3678: [Pulsar Functions] Add support for multiple sinks/sources in a single NAR file. URL: https://github.com/apache/pulsar/pull/3678#issuecomment-467158197 @david-streamlio please revert back the change in pulsar_tools_env.sh and I think we are good to go. Th

[GitHub] jerrypeng commented on issue #3679: Pulsar SQL queries fail with "failed: refCnt: 0"

jerrypeng commented on issue #3679: Pulsar SQL queries fail with "failed: refCnt: 0" URL: https://github.com/apache/pulsar/issues/3679#issuecomment-467177264 @ofaz I have a fix up for this issue: https://github.com/apache/pulsar/pull/3684 in the mean time, to side step this is

[GitHub] jerrypeng commented on issue #3638: Fix: package windowing code with function instance

jerrypeng commented on issue #3638: Fix: package windowing code with function instance URL: https://github.com/apache/pulsar/pull/3638#issuecomment-467177511 rerun java8 tests This is an automated message from the Apache Git

[GitHub] jerrypeng opened a new pull request #3684: fix: non-batched messages cause sql query to fail

jerrypeng opened a new pull request #3684: fix: non-batched messages cause sql query to fail URL: https://github.com/apache/pulsar/pull/3684 ### Motivation Because of error as describe in: https://github.com/apache/pulsar/issues/3679 If messages published by a producer

[GitHub] srkukarni commented on issue #3551: Simplified the workflow of functionruntime manager

srkukarni commented on issue #3551: Simplified the workflow of functionruntime manager URL: https://github.com/apache/pulsar/pull/3551#issuecomment-467218634 run java8 tests This is an automated message from the Apache Git Se

[GitHub] jerrypeng merged pull request #3638: Fix: package windowing code with function instance

jerrypeng merged pull request #3638: Fix: package windowing code with function instance URL: https://github.com/apache/pulsar/pull/3638 This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] jerrypeng commented on issue #3684: fix: non-batched messages cause sql query to fail

jerrypeng commented on issue #3684: fix: non-batched messages cause sql query to fail URL: https://github.com/apache/pulsar/pull/3684#issuecomment-467220921 rerun java8 tests This is an automated message from the Apache Git S

[GitHub] merlimat commented on issue #3684: fix: non-batched messages cause sql query to fail

merlimat commented on issue #3684: fix: non-batched messages cause sql query to fail URL: https://github.com/apache/pulsar/pull/3684#issuecomment-467220900 run java8 tests This is an automated message from the Apache Git Serv

[pulsar] branch master updated: package windowing code with function instance (#3638)

This is an automated email from the ASF dual-hosted git repository. jerrypeng 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 915a4d0 package windowing code with function

[GitHub] srkukarni opened a new pull request #3685: Added a flush method for python producer

srkukarni opened a new pull request #3685: Added a flush method for python producer URL: https://github.com/apache/pulsar/pull/3685 ### Motivation The current producer interface in python lacks a flush method. This pr adds it ### Modifications Since python client is modele

[GitHub] srkukarni commented on issue #3685: Added a flush method for python producer

srkukarni commented on issue #3685: Added a flush method for python producer URL: https://github.com/apache/pulsar/pull/3685#issuecomment-467250159 run java8 tests This is an automated message from the Apache Git Service. To r

[GitHub] srkukarni opened a new issue #3686: python bookkeeper client defective for python2 in mac

srkukarni opened a new issue #3686: python bookkeeper client defective for python2 in mac URL: https://github.com/apache/pulsar/issues/3686 **Describe the bug** Importing bookkeeper.admin module fails on a mac running python2 **To Reproduce** Mac running Mojave and python2. make

[GitHub] sijie commented on issue #3683: [schema] Introduce `GenericSchema` interface

sijie commented on issue #3683: [schema] Introduce `GenericSchema` interface URL: https://github.com/apache/pulsar/pull/3683#issuecomment-467254563 run java8 tests This is an automated message from the Apache Git Service. To r

[GitHub] sijie commented on issue #3682: [schema] Introduce schema builder to build schema.

sijie commented on issue #3682: [schema] Introduce schema builder to build schema. URL: https://github.com/apache/pulsar/pull/3682#issuecomment-467257033 run java8 tests This is an automated message from the Apache Git Servic

[GitHub] ConcurrencyPractitioner removed a comment on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation

ConcurrencyPractitioner removed a comment on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation URL: https://github.com/apache/pulsar/pull/3625#issuecomment-467261515 run java 8 - unit tests --

[GitHub] ConcurrencyPractitioner commented on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation

ConcurrencyPractitioner commented on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation URL: https://github.com/apache/pulsar/pull/3625#issuecomment-467261515 rerun java 8 - unit tests

[GitHub] ConcurrencyPractitioner commented on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation

ConcurrencyPractitioner commented on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation URL: https://github.com/apache/pulsar/pull/3625#issuecomment-467261661 Retest this please. --

[GitHub] ConcurrencyPractitioner commented on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation

ConcurrencyPractitioner commented on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation URL: https://github.com/apache/pulsar/pull/3625#issuecomment-467261601 run java 8 - unit tests --

[GitHub] ConcurrencyPractitioner removed a comment on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation

ConcurrencyPractitioner removed a comment on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation URL: https://github.com/apache/pulsar/pull/3625#issuecomment-467261601 run java 8 - unit tests --

[GitHub] ConcurrencyPractitioner edited a comment on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation

ConcurrencyPractitioner edited a comment on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation URL: https://github.com/apache/pulsar/pull/3625#issuecomment-467261515 run java 8 - unit tests ---

[GitHub] merlimat merged pull request #3684: fix: non-batched messages cause sql query to fail

merlimat merged pull request #3684: fix: non-batched messages cause sql query to fail URL: https://github.com/apache/pulsar/pull/3684 This is an automated message from the Apache Git Service. To respond to the message, pleas

[pulsar] branch master updated: fix: non-batched messages cause sql query to fail (#3684)

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 397ef33 fix: non-batched messages cause sql que

[GitHub] jiazhai commented on issue #3682: [schema] Introduce schema builder to build schema.

jiazhai commented on issue #3682: [schema] Introduce schema builder to build schema. URL: https://github.com/apache/pulsar/pull/3682#issuecomment-467269911 rerun java8 tests This is an automated message from the Apache Git Se

[GitHub] jiazhai commented on issue #3678: [Pulsar Functions] Add support for multiple sinks/sources in a single NAR file.

jiazhai commented on issue #3678: [Pulsar Functions] Add support for multiple sinks/sources in a single NAR file. URL: https://github.com/apache/pulsar/pull/3678#issuecomment-467269978 rerun java8 tests This is an automated m

[GitHub] jiazhai commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication

jiazhai commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication URL: https://github.com/apache/pulsar/pull/3677#discussion_r260105120 ## File path: pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/Authentication

[GitHub] jiazhai commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication

jiazhai commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication URL: https://github.com/apache/pulsar/pull/3677#discussion_r260105266 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java ##

[GitHub] jiazhai commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication

jiazhai commented on a change in pull request #3677: [WIP]PIP-30: interface and mutual change authentication URL: https://github.com/apache/pulsar/pull/3677#discussion_r260105596 ## File path: pulsar-common/src/main/java/org/apache/pulsar/common/api/Commands.java ## @@ -1

[GitHub] srkukarni commented on issue #3685: Added a flush method for python producer

srkukarni commented on issue #3685: Added a flush method for python producer URL: https://github.com/apache/pulsar/pull/3685#issuecomment-467302190 run java8 tests This is an automated message from the Apache Git Service. To r

[GitHub] sijie commented on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation

sijie commented on issue #3625: [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partitioned topic creation URL: https://github.com/apache/pulsar/pull/3625#issuecomment-467304886 run java8 tests This is an automate