[GitHub] sijie closed issue #2743: NPE at RoundRobinScheduler

sijie closed issue #2743: NPE at RoundRobinScheduler URL: https://github.com/apache/pulsar/issues/2743 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL

[pulsar] branch master updated: fix: NPE when there are assignments for workers not in membership (#2744)

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 7e3203d fix: NPE when there are assignments for

[GitHub] sijie closed pull request #2744: fix: NPE when there are assignments for workers not in membership

sijie closed pull request #2744: fix: NPE when there are assignments for workers not in membership URL: https://github.com/apache/pulsar/pull/2744 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:

[GitHub] rdhabalia opened a new pull request #2745: Fix: deadlock on blocking ml operation

rdhabalia opened a new pull request #2745: Fix: deadlock on blocking ml operation URL: https://github.com/apache/pulsar/pull/2745 ### Motivation Found a deadlock in broker with below jstack. [Jstack](https://gist.github.com/rdhabalia/9cffa5005716d077a8a767a0cc6afd1b)

[GitHub] sijie opened a new pull request #2746: [clients][kafka] Fix topic name & race condition on kafka wrapper

sijie opened a new pull request #2746: [clients][kafka] Fix topic name & race condition on kafka wrapper URL: https://github.com/apache/pulsar/pull/2746 *Motivation* Current PulsarKafkaConsumer has following defects: - topic name is used inconsistently for keeping different

[pulsar] branch asf-site updated: Updated site at revision 7e3203d

This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/asf-site by this push: new 71dddee Updated site at revision 7e3203d

[GitHub] ivankelly commented on a change in pull request #2725: Fixed intermittent test failures with "bind error"

ivankelly commented on a change in pull request #2725: Fixed intermittent test failures with "bind error" URL: https://github.com/apache/pulsar/pull/2725#discussion_r223330384 ## File path:

[pulsar] annotated tag v2.2.0-candidate-1 updated (9a46975 -> 196d7ec)

This is an automated email from the ASF dual-hosted git repository. joef pushed a change to annotated tag v2.2.0-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar.git. *** WARNING: tag v2.2.0-candidate-1 was modified! *** from 9a46975 (commit) to 196d7ec (tag)

[pulsar] 01/01: Release 2.2.0

This is an automated email from the ASF dual-hosted git repository. joef pushed a commit to branch branch-2.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 9a469755d09592d6a726808240594a31d6492cf2 Author: joefk <22042978+jo...@users.noreply.github.com> AuthorDate: Mon Oct 8

[pulsar] branch branch-2.2 created (now 9a46975)

This is an automated email from the ASF dual-hosted git repository. joef pushed a change to branch branch-2.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git. at 9a46975 Release 2.2.0 This branch includes the following new commits: new 9a46975 Release 2.2.0 The 1

[GitHub] sijie commented on issue #2746: [clients][kafka] Fix topic name & race condition on kafka wrapper

sijie commented on issue #2746: [clients][kafka] Fix topic name & race condition on kafka wrapper URL: https://github.com/apache/pulsar/pull/2746#issuecomment-427908391 run integration tests run java8 tests This is an

[GitHub] srkukarni opened a new pull request #2747: All grpc calls should have timeouts

srkukarni opened a new pull request #2747: All grpc calls should have timeouts URL: https://github.com/apache/pulsar/pull/2747 ### Motivation Default timeout for grpc calls is infinity which means that problematic grpc calls end up holding resources forever. This pr attaches a timeout

[GitHub] sijie commented on issue #2741: Avoid shading netty in managed-ledger-shaded

sijie commented on issue #2741: Avoid shading netty in managed-ledger-shaded URL: https://github.com/apache/pulsar/pull/2741#issuecomment-428020921 run java8 tests This is an automated message from the Apache Git Service. To

[GitHub] jerrypeng commented on a change in pull request #2748: Fix getstatus logic in kubernetes runtime

jerrypeng commented on a change in pull request #2748: Fix getstatus logic in kubernetes runtime URL: https://github.com/apache/pulsar/pull/2748#discussion_r223532126 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java

[GitHub] srkukarni commented on issue #2748: Fix getstatus logic in kubernetes runtime

srkukarni commented on issue #2748: Fix getstatus logic in kubernetes runtime URL: https://github.com/apache/pulsar/pull/2748#issuecomment-428023706 @sijie handled null uri case This is an automated message from the Apache

[GitHub] sijie commented on a change in pull request #2748: Fix getstatus logic in kubernetes runtime

sijie commented on a change in pull request #2748: Fix getstatus logic in kubernetes runtime URL: https://github.com/apache/pulsar/pull/2748#discussion_r223531507 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java

[GitHub] srkukarni opened a new pull request #2748: Fix getstatus logic in kubernetes runtime

srkukarni opened a new pull request #2748: Fix getstatus logic in kubernetes runtime URL: https://github.com/apache/pulsar/pull/2748 ### Motivation When running in k8 environment, all instances of a function are owned by only one function worker. Now if there are multiple workers

[GitHub] sijie commented on a change in pull request #2748: Fix getstatus logic in kubernetes runtime

sijie commented on a change in pull request #2748: Fix getstatus logic in kubernetes runtime URL: https://github.com/apache/pulsar/pull/2748#discussion_r223533387 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java

[GitHub] sijie commented on a change in pull request #2748: Fix getstatus logic in kubernetes runtime

sijie commented on a change in pull request #2748: Fix getstatus logic in kubernetes runtime URL: https://github.com/apache/pulsar/pull/2748#discussion_r223532108 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java

[pulsar] 08/13: Made pulsar admin to use Source/Sink endpoints

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 4334d628fbffebc39d6d162911e1c9532c6fea83 Author: Sanjeev Kulkarni AuthorDate: Mon

[pulsar] 12/13: Fixed unittest

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit d6c62cf823064d3c136ee423bf0c08f192f1828d Author: Sanjeev Kulkarni AuthorDate: Mon

[pulsar] 03/13: Merge branch 'master' into serverside_validation_endpoints

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit eacd45380448b32547234ebfec05004959f630c1 Merge: 48f5233 79dd772 Author: Sanjeev

[pulsar] 02/13: More better check

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 48f5233f3eb0975aaf37974b4aa1310f292f41f9 Author: Sanjeev Kulkarni AuthorDate: Thu

[pulsar] 01/13: First cut of adding new endpoints for source/sink

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit ee81c7e7ad6a7b4f466ba4abf478545e6d3bccf2 Author: Sanjeev Kulkarni AuthorDate: Thu

[pulsar] 05/13: Plugged in source/sink

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit f8577658f940a582ee59d4e2467f1465a2655de1 Author: Sanjeev Kulkarni AuthorDate: Fri

[pulsar] 07/13: Merge branch 'master' into serverside_validation_endpoints

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit e4f848ce171de4b0769bfdd56a146a08d524d194 Merge: 41b108a f8e7dfe Author: Sanjeev

[pulsar] branch srkukarni/serverside_validation_endpoints created (now 8fd2209)

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a change to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git. at 8fd2209 Logic correction This branch includes the following new commits:

[pulsar] 13/13: Logic correction

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 8fd2209494db0756ef83627da5a7426cc7e2af02 Author: Sanjeev Kulkarni AuthorDate: Mon

[pulsar] 11/13: Fix unittests

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 625a31b952f32ed69753fd376e4f2a892effeba8 Author: Sanjeev Kulkarni AuthorDate: Mon

[pulsar] 06/13: Merge branch 'master' into serverside_validation_endpoints

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 41b108a8e09a0b4aa24621a1fd6add2bcc3fa719 Merge: f857765 d26bea8 Author: Sanjeev

[pulsar] 04/13: Merge branch 'master' into serverside_validation_endpoints

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit e59600aca89331b00077655fb575e94674de9c67 Merge: eacd453 525239b Author: Sanjeev

[pulsar] 09/13: Merge branch 'master' into serverside_validation_endpoints

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git commit d84aab19c768229d13a0a5faec3917b1c9e7e48b Merge: 4334d62 7e3203d Author: Sanjeev

[GitHub] jerrypeng commented on a change in pull request #2748: Fix getstatus logic in kubernetes runtime

jerrypeng commented on a change in pull request #2748: Fix getstatus logic in kubernetes runtime URL: https://github.com/apache/pulsar/pull/2748#discussion_r223531707 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java

[GitHub] sijie closed pull request #2748: Fix getstatus logic in kubernetes runtime

sijie closed pull request #2748: Fix getstatus logic in kubernetes runtime URL: https://github.com/apache/pulsar/pull/2748 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

[pulsar] branch master updated: Fix getstatus logic in kubernetes runtime (#2748)

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 90aa408 Fix getstatus logic in kubernetes

[pulsar] branch master updated: All grpc calls should have timeouts (#2747)

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 f718128 All grpc calls should have timeouts

[GitHub] srkukarni closed pull request #2747: All grpc calls should have timeouts

srkukarni closed pull request #2747: All grpc calls should have timeouts URL: https://github.com/apache/pulsar/pull/2747 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

[pulsar] branch master updated: [clients][kafka] Fix topic name & race condition on kafka wrapper (#2746)

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 dd4f71d [clients][kafka] Fix topic name & race