svn commit: r27523 - /dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/ /release/incubator/pulsar/pulsar-1.22.1-incubating/
Author: jai1 Date: Mon Jun 18 05:52:38 2018 New Revision: 27523 Log: (empty) Added: release/incubator/pulsar/pulsar-1.22.1-incubating/ - copied from r27522, dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/ Removed: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/
[incubator-pulsar.wiki] branch master updated: Updated Release process (markdown)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.wiki.git The following commit(s) were added to refs/heads/master by this push: new 0d12687 Updated Release process (markdown) 0d12687 is described below commit 0d126872fe8163868832cfdd4d521992cdec5c51 Author: Jai Asher AuthorDate: Tue Jun 12 17:53:46 2018 -0700 Updated Release process (markdown) --- Release-process.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Release-process.md b/Release-process.md index 15af5c5..9456cc3 100644 --- a/Release-process.md +++ b/Release-process.md @@ -231,7 +231,7 @@ Subject: [VOTE] Pulsar Release 1.X.0-incubating Candidate 1 ``` -Add a link to the dev@ vote thread, you can get that through lists.apache.org +Add a link to the dev@ vote thread, you can get that through https://lists.apache.org/ As before, the vote should be open for at least 72 hours and it should get at least 3 binding +1s from Incubator PMC members. -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar.wiki] branch master updated: Updated Release process (markdown)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.wiki.git The following commit(s) were added to refs/heads/master by this push: new 985f12f Updated Release process (markdown) 985f12f is described below commit 985f12f14cb2c3ecc1725a4d20a4578209207272 Author: Jai Asher AuthorDate: Tue Jun 12 10:25:36 2018 -0700 Updated Release process (markdown) --- Release-process.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/Release-process.md b/Release-process.md index 58fae27..15af5c5 100644 --- a/Release-process.md +++ b/Release-process.md @@ -231,6 +231,8 @@ Subject: [VOTE] Pulsar Release 1.X.0-incubating Candidate 1 ``` +Add a link to the dev@ vote thread, you can get that through lists.apache.org + As before, the vote should be open for at least 72 hours and it should get at least 3 binding +1s from Incubator PMC members. -- To stop receiving notification emails like this one, please contact j...@apache.org.
svn commit: r27311 - /dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/
Author: jai1 Date: Thu Jun 7 18:19:28 2018 New Revision: 27311 Log: Staging artifacts and signature for Pulsar release 1.22.1-incubating Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha1 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.sha1 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.sha512 Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc Thu Jun 7 18:19:28 2018 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlsZdw0ACgkQe6GmTLvB +FOxUcw//UvHcel+A0dmnoLCAMudwTreQJNgv0//XtB/q8qkQEd/LEpz+M9bJc1w+ +Lqiqsm+gfoEUN9vbs3emDhKaVichOMESDv3A1JnKGRHZC7gncVYe4m6AHW1Lg8dB +o8xIQvDVNdqxz8/IQ8OIE9k3HhvN0LP8E3iTIbCr659oA28DKLCt72zkUqSXdWNT +F15tSRiqkuTMs1+a1Y3ihT5icQ6kyAy1P+g8o7Nhceh7musELCd1jIsrq2c1f5Cj +PyLjdfCS4tjthCcLDKohlEWJ9vEcAgUBtAhDRok68vwioOdLFZp0jZ5uRm+m+LBV +6IZJMfGMQyCyoYBzW4bEj3PHYk5HdkPOPkN5FvFeqsYRf2inhb+l4l6EaiYOTmuf +MIofFxhi8p5pChCcB3JPrLxS0scGZ76OuyAuvqziPy8dGZAfovKhc2zDDAJZggbM +UyGyCIIihZjhVQInC1/pjtJ9ahvNV9B7sWZMAw9oE/a8SSsFo9pyysnppwEtawA9 +0cgzl0eoF8gbtf+0sLqWJLql56AHxiC/oCt5HbAhy5cL6dwY/moOmEGqGR56z+hA +mmnqfGjY//i66rVwYnwLnhrgePhp2K+RHlMHkBdlgN3QlxKnXMhmp+K1DHzDeqUY +cCiLp6kCY2M96HwlNvKpI1FO4tySPvaAdnJWOGmVtVd1SFR72hc= +=2rw2 +-END PGP SIGNATURE- Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha1 == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha1 (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha1 Thu Jun 7 18:19:28 2018 @@ -0,0 +1 @@ +f2704cae22b7fb3c1b72daab6ebe7d484fdfec6b apache-pulsar-1.22.1-incubating-bin.tar.gz Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 Thu Jun 7 18:19:28 2018 @@ -0,0 +1 @@ +62ffb1ebc82d6118375fb15cea298a2208c9bb3becffe1de8b3b67a3bf06e18a6c861f5cae2e043445b11539555ff364abb1dea1ffd8e555af417bb1b2ba293d apache-pulsar-1.22.1-incubating-bin.tar.gz Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.asc Thu Jun 7 18:19:28 2018 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlsZdw4ACgkQe6GmTLvB +FOxLJg/8CsLsT60wSsRsKbR53IGH8dqCRx1Mw9BhlVNIBABfDAvuIJLZH0/PwHuX ++J06KWwsPE/V1nyCgEaI8jw2HZjccVvufz06ZMYqtpzldgJspdnVKcqAqOWoCkM2 +fKhkyIysYumtz8OlMyXYS9HTYkR4ZVCt5YJauQCD0/yziOG02U1KXXm3yPacwN3Y +eTvJz08j8cfN0sxFM5orHIesV1fDNVJkQZp4ge11ANxRVbt9cg8ioWkeeD6M/01U +6FUkd3SqaNDh/fuOB5PAy5YlnpDJadVUN8P0ArCe3Dc0lDWgizCynjzBrRBp8fxi +YlJYR5m+QFWUbve3FeelBaBmgaCxvUJ8eZNu2vkVjy2vRkY0qAdeD6ikhJ9KYTss +cN+d94U2nW+Z0VcAMkale+3FZuGCGdWR9uiJ8GbTofRyyo60L83Za4Fl/a/10ty4 +ep0QmavRQfGVv1JAKV5HSZCLbhFq4BoJoO+tmST45jgYtg+sfSoizHOmwJtfvWw5 +Bdws8Czvb9x/tF2GJ+iVxQ3UHZ+cJZE6pV271CQWM3xbRmM7g+4f4Fju5vJLYMgE +CubGzANqCeYF9zNCLG9dTHeIi5x1ITKAiqsnnvYP+NiewxLs7CwR19pfgHVLRcGq +HpOwzEfhBmNMYvD0Ht6AGAQuE6c6X/viC3dWABzmoH28YN0p1R4= +=qtHv +-END PGP SIGNATURE- Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.sha1 == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.sha1 (added) +++ dev/incubator/pulsar/pulsar-1.22.1
svn commit: r27208 - /dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/
Author: jai1 Date: Fri Jun 1 06:35:43 2018 New Revision: 27208 Log: Staging artifacts and signature for Pulsar release 1.22.1-incubating Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz (with props) dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz (with props) dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.sha512 Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz == Binary file - no diff available. Propchange: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz -- svn:mime-type = application/octet-stream Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc Fri Jun 1 06:35:43 2018 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlsQ6PcACgkQe6GmTLvB +FOy/TA//QJ2gpD+5F668soGqop4gIUM1vsmGVBqHVHhBrESBfvZG+AoRwQ3aOhPf +cvu48Fd09bWVwwTJvrzBLAdiImbYUVfUzjqK5hSFORD0U921Mm54db2eh1rFM4OG +GT2qLFG8+bTAnjDlf+tcAAaeePWRhuiuabMWqvIRjIj+ZsTjWdonxr5kIyJrUSTX +gTKAywmEpiAa6nd3ru3xiV3aGZs2+vYZfZRkQvoSiozT8OBqhRawoKR1JWJWiIku +ZeW3dj9dKZ7eanrlXp1DVd8aZqs8RxDkRGfH2hTAUAl+QSXWWxrJCFwcgV13AZbP +36HRjGHVC2Nujylvfn3Yv9c3iytfRkaTtYjA7k0gDjayUZBnuGsuxpZsaU9Y2kj1 +6cwupq08Qfl+GcCzvBCCdbadCVGykIKAuazlbuU8yVa2YA7n6srQTi6yP9kPO/nD +Hl3IrI/uxiOCrtSifdIxpv9a+tdrrILxb9c9JVJKlPVR6P45YXz2s+vZ8A6Hahvs +m2CIPRwI/2Pj1mOMJQ0unUvsMW5CMImdnGrXIMZu4go9M1vAPmWipPm0MfWBHd4Q +bUPK6q7BGumMJgTFsgizEyhug/Eh4jKrorUdVu8Mcjjk4YIlZvyhsI3KERTYvP0q +h0naT5Rhh3BE3O/PKNrm1YNBc2ogITpCkirMmOHnoZB8CAbwPT8= +=r1Rr +-END PGP SIGNATURE- Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 Fri Jun 1 06:35:43 2018 @@ -0,0 +1,2 @@ +apache-pulsar-1.22.1-incubating-bin.tar.gz: +50 A7 55 CA 91 19 A6 3B 88 DD 3A 42 83 98 38 46 Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 Fri Jun 1 06:35:43 2018 @@ -0,0 +1,3 @@ +apache-pulsar-1.22.1-incubating-bin.tar.gz: +62FFB1EB C82D6118 375FB15C EA298A22 08C9BB3B ECFFE1DE 8B3B67A3 BF06E18A 6C861F5C + AE2E0434 45B11539 555FF364 ABB1DEA1 FFD8E555 AF417BB1 B2BA293D Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz == Binary file - no diff available. Propchange: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating-src.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-2/apache-pulsar-1.22.1-incubating
[incubator-pulsar] annotated tag v1.22.1-incubating-candidate-2 updated (c9a3699 -> c22cb99)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a change to annotated tag v1.22.1-incubating-candidate-2 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git. *** WARNING: tag v1.22.1-incubating-candidate-2 was modified! *** from c9a3699 (commit) to c22cb99 (tag) tagging c9a369936af3b3ecc663b86ae959a3fbfa627aca (commit) replaces v1.22.1-incubating-candidate-1 by jai1 on Mon May 28 17:07:41 2018 -0700 - Log - Release v1.22.1-incubating-candidate-2 -BEGIN PGP SIGNATURE- iQJEBAABCAAuFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlsMmc0QHGphaTFAYXBh Y2hlLm9yZwAKCRB7oaZMu8EU7MqgD/0U0p6OO0vpszRjxTsDr/4McVgpgT5WydL+ x2iWMc5HguhRQw6k6CaAz/B29eRIROW8jY3o0VRTTy8jHnN5gJ+XYDa65zfeMEfi TMrsb402bad9GK7HI8eqakV+gAgdLNyoSaVDPCu86FYWm/2ToCNzShpT6hkD7cfk h3Yx7ygmF8m0L4Xm3r8FzpyTBUk+YpA9zLwaBOsjumVZ6Q2rVTVbQORvCHwfIG/W UylfYeFwx2ZHFicBe9z9jPggLe8RCjkUSyMkjKo5O540ba0An7n4IIraP2/vNJ1U L9sOqRPI58xhrVpl6eIiO4ng9qwGtFWi2VN0gsgb/ceqeWJSVjsNuRbVOoKvPwdj //DHHc1/kfuJGJjY5Dg6h22z1nw9W+3sI8/KTEx3PEHPxE10/Ckb/xBRSB+X3EkX lGfnzRdANa4+p1HUG3/PIWseIIWfNgg2NYQuLj9/csPEfJVcNBa5IDdhU9KQm0+M U4fEw775FSJb9dyHMVnljMYVnAwo1rRKjNyDuumuds8uIkJg4+A02we35YSKmQPx sKQ2KHDDVzJt2f0Fro/BZAjj2aR3MtlQq/6CWteHhQpoEeow4BbYUOt3t+0KgwTQ LK5ntxt/g/fHpddvLHWflUdEn7RFFZZbVZec8fU5M1qDao/HlL6/TgNk8TlGiHti H63yKTebRA== =V19v -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes: -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar] branch branch-1.22 updated: Fixing resource leak due to open file descriptors in SecurityUtility.java (#1851)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new c9a3699 Fixing resource leak due to open file descriptors in SecurityUtility.java (#1851) c9a3699 is described below commit c9a369936af3b3ecc663b86ae959a3fbfa627aca Author: Jai Asher AuthorDate: Mon May 28 17:02:06 2018 -0700 Fixing resource leak due to open file descriptors in SecurityUtility.java (#1851) --- .../org/apache/pulsar/common/util/SecurityUtility.java | 16 ++-- 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/util/SecurityUtility.java b/pulsar-common/src/main/java/org/apache/pulsar/common/util/SecurityUtility.java index e9106f6..7121149 100644 --- a/pulsar-common/src/main/java/org/apache/pulsar/common/util/SecurityUtility.java +++ b/pulsar-common/src/main/java/org/apache/pulsar/common/util/SecurityUtility.java @@ -58,7 +58,7 @@ public class SecurityUtility { } public static SslContext createNettySslContextForClient(boolean allowInsecureConnection, String trustCertsFilePath) -throws GeneralSecurityException, SSLException, FileNotFoundException { +throws IOException, GeneralSecurityException, SSLException, FileNotFoundException { return createNettySslContextForClient(allowInsecureConnection, trustCertsFilePath, (Certificate[]) null, (PrivateKey) null); } @@ -73,7 +73,7 @@ public class SecurityUtility { public static SslContext createNettySslContextForClient(boolean allowInsecureConnection, String trustCertsFilePath, String certFilePath, String keyFilePath) -throws GeneralSecurityException, SSLException, FileNotFoundException { +throws IOException, GeneralSecurityException, SSLException, FileNotFoundException { X509Certificate[] certificates = loadCertificatesFromPemFile(certFilePath); PrivateKey privateKey = loadPrivateKeyFromPemFile(keyFilePath); return createNettySslContextForClient(allowInsecureConnection, trustCertsFilePath, certificates, privateKey); @@ -81,13 +81,15 @@ public class SecurityUtility { public static SslContext createNettySslContextForClient(boolean allowInsecureConnection, String trustCertsFilePath, Certificate[] certificates, PrivateKey privateKey) -throws GeneralSecurityException, SSLException, FileNotFoundException { +throws GeneralSecurityException, IOException, FileNotFoundException { SslContextBuilder builder = SslContextBuilder.forClient(); if (allowInsecureConnection) { builder.trustManager(InsecureTrustManagerFactory.INSTANCE); } else { if (trustCertsFilePath != null && trustCertsFilePath.length() != 0) { -builder.trustManager(new FileInputStream(trustCertsFilePath)); +try (FileInputStream input = new FileInputStream(trustCertsFilePath)) { +builder.trustManager(input); +} } } builder.keyManager(privateKey, (X509Certificate[]) certificates); @@ -96,7 +98,7 @@ public class SecurityUtility { public static SslContext createNettySslContextForServer(boolean allowInsecureConnection, String trustCertsFilePath, String certFilePath, String keyFilePath) -throws GeneralSecurityException, SSLException, FileNotFoundException { +throws IOException, GeneralSecurityException, SSLException, FileNotFoundException { X509Certificate[] certificates = loadCertificatesFromPemFile(certFilePath); PrivateKey privateKey = loadPrivateKeyFromPemFile(keyFilePath); @@ -105,7 +107,9 @@ public class SecurityUtility { builder.trustManager(InsecureTrustManagerFactory.INSTANCE); } else { if (trustCertsFilePath != null && trustCertsFilePath.length() != 0) { -builder.trustManager(new FileInputStream(trustCertsFilePath)); +try (FileInputStream input = new FileInputStream(trustCertsFilePath)) { +builder.trustManager(input); +} } else { builder.trustManager((File) null); } -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar] branch branch-1.22 updated: Fixed mem leak when acknowledging while disconnected from broker (#1817)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new b3d5256 Fixed mem leak when acknowledging while disconnected from broker (#1817) b3d5256 is described below commit b3d52562430da6bbeb7c0ab48edbe202a75b1099 Author: Matteo Merli <mme...@apache.org> AuthorDate: Sun May 20 16:21:49 2018 -0700 Fixed mem leak when acknowledging while disconnected from broker (#1817) --- .../src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java index b74bb13..4629aca 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java @@ -479,13 +479,13 @@ public class ConsumerImpl extends ConsumerBase { private CompletableFuture sendAcknowledge(MessageId messageId, AckType ackType, Map<String,Long> properties) { MessageIdImpl msgId = (MessageIdImpl) messageId; -final ByteBuf cmd = Commands.newAck(consumerId, msgId.getLedgerId(), msgId.getEntryId(), -ackType, null, properties); // There's no actual response from ack messages final CompletableFuture ackFuture = new CompletableFuture(); if (isConnected()) { +final ByteBuf cmd = Commands.newAck(consumerId, msgId.getLedgerId(), msgId.getEntryId(), +ackType, null, properties); cnx().ctx().writeAndFlush(cmd).addListener(new GenericFutureListener<Future>() { @Override public void operationComplete(Future future) throws Exception { -- To stop receiving notification emails like this one, please contact j...@apache.org.
svn commit: r26945 - /dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/
Author: jai1 Date: Wed May 16 04:00:52 2018 New Revision: 26945 Log: Staging artifacts and signature for Pulsar release 1.22.1-incubating Modified: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz.sha512 Modified: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz == Binary files - no diff available. Modified: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc (original) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc Wed May 16 04:00:52 2018 @@ -1,16 +1,16 @@ -BEGIN PGP SIGNATURE- -iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlr67BAACgkQe6GmTLvB -FOx02w/8DsVFMH8cz3BWlRU9w+gaz3MWHqPWpMUxHWUCLVEuyun/Q9DVvbHk5ytR -MYpyfLEU5qlPra5la/B1NSE96+O6EQ1Z17sQbN5E2hcS0pDJ3k/TcNbAAAit4yph -sLSjeLKPzbQM+noR9URldE1QrSfwE+h4xrRnr6Z05Nk3I1uQFfckpFQLM+1ETJIx -kiB7U6/tfZAmHGT5h3z6T84Ir/S7YfHEhcJAhCUAEjWRAhj08wosrBbOsInPuPqs -IsxWJoGhnX/LPSM8tjUyVemFiIayRP7gLyPX4gxYV+glDgAiX7Uog16YnU1EVYv2 -6+sTmKTRSQ75w2/jEgyZsrXnxBPQ3P8ad+vDyza0cWSm4H+ZChdAfpAUkiSfEEr1 -gL9+iFB5e6WZxJN8McgZfzYFd9Uwzh+OxVhcPEss0ND1ueGmeSVrY8OanXhvFslM -/aKzrxCUQ6RieCbFEzrbRMRMGyZi8XnMmW/CoTHolOTbPTn124TNgGo7Mt33QZyj -Ps+uFFj9MLGJfBT1TzftjxRA1B20RUggK8i6cDRpRfgHggefSnE+w78VwIxuynRi -3U0gcZgRQidCmdb9+5iAqTjODxT3hmrP9J35Jl+E0yWCzpr2VHiCu+eakj3goUQ3 -RcV33z4Uy9IYykAaeikxfGVCXpDYhZo86SFthNkpYZkp4WNnjUo= -=hm8U +iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlr7rHkACgkQe6GmTLvB +FOxniA/+MGw5sJnMOkP6kgAH6y+R4oGy4/VGIRT2NQeZcPeNp0TOZ3ZjfxvY6YPR +Cvv1ZeMbPksSeZLX/RRN+rFMkmx/UMMZ8E/OKBinQ3y6Tukk2C1ScK6aPit1H7KV +LA/ckJd38rPIx02XrmFhkX3lcRrWeeCeTiMXCVyIF5xv2/mfo+PMR3Dg/j31rCWY +8Kw818T+jdzJ2zV9PVo7H/6ob+Optb55CNEoKoot8fZPkGRm8/2hVz9n4Y7ITk3W +8Ol9tM9UjA2tQpI3NGAIxXJ/Kno3mwDKdaUZ0cA3jH9VDoDLPj3fKakzLG8YSs5y ++iblrvmlknDVNDFuKjgAF7o2uezTzefu3WegnApY+9WiwGqWE0l1O4X6bUOC10iU +qlC27qDSck6t6A0369zuuM4iDQkvkw5nkSnRIBABRBnLwBYOof+4aFXMH5JI0Z3i +soQuYh/GT4ZHx4lBgEHJbATLmGNxT/BXvtvW1eHlIO9PGZGJScEhk05PkJvAxfHY +QLaPRCArd3utrniIWZldTB4RGY0LWhfEyDUmGeQyeffSNFWfWvhqmvOqBgxBZZKH +YBCc8BmowvNlKWsQGq9MapDTQf7p9ii/J4ZfcmaPg8NHrnF0DfmNdjlh92RvKXfx +WZS0klF8AtBwGTsqs9gtA+Epn9e+S6DlPPwzixn0LE8z4Db/rcU= +=AH1C -END PGP SIGNATURE- Modified: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 (original) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 Wed May 16 04:00:52 2018 @@ -1,2 +1,2 @@ -apache-pulsar-1.22.1-incubating-bin.tar.gz: -87 17 EE DF 40 31 52 F2 E9 9C FA 32 E5 E8 BA B8 +./apache-pulsar-1.22.1-incubating-bin.tar.gz: +1C 20 F0 83 0D 3D 05 D2 27 58 DD B1 0C 12 28 8B Modified: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 (original) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 Wed May 16 04:00:52 2018 @@ -1,3 +1,3 @@ -apache-pulsar-1.22.1-incubating-bin.tar.gz: -7CE22540 EABEC216 43B7D5BE BB489E15 F8618BF2 178B2DE9 53F75398 18D99F87 A5B9AB16 - 3D693F68 3958FCFA B1ABB12F C7831BFC 9F9255F3 AD67A09A 48BDD09D +./apache-pulsar-1.22.1-incubating-bin.tar.gz: +7B1CE6BC 4D25CB1E F18A0B6E 7519EDD1 5E6D399A C43DC6C9 3CF7C751 F7C1420E AF2E33B3 + 67762EF5 18262A00 4F37054E D91E50F5 2CCAF4D9 DFE9D232 CFACBBE2 Modified: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating
svn commit: r26924 - /dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/
Author: jai1 Date: Tue May 15 14:23:30 2018 New Revision: 26924 Log: Staging artifacts and signature for Pulsar release 1.22.1-incubating Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz (with props) dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz (with props) dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz.sha512 Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz == Binary file - no diff available. Propchange: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz -- svn:mime-type = application/octet-stream Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.asc Tue May 15 14:23:30 2018 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlr67BAACgkQe6GmTLvB +FOx02w/8DsVFMH8cz3BWlRU9w+gaz3MWHqPWpMUxHWUCLVEuyun/Q9DVvbHk5ytR +MYpyfLEU5qlPra5la/B1NSE96+O6EQ1Z17sQbN5E2hcS0pDJ3k/TcNbAAAit4yph +sLSjeLKPzbQM+noR9URldE1QrSfwE+h4xrRnr6Z05Nk3I1uQFfckpFQLM+1ETJIx +kiB7U6/tfZAmHGT5h3z6T84Ir/S7YfHEhcJAhCUAEjWRAhj08wosrBbOsInPuPqs +IsxWJoGhnX/LPSM8tjUyVemFiIayRP7gLyPX4gxYV+glDgAiX7Uog16YnU1EVYv2 +6+sTmKTRSQ75w2/jEgyZsrXnxBPQ3P8ad+vDyza0cWSm4H+ZChdAfpAUkiSfEEr1 +gL9+iFB5e6WZxJN8McgZfzYFd9Uwzh+OxVhcPEss0ND1ueGmeSVrY8OanXhvFslM +/aKzrxCUQ6RieCbFEzrbRMRMGyZi8XnMmW/CoTHolOTbPTn124TNgGo7Mt33QZyj +Ps+uFFj9MLGJfBT1TzftjxRA1B20RUggK8i6cDRpRfgHggefSnE+w78VwIxuynRi +3U0gcZgRQidCmdb9+5iAqTjODxT3hmrP9J35Jl+E0yWCzpr2VHiCu+eakj3goUQ3 +RcV33z4Uy9IYykAaeikxfGVCXpDYhZo86SFthNkpYZkp4WNnjUo= +=hm8U +-END PGP SIGNATURE- Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.md5 Tue May 15 14:23:30 2018 @@ -0,0 +1,2 @@ +apache-pulsar-1.22.1-incubating-bin.tar.gz: +87 17 EE DF 40 31 52 F2 E9 9C FA 32 E5 E8 BA B8 Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-bin.tar.gz.sha512 Tue May 15 14:23:30 2018 @@ -0,0 +1,3 @@ +apache-pulsar-1.22.1-incubating-bin.tar.gz: +7CE22540 EABEC216 43B7D5BE BB489E15 F8618BF2 178B2DE9 53F75398 18D99F87 A5B9AB16 + 3D693F68 3958FCFA B1ABB12F C7831BFC 9F9255F3 AD67A09A 48BDD09D Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz == Binary file - no diff available. Propchange: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating-src.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.1-incubating-candidate-1/apache-pulsar-1.22.1-incubating
[incubator-pulsar] branch branch-1.22 updated: Fixed backporting errors and lombok license (#1752)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new 0093a80 Fixed backporting errors and lombok license (#1752) 0093a80 is described below commit 0093a8024f2be1aea8d85406dca403c3ef01e17c Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed May 9 00:46:17 2018 -0700 Fixed backporting errors and lombok license (#1752) --- all/licenses/LICENSE-Lombok.txt | 19 +++ all/src/assemble/LICENSE.bin.txt | 1 + pom.xml | 7 +++ .../pulsar/broker/namespace/NamespaceService.java | 13 + .../org/apache/pulsar/broker/admin/AdminApiTest.java | 2 +- 5 files changed, 37 insertions(+), 5 deletions(-) diff --git a/all/licenses/LICENSE-Lombok.txt b/all/licenses/LICENSE-Lombok.txt new file mode 100644 index 000..5da7dbe --- /dev/null +++ b/all/licenses/LICENSE-Lombok.txt @@ -0,0 +1,19 @@ +Copyright (C) 2009-2015 The Project Lombok Authors. + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is +furnished to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in +all copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +THE SOFTWARE. diff --git a/all/src/assemble/LICENSE.bin.txt b/all/src/assemble/LICENSE.bin.txt index 944ba2d..b5e7db8 100644 --- a/all/src/assemble/LICENSE.bin.txt +++ b/all/src/assemble/LICENSE.bin.txt @@ -348,6 +348,7 @@ BSD License MIT License * Java SemVer -- com.github.zafarkhaja-java-semver-*.jar -- licenses/LICENSE-SemVer.txt * SLF4J -- org.slf4j.*.jar -- licenses/LICENSE-SLF4J.txt + * Lombok -- org.projectlombok-*.jar -- licenses/LICENSE-Lombok.txt Protocol Buffers License * Protocol Buffers -- com.google.protobuf-*.jar -- licenses/LICENSE-protobuf.txt diff --git a/pom.xml b/pom.xml index 16b1eca..9043897 100644 --- a/pom.xml +++ b/pom.xml @@ -592,6 +592,13 @@ flexible messaging model and an intuitive client API. powermock-module-testng test + + + org.projectlombok + lombok + 1.16.20 + provided + diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java index b8e4ae0..547f914 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java @@ -42,6 +42,7 @@ import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Collectors; +import org.apache.bookkeeper.util.SafeRunnable; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.tuple.Pair; import org.apache.pulsar.broker.PulsarServerException; @@ -632,12 +633,16 @@ public class NamespaceService { // If success updateNamespaceBundles, then do invalidateBundleCache and unload. // Else retry splitAndOwnBundleOnceAndRetry. -updateFuture.whenCompleteAsync((r, t)-> { +updateFuture.whenComplete((r, t)-> { if (t != null) { // retry several times on BadVersion if ((t instanceof ServerMetadataException) && (counter.decrementAndGet() >= 0)) { -pulsar.getOrderedExecutor().submit( -() -> splitAndOwnBundleOnceAndRetry(bundle, unload, counter, unloadFuture)); +pulsar.getOrderedExecutor().submit(new SafeRunnable() { +@Override +public void safeRun() { +splitAndOwnBundleOnceAndRetry(bundle, unload, counter, unloadFuture); +} +}); } else { // Retry enough, or meet other exception String msg2 = format(" %s not success update nsBundles,
[incubator-pulsar] branch master updated: Fixed authentication flow via Pulsar Proxy (#1707)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/master by this push: new 9348d34 Fixed authentication flow via Pulsar Proxy (#1707) 9348d34 is described below commit 9348d34e830f558e3fc0ca096115bcc0d569ab0d Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Thu May 3 00:04:24 2018 -0700 Fixed authentication flow via Pulsar Proxy (#1707) --- .../apache/pulsar/broker/service/ServerCnx.java| 52 +--- .../org/apache/pulsar/client/impl/ClientCnx.java | 30 ++- .../apache/pulsar/client/impl/ConnectionPool.java | 7 +- .../apache/pulsar/client/impl/ConsumerImpl.java| 6 +- .../org/apache/pulsar/common/api/Commands.java | 66 ++--- pulsar-common/src/main/proto/PulsarApi.proto | 2 + .../pulsar/proxy/server/DirectProxyHandler.java| 29 ++- .../pulsar/proxy/server/LookupProxyHandler.java| 35 ++- .../apache/pulsar/proxy/server/ProxyClientCnx.java | 63 + .../pulsar/proxy/server/ProxyConnection.java | 95 ++-- .../apache/pulsar/proxy/server/ProxyService.java | 57 + .../proxy/server/ProxyAuthenticationTest.java | 268 + .../proxy/server/ProxyForwardAuthDataTest.java | 2 +- 13 files changed, 502 insertions(+), 210 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java index 4fac97d..f8ad145 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java @@ -227,21 +227,6 @@ public class ServerCnx extends PulsarHandler { return; } -String originalPrincipal = null; -if (authenticateOriginalAuthData && lookup.hasOriginalAuthData()) { -originalPrincipal = validateOriginalPrincipal( -lookup.hasOriginalAuthData() ? lookup.getOriginalAuthData() : null, -lookup.hasOriginalAuthMethod() ? lookup.getOriginalAuthMethod() : null, -lookup.hasOriginalPrincipal() ? lookup.getOriginalPrincipal() : this.originalPrincipal, requestId, -lookup); - -if (originalPrincipal == null) { -return; -} -} else { -originalPrincipal = lookup.hasOriginalPrincipal() ? lookup.getOriginalPrincipal() : this.originalPrincipal; -} - final Semaphore lookupSemaphore = service.getLookupRequestSemaphore(); if (lookupSemaphore.tryAcquire()) { if (invalidOriginalPrincipal(originalPrincipal)) { @@ -312,22 +297,7 @@ public class ServerCnx extends PulsarHandler { if (topicName == null) { return; } -String originalPrincipal = null; -if (authenticateOriginalAuthData && partitionMetadata.hasOriginalAuthData()) { -originalPrincipal = validateOriginalPrincipal( -partitionMetadata.hasOriginalAuthData() ? partitionMetadata.getOriginalAuthData() : null, -partitionMetadata.hasOriginalAuthMethod() ? partitionMetadata.getOriginalAuthMethod() : null, -partitionMetadata.hasOriginalPrincipal() ? partitionMetadata.getOriginalPrincipal() -: this.originalPrincipal, -requestId, partitionMetadata); - -if (originalPrincipal == null) { -return; -} -} else { -originalPrincipal = partitionMetadata.hasOriginalPrincipal() ? partitionMetadata.getOriginalPrincipal() : this.originalPrincipal; -} - + final Semaphore lookupSemaphore = service.getLookupRequestSemaphore(); if (lookupSemaphore.tryAcquire()) { if (invalidOriginalPrincipal(originalPrincipal)) { @@ -450,26 +420,6 @@ public class ServerCnx extends PulsarHandler { return commandConsumerStatsResponseBuilder; } -private String validateOriginalPrincipal(String originalAuthData, String originalAuthMethod, String originalPrincipal, Long requestId, GeneratedMessageLite request) { -ChannelHandler sslHandler = ctx.channel().pipeline().get(PulsarChannelInitializer.TLS_HANDLER); -SSLSession sslSession = null; -if (sslHandler != null) { -sslSession = ((SslHandler) sslHandler).engine().getSession(); -} -try { -return getOriginalPrincipal(originalAuthData, originalAuthMethod, originalPrincipal, sslSession); -} catch (AuthenticationException e) { -String msg = "Unable to authenticate original authdata "; -log.warn("[{}] {}: {}", remoteAddress, msg, e.getMessa
[incubator-pulsar] annotated tag v1.22.1-incubating-candidate-1 updated (741174e -> 3151f61)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a change to annotated tag v1.22.1-incubating-candidate-1 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git. *** WARNING: tag v1.22.1-incubating-candidate-1 was modified! *** from 741174e (commit) to 3151f61 (tag) tagging 741174e6b0a46592a46fe2944ef292f08bffa347 (commit) replaces v1.22.0-incubating by jai1 on Wed May 2 13:30:43 2018 -0700 - Log - Release v1.22.1-incubating-candidate-1 -BEGIN PGP SIGNATURE- iQJEBAABCAAuFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlrqH/MQHGphaTFAYXBh Y2hlLm9yZwAKCRB7oaZMu8EU7HnnEACnKg275Ih7aXXK5u6L6qbMj5ELicjWxB8e EF4My0e7+H1KyRTez1PnMmCMel4w3twFUjSg4VMbyh9N9ts36Zz9kC4NfecP1xPI NXR9QG1DxKwdK3OTfFnZQO4H7KDV0F9O20jNiw2QiVX8gitEf4cQPT3RX1Djcbfm 2/TlkZheaBQay/lDUayU4VTjnTG8aJZ5ZSEwy+pC1n6sgZXq0YN60afj5eDXet2o tRuOSazGmxtBJKk6PVC7pCOgUEyYVxUEFcH8qn67P5Gdu4s4HUL3gxVrXSrR9Zd0 9ne49yReU4+XGhW+nIg0kenVvl5+Yezt+vD2yqvIFbQxgEZHKCjaVk9XjnCa42js /592iryYDiwDulefkWhybH2bg1E17szCQiN3gLKAn51Bc90nY/V5Hy752U2S7IgE W4zgDnA8LgMKR9Dr2i0fv+JlO59Ki2meBpDBjH09eYseidVc0a2Dh+xsoQvWIkc7 qn7QD9ElbMw6LO2R1n13g9Cq89kMIplr8T4N3WO4WxLa2ILgqZPAnABQPW42tIIZ JDrLEzfvmF1WXM43mQV4a/3SWPS7VaP/mUCFh2n7bwX+KKaWiYO21M9IWvymghql 8J9iA7wXF0Q0pP7mF6JR9Cswtsl+ZlrGC46qXel9cUAPXbeSv6PaV3sj5RQQtpuC c9s4uY2U/Q== =Q5kY -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes: -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar] branch branch-1.22 updated: Release 1.22.1-incubating
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new 741174e Release 1.22.1-incubating 741174e is described below commit 741174e6b0a46592a46fe2944ef292f08bffa347 Author: jai1 <j...@apache.org> AuthorDate: Wed May 2 13:29:23 2018 -0700 Release 1.22.1-incubating --- all/pom.xml | 2 +- buildtools/pom.xml | 2 +- managed-ledger/pom.xml | 2 +- pom.xml | 2 +- pulsar-broker-auth-athenz/pom.xml| 2 +- pulsar-broker-common/pom.xml | 2 +- pulsar-broker-shaded/pom.xml | 2 +- pulsar-broker/pom.xml| 2 +- pulsar-checksum/pom.xml | 2 +- pulsar-client-admin-shaded/pom.xml | 2 +- pulsar-client-admin/pom.xml | 2 +- pulsar-client-auth-athenz/pom.xml| 2 +- pulsar-client-kafka-compat/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml | 2 +- pulsar-client-shaded/pom.xml | 2 +- pulsar-client-tools/pom.xml | 2 +- pulsar-client/pom.xml| 2 +- pulsar-common/pom.xml| 2 +- pulsar-discovery-service/pom.xml | 2 +- pulsar-proxy/pom.xml | 2 +- pulsar-spark/pom.xml | 2 +- pulsar-storm/pom.xml | 2 +- pulsar-testclient/pom.xml| 2 +- pulsar-websocket/pom.xml | 2 +- pulsar-zookeeper-utils/pom.xml | 2 +- pulsar-zookeeper/pom.xml | 2 +- 27 files changed, 27 insertions(+), 27 deletions(-) diff --git a/all/pom.xml b/all/pom.xml index 4283f55..5f7ae07 100644 --- a/all/pom.xml +++ b/all/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar -1.22.0-incubating +1.22.1-incubating .. diff --git a/buildtools/pom.xml b/buildtools/pom.xml index 11a3bd9..2e42b9b 100644 --- a/buildtools/pom.xml +++ b/buildtools/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar -1.22.0-incubating +1.22.1-incubating .. diff --git a/managed-ledger/pom.xml b/managed-ledger/pom.xml index 0cdff4a..f4bf035 100644 --- a/managed-ledger/pom.xml +++ b/managed-ledger/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar -1.22.0-incubating +1.22.1-incubating .. diff --git a/pom.xml b/pom.xml index daa6c5a..16b1eca 100644 --- a/pom.xml +++ b/pom.xml @@ -33,7 +33,7 @@ org.apache.pulsar pulsar - 1.22.0-incubating + 1.22.1-incubating Pulsar Pulsar is a distributed pub-sub messaging platform with a very diff --git a/pulsar-broker-auth-athenz/pom.xml b/pulsar-broker-auth-athenz/pom.xml index 0e5f6b1..3a24bd2 100644 --- a/pulsar-broker-auth-athenz/pom.xml +++ b/pulsar-broker-auth-athenz/pom.xml @@ -26,7 +26,7 @@ org.apache.pulsar pulsar -1.22.0-incubating +1.22.1-incubating pulsar-broker-auth-athenz diff --git a/pulsar-broker-common/pom.xml b/pulsar-broker-common/pom.xml index b65323f..940668a 100644 --- a/pulsar-broker-common/pom.xml +++ b/pulsar-broker-common/pom.xml @@ -26,7 +26,7 @@ org.apache.pulsar pulsar -1.22.0-incubating +1.22.1-incubating pulsar-broker-common diff --git a/pulsar-broker-shaded/pom.xml b/pulsar-broker-shaded/pom.xml index 6d552bf..efc43c5 100644 --- a/pulsar-broker-shaded/pom.xml +++ b/pulsar-broker-shaded/pom.xml @@ -26,7 +26,7 @@ org.apache.pulsar pulsar -1.22.0-incubating +1.22.1-incubating .. diff --git a/pulsar-broker/pom.xml b/pulsar-broker/pom.xml index f5c6528..868e1f4 100644 --- a/pulsar-broker/pom.xml +++ b/pulsar-broker/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar -1.22.0-incubating +1.22.1-incubating .. diff --git a/pulsar-checksum/pom.xml b/pulsar-checksum/pom.xml index ff0a63a..837286b 100644 --- a/pulsar-checksum/pom.xml +++ b/pulsar-checksum/pom.xml @@ -26,7 +26,7 @@ org.apache.pulsar pulsar -1.22.0-incubating +1.22.1-incubating .. diff --git a/pulsar-client-admin-shaded/pom.xml b/pulsar-client-admin-shaded/pom.xml index f72243f..c3c3928 100644 --- a/pulsar-
[incubator-pulsar] branch branch-1.22 updated: Broker should not start replicator for root partitioned-topic (#1715)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new ca7559b Broker should not start replicator for root partitioned-topic (#1715) ca7559b is described below commit ca7559bd4e54eff3b3be8ba01263805da162bee0 Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed May 2 13:15:24 2018 -0700 Broker should not start replicator for root partitioned-topic (#1715) --- .../pulsar/broker/service/AbstractReplicator.java | 48 ++- .../pulsar/broker/service/BrokerService.java | 53 +--- .../nonpersistent/NonPersistentReplicator.java | 3 +- .../service/nonpersistent/NonPersistentTopic.java | 43 - .../service/persistent/PersistentReplicator.java | 3 +- .../broker/service/persistent/PersistentTopic.java | 39 ++-- .../pulsar/broker/service/ReplicatorTest.java | 72 ++ .../pulsar/broker/service/ReplicatorTestBase.java | 3 + 8 files changed, 216 insertions(+), 48 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java index 1913dd5..d5480cc 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java @@ -18,17 +18,22 @@ */ package org.apache.pulsar.broker.service; +import static org.apache.pulsar.broker.web.PulsarWebResource.path; + import java.util.concurrent.CompletableFuture; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; import org.apache.bookkeeper.mledger.ManagedCursor; import org.apache.bookkeeper.mledger.Position; +import org.apache.pulsar.broker.admin.AdminResource; +import org.apache.pulsar.broker.service.BrokerServiceException.NamingException; import org.apache.pulsar.broker.service.BrokerServiceException.TopicBusyException; import org.apache.pulsar.client.api.ProducerConfiguration; import org.apache.pulsar.client.impl.Backoff; import org.apache.pulsar.client.impl.ProducerImpl; import org.apache.pulsar.client.impl.PulsarClientImpl; +import org.apache.pulsar.common.naming.DestinationName; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -57,8 +62,9 @@ public abstract class AbstractReplicator { Stopped, Starting, Started, Stopping } -public AbstractReplicator(String topicName, String replicatorPrefix, String localCluster, -String remoteCluster, BrokerService brokerService) { +public AbstractReplicator(String topicName, String replicatorPrefix, String localCluster, String remoteCluster, +BrokerService brokerService) throws NamingException { +validatePartitionedTopic(topicName, brokerService); this.brokerService = brokerService; this.topicName = topicName; this.replicatorPrefix = replicatorPrefix; @@ -67,7 +73,6 @@ public abstract class AbstractReplicator { this.client = (PulsarClientImpl) brokerService.getReplicationClient(remoteCluster); this.producer = null; this.producerQueueSize = brokerService.pulsar().getConfiguration().getReplicationProducerQueueSize(); - this.producerConfiguration = new ProducerConfiguration(); this.producerConfiguration.setSendTimeout(0, TimeUnit.SECONDS); this.producerConfiguration.setMaxPendingMessages(producerQueueSize); @@ -214,5 +219,42 @@ public abstract class AbstractReplicator { return (replicatorPrefix + "." + cluster).intern(); } +/** + * Replication can't be started on root-partitioned-topic to avoid producer startup conflict. + * + * + * eg: + * if topic : persistent://prop/cluster/ns/my-topic is a partitioned topic with 2 partitions then + * broker explicitly creates replicator producer for: "my-topic-partition-1" and "my-topic-partition-2". + * + * However, if broker tries to start producer with root topic "my-topic" then client-lib internally creates individual + * producers for "my-topic-partition-1" and "my-topic-partition-2" which creates conflict with existing + * replicator producers. + * + * + * Therefore, replicator can't be started on root-partition topic which can internally create multiple partitioned + * producers. + * + * @param topicName + * @param brokerService + */ +private void validatePartitionedTopic(String topicName, BrokerService brokerService) throws NamingException { +DestinationName destination = DestinationName.get(topicName); +String parti
[incubator-pulsar] branch branch-1.22 updated (1875841 -> 5484585)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a change to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git. from 1875841 Fix: handle invalid markDelete position at managed-cursor (#1718) add 5484585 Fix: deadlock while closing non-shared consumer (#1716) No new revisions were added by this update. Summary of changes: .../pulsar/broker/service/persistent/PersistentSubscription.java | 8 ++-- 1 file changed, 6 insertions(+), 2 deletions(-) -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar] branch branch-1.22 updated: Fix: handle invalid markDelete position at managed-cursor (#1718)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new 1875841 Fix: handle invalid markDelete position at managed-cursor (#1718) 1875841 is described below commit 187584155bcacec0900e8f6203a5f81a1e60ec7d Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed May 2 13:14:48 2018 -0700 Fix: handle invalid markDelete position at managed-cursor (#1718) --- .../bookkeeper/mledger/impl/ManagedCursorImpl.java | 22 - .../bookkeeper/mledger/impl/ManagedCursorTest.java | 56 ++ 2 files changed, 77 insertions(+), 1 deletion(-) diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java index 22cdf3d..8172784 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java @@ -1291,7 +1291,7 @@ public class ManagedCursorImpl implements ManagedCursor { final MarkDeleteCallback callback, final Object ctx) { checkNotNull(position); checkArgument(position instanceof PositionImpl); - + if (STATE_UPDATER.get(this) == State.Closed) { callback.markDeleteFailed(new ManagedLedgerException("Cursor was already closed"), ctx); return; @@ -1312,6 +1312,16 @@ public class ManagedCursorImpl implements ManagedCursor { log.debug("[{}] Mark delete cursor {} up to position: {}", ledger.getName(), name, position); } PositionImpl newPosition = (PositionImpl) position; + +if (((PositionImpl) ledger.getLastConfirmedEntry()).compareTo(newPosition) < 0) { +if (log.isDebugEnabled()) { +log.debug( +"[{}] Failed mark delete due to invalid markDelete {} is ahead of last-confirmed-entry {} for cursor [{}]", +ledger.getName(), position, ledger.getLastConfirmedEntry(), name); +} +callback.markDeleteFailed(new ManagedLedgerException("Invalid mark deleted position"), ctx); +return; +} lock.writeLock().lock(); try { @@ -1509,6 +1519,16 @@ public class ManagedCursorImpl implements ManagedCursor { ledger.getName(), name, pos, individualDeletedMessages, markDeletePosition, previousPosition); } +if (((PositionImpl) ledger.getLastConfirmedEntry()).compareTo(position) < 0) { +if (log.isDebugEnabled()) { +log.debug( +"[{}] Failed mark delete due to invalid markDelete {} is ahead of last-confirmed-entry {} for cursor [{}]", +ledger.getName(), position, ledger.getLastConfirmedEntry(), name); +} +callback.deleteFailed(new ManagedLedgerException("Invalid mark deleted position"), ctx); +return; +} + if (individualDeletedMessages.contains(position) || position.compareTo(markDeletePosition) <= 0) { if (log.isDebugEnabled()) { log.debug("[{}] [{}] Position was already deleted {}", ledger.getName(), name, position); diff --git a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java index 61e9b3d..59e1594 100644 --- a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java +++ b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java @@ -49,6 +49,7 @@ import org.apache.bookkeeper.client.LedgerEntry; import org.apache.bookkeeper.client.BookKeeper.DigestType; import org.apache.bookkeeper.mledger.AsyncCallbacks; import org.apache.bookkeeper.mledger.AsyncCallbacks.AddEntryCallback; +import org.apache.bookkeeper.mledger.AsyncCallbacks.DeleteCallback; import org.apache.bookkeeper.mledger.AsyncCallbacks.MarkDeleteCallback; import org.apache.bookkeeper.mledger.AsyncCallbacks.ReadEntriesCallback; import org.apache.bookkeeper.mledger.Entry; @@ -2614,5 +2615,60 @@ public class ManagedCursorTest extends MockedBookKeeperTestCase { assertEquals(entries.size(), totalAddEntries / 2); } +@Test +public void testInvalidMarkDelete() throws Exception { +ManagedLedger ledger = factory.open("my_test_ledger", new ManagedLedgerConfig()); + +ManagedCursor cursor = ledger.openCursor("c1"); +Position readPosition = cursor.g
[incubator-pulsar] branch branch-1.22 updated: Fix: deadlock while closing non-persistent topic
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new 1a31f91 Fix: deadlock while closing non-persistent topic 1a31f91 is described below commit 1a31f91660de11060e0286e83ea35ef745e596f7 Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed May 2 01:28:40 2018 -0700 Fix: deadlock while closing non-persistent topic --- .../pulsar/broker/service/nonpersistent/NonPersistentTopic.java | 8 ++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java index 44a9e14..5d6b4ba 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java @@ -462,8 +462,12 @@ public class NonPersistentTopic implements Topic { FutureUtil.waitForAll(futures).thenRun(() -> { log.info("[{}] Topic closed", topic); -brokerService.pulsar().getExecutor().submit(() -> brokerService.removeTopicFromCache(topic)); -closeFuture.complete(null); +// unload topic iterates over topics map and removing from the map with the same thread creates deadlock. +// so, execute it in different thread +brokerService.executor().execute(() -> { +brokerService.removeTopicFromCache(topic); +closeFuture.complete(null); +}); }).exceptionally(exception -> { log.error("[{}] Error closing topic", topic, exception); isFenced = false; -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar] branch branch-1.22 updated: Relocate service files for shading `pulsar-client-admin` module
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new 4c946b6 Relocate service files for shading `pulsar-client-admin` module 4c946b6 is described below commit 4c946b6d70172347d07057f8cb5a2b33ca327d3c Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed May 2 01:28:21 2018 -0700 Relocate service files for shading `pulsar-client-admin` module --- pom.xml| 2 +- pulsar-client-admin-shaded/pom.xml | 4 pulsar-client-shaded/pom.xml | 4 3 files changed, 9 insertions(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index b4e63d7..daa6c5a 100644 --- a/pom.xml +++ b/pom.xml @@ -805,7 +805,7 @@ flexible messaging model and an intuitive client API. org.apache.maven.plugins maven-shade-plugin - 2.4.2 + 3.1.0 maven-enforcer-plugin diff --git a/pulsar-client-admin-shaded/pom.xml b/pulsar-client-admin-shaded/pom.xml index c5624fe..f72243f 100644 --- a/pulsar-client-admin-shaded/pom.xml +++ b/pulsar-client-admin-shaded/pom.xml @@ -185,6 +185,10 @@ org.apache.pulsar.admin.shade.org.reactivestreams + + + + diff --git a/pulsar-client-shaded/pom.xml b/pulsar-client-shaded/pom.xml index 81f873e..9219c1f 100644 --- a/pulsar-client-shaded/pom.xml +++ b/pulsar-client-shaded/pom.xml @@ -160,6 +160,10 @@ org.apache.pulsar.shade.org.apache.http + + + + -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar] branch branch-1.22 updated: Fix: NPE when cursor failed to close empty subscription
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new 5ce64ff Fix: NPE when cursor failed to close empty subscription 5ce64ff is described below commit 5ce64ff0f2196ad791b2e19c64772c11a63e0030 Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed May 2 01:27:53 2018 -0700 Fix: NPE when cursor failed to close empty subscription --- .../pulsar/broker/service/persistent/PersistentSubscription.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java index e742f14..5e6153b 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java @@ -533,7 +533,9 @@ public class PersistentSubscription implements Subscription { disconnectFuture.complete(null); }).exceptionally(exception -> { IS_FENCED_UPDATER.set(this, FALSE); -dispatcher.reset(); +if (dispatcher != null) { +dispatcher.reset(); +} log.error("[{}][{}] Error disconnecting consumers from subscription", topicName, subName, exception); disconnectFuture.completeExceptionally(exception); -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar] branch branch-1.22 updated: Issue #1117: handle race in concurrent bundle split
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new dd5c425 Issue #1117: handle race in concurrent bundle split dd5c425 is described below commit dd5c425f9b9df0de4852a49a9d8f731020271320 Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed May 2 01:27:05 2018 -0700 Issue #1117: handle race in concurrent bundle split --- .../broker/cache/LocalZooKeeperCacheService.java | 21 ++- .../pulsar/broker/namespace/NamespaceService.java | 171 ++--- .../pulsar/broker/service/BrokerService.java | 13 +- .../common/naming/NamespaceBundleFactory.java | 32 ++-- .../pulsar/common/naming/NamespaceBundles.java | 18 ++- .../apache/pulsar/broker/admin/AdminApiTest.java | 115 ++ .../broker/namespace/NamespaceServiceTest.java | 10 +- .../pulsar/zookeeper/ZooKeeperDataCache.java | 8 + 8 files changed, 306 insertions(+), 82 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/cache/LocalZooKeeperCacheService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/cache/LocalZooKeeperCacheService.java index 66a1ffa..4b28cad 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/cache/LocalZooKeeperCacheService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/cache/LocalZooKeeperCacheService.java @@ -22,6 +22,8 @@ import static com.google.common.base.Preconditions.checkNotNull; import static org.apache.pulsar.broker.cache.ConfigurationCacheService.POLICIES_ROOT; import static org.apache.pulsar.broker.web.PulsarWebResource.joinPath; +import com.google.common.collect.Maps; +import java.util.Map.Entry; import java.util.Optional; import java.util.concurrent.CompletableFuture; @@ -38,6 +40,7 @@ import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.ZooDefs.Ids; import org.apache.zookeeper.ZooKeeper; +import org.apache.zookeeper.data.Stat; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -79,20 +82,28 @@ public class LocalZooKeeperCacheService { @Override public CompletableFuture<Optional> getAsync(String path) { -CompletableFuture<Optional> future = new CompletableFuture<>(); +return getWithStatAsync(path).thenApply(entry -> entry.map(e -> e.getKey())); +} + +@Override +public CompletableFuture<Optional<Entry<LocalPolicies, Stat>>> getWithStatAsync(String path) { +CompletableFuture<Optional<Entry<LocalPolicies, Stat>>> future = new CompletableFuture<>(); // First check in local-zk cache -super.getAsync(path).thenAccept(localPolicies -> { +super.getWithStatAsync(path).thenAccept(result -> { +Optional localPolicies = result.map(Entry::getKey); if (localPolicies.isPresent()) { -future.complete(localPolicies); +future.complete(result); } else { // create new policies node under Local ZK by coping it from Global ZK createPolicies(path, true).thenAccept(p -> { LOG.info("Successfully created local policies for {} -- {}", path, p); // local-policies have been created but it's not part of policiesCache. so, call // super.getAsync() which will load it and set the watch on local-policies path -super.getAsync(path); -future.complete(p); +super.getWithStatAsync(path); +Stat stat = new Stat(); +stat.setVersion(-1); + future.complete(Optional.of(Maps.immutableEntry(p.orElse(null), stat))); }).exceptionally(ex -> { future.completeExceptionally(ex); return null; diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java index e7b885a..b8e4ae0 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java @@ -22,7 +22,6 @@ import static com.google.common.base.Preconditions.checkArgument; import static com.google.common.base.Preconditions.checkNotNull; import static
[incubator-pulsar] branch branch-1.22 updated: Fixed Lookup redirect logic on Proxy side
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new 335bc33 Fixed Lookup redirect logic on Proxy side 335bc33 is described below commit 335bc33a593378da21a5d7627688910a59d09f2c Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed May 2 01:27:33 2018 -0700 Fixed Lookup redirect logic on Proxy side --- .../main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java| 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java index 7d4d683..148a7a4 100644 --- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java +++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java @@ -125,7 +125,7 @@ public class LookupProxyHandler { requestId).thenAccept(result -> { if (result.redirect) { // Need to try the lookup again on a different broker -performLookup(clientRequestId, topic, result.brokerUrl, authoritative, numberOfRetries - 1); +performLookup(clientRequestId, topic, result.brokerUrl, result.authoritative, numberOfRetries - 1); } else { // We have the result immediately String brokerUrl = connectWithTLS ? result.brokerUrlTls : result.brokerUrl; -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar] branch master updated: Fixed InvocationTargetException in pulsar-admin (#1492)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/master by this push: new 1edf4d9 Fixed InvocationTargetException in pulsar-admin (#1492) 1edf4d9 is described below commit 1edf4d9d31d4c935ccd49015727fe66956434e8a Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed Apr 4 15:08:44 2018 -0700 Fixed InvocationTargetException in pulsar-admin (#1492) --- .../apache/pulsar/client/admin/PulsarAdmin.java| 27 +++--- .../apache/pulsar/admin/cli/CmdFunctionsTest.java | 2 +- .../org/apache/pulsar/admin/cli/CmdFunctions.java | 11 ++--- .../client/admin/PulsarAdminWithFunctions.java | 16 ++--- 4 files changed, 30 insertions(+), 26 deletions(-) diff --git a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java index 5a56830..7bb23b9 100644 --- a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java +++ b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java @@ -29,6 +29,7 @@ import javax.ws.rs.client.Client; import javax.ws.rs.client.ClientBuilder; import javax.ws.rs.client.WebTarget; +import org.apache.commons.lang3.StringUtils; import org.apache.pulsar.client.admin.internal.BrokerStatsImpl; import org.apache.pulsar.client.admin.internal.BrokersImpl; import org.apache.pulsar.client.admin.internal.ClustersImpl; @@ -71,7 +72,7 @@ public class PulsarAdmin implements Closeable { private final PersistentTopics persistentTopics; private final NonPersistentTopics nonPersistentTopics; private final ResourceQuotas resourceQuotas; - +private final ClientConfigurationData clientConfigData; private final Client client; private final String serviceUrl; private final Lookup lookups; @@ -103,8 +104,9 @@ public class PulsarAdmin implements Closeable { return new PulsarAdminBuilderImpl(); } -public PulsarAdmin(String serviceUrl, ClientConfigurationData pulsarConfig) throws PulsarClientException { -this.auth = pulsarConfig != null ? pulsarConfig.getAuthentication() : new AuthenticationDisabled(); +public PulsarAdmin(String serviceUrl, ClientConfigurationData clientConfigData) throws PulsarClientException { +this.clientConfigData = clientConfigData; +this.auth = clientConfigData != null ? clientConfigData.getAuthentication() : new AuthenticationDisabled(); LOG.debug("created: serviceUrl={}, authMethodName={}", serviceUrl, auth != null ? auth.getAuthMethodName() : null); @@ -120,22 +122,24 @@ public class PulsarAdmin implements Closeable { ClientBuilder clientBuilder = ClientBuilder.newBuilder().withConfig(httpConfig) .register(JacksonConfigurator.class).register(JacksonFeature.class); -boolean useTls = pulsarConfig.getServiceUrl().startsWith("https://;); +boolean useTls = false; -if (pulsarConfig != null && useTls) { +if (clientConfigData != null && StringUtils.isNotBlank(clientConfigData.getServiceUrl()) +&& clientConfigData.getServiceUrl().startsWith("https://;)) { +useTls = true; try { SSLContext sslCtx = null; X509Certificate trustCertificates[] = SecurityUtility - .loadCertificatesFromPemFile(pulsarConfig.getTlsTrustCertsFilePath()); + .loadCertificatesFromPemFile(clientConfigData.getTlsTrustCertsFilePath()); // Set private key and certificate if available AuthenticationDataProvider authData = auth.getAuthData(); if (authData.hasDataForTls()) { -sslCtx = SecurityUtility.createSslContext(pulsarConfig.isTlsAllowInsecureConnection(), +sslCtx = SecurityUtility.createSslContext(clientConfigData.isTlsAllowInsecureConnection(), trustCertificates, authData.getTlsCertificates(), authData.getTlsPrivateKey()); } else { -sslCtx = SecurityUtility.createSslContext(pulsarConfig.isTlsAllowInsecureConnection(), +sslCtx = SecurityUtility.createSslContext(clientConfigData.isTlsAllowInsecureConnection(), trustCertificates); } @@ -314,6 +318,13 @@ public class PulsarAdmin implements Closeable { } /** + * @return the client Configuration Data that is being used + */ +public ClientConfigurationData getClientConfigData() { +return clientConfigData; +} + +/** * Close the Pulsar admin client to release all the resources *
[incubator-pulsar] branch master updated: Added Throttling mechanism to Pulsar Proxy (#1453)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/master by this push: new 56e0109 Added Throttling mechanism to Pulsar Proxy (#1453) 56e0109 is described below commit 56e0109657e3b53690d9c91bfe7a231474a36895 Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Thu Mar 29 10:37:05 2018 -0700 Added Throttling mechanism to Pulsar Proxy (#1453) --- conf/proxy.conf| 7 ++ .../pulsar/proxy/server/DirectProxyHandler.java| 2 - .../pulsar/proxy/server/LookupProxyHandler.java| 125 - .../pulsar/proxy/server/ProxyConfiguration.java| 24 +++- .../pulsar/proxy/server/ProxyConnection.java | 28 - .../apache/pulsar/proxy/server/ProxyService.java | 13 ++- .../server/ProxyConnectionThrottlingTest.java | 87 ++ .../proxy/server/ProxyLookupThrottlingTest.java| 91 +++ 8 files changed, 313 insertions(+), 64 deletions(-) diff --git a/conf/proxy.conf b/conf/proxy.conf index 5d0647d..f731240 100644 --- a/conf/proxy.conf +++ b/conf/proxy.conf @@ -69,6 +69,13 @@ superUserRoles= # make sure authentication is enabled for this to take effect forwardAuthorizationCredentials=false +# --- RateLimiting +# Max concurrent inbound Connections, proxy will reject requests beyond that. Default value is 10,000 +maxConcurrentInboundConnections=1 + +# Max concurrent outbound Connections, proxy will error out requests beyond that. Default value is 10,000 +maxConcurrentLookupRequests=1 + # --- TLS --- # # Enable TLS in the proxy diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java index 92ff107..8b224f6 100644 --- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java +++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java @@ -58,7 +58,6 @@ public class DirectProxyHandler { private String originalPrincipal; private String clientAuthData; private String clientAuthMethod; -private boolean forwardAuthData; public static final String TLS_HANDLER = "tls"; private final Authentication authentication; @@ -70,7 +69,6 @@ public class DirectProxyHandler { this.clientAuthData = proxyConnection.clientAuthData; this.clientAuthMethod = proxyConnection.clientAuthMethod; ProxyConfiguration config = service.getConfiguration(); -this.forwardAuthData = service.getConfiguration().forwardAuthorizationCredentials(); // Start the connection attempt. Bootstrap b = new Bootstrap(); diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java index 6da5a89..aad42df 100644 --- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java +++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java @@ -65,28 +65,37 @@ public class LookupProxyHandler { if (log.isDebugEnabled()) { log.debug("Received Lookup from {}", clientAddress); } - -lookupRequests.inc(); long clientRequestId = lookup.getRequestId(); -String topic = lookup.getTopic(); -String serviceUrl; -if (isBlank(brokerServiceURL)) { -ServiceLookupData availableBroker = null; -try { -availableBroker = service.getDiscoveryProvider().nextBroker(); -} catch (Exception e) { -log.warn("[{}] Failed to get next active broker {}", clientAddress, e.getMessage(), e); -proxyConnection.ctx().writeAndFlush( - Commands.newLookupErrorResponse(ServerError.ServiceNotReady, e.getMessage(), clientRequestId)); -return; +if (this.service.getLookupRequestSemaphore().tryAcquire()) { +lookupRequests.inc(); +String topic = lookup.getTopic(); +String serviceUrl; +if (isBlank(brokerServiceURL)) { +ServiceLookupData availableBroker = null; +try { +availableBroker = service.getDiscoveryProvider().nextBroker(); +} catch (Exception e) { +log.warn("[{}] Failed to get next active broker {}", clientAddress, e.getMessage(), e); + proxyConnection.ctx().writeAndFlush(Commands.newLookupErrorResponse(ServerError.ServiceNotReady, +e.getMessage(), clientRequestId)); +return; +} +
svn commit: r25403 - /release/incubator/pulsar/pulsar-1.21.0-incubating/
Author: jai1 Date: Mon Mar 5 06:19:58 2018 New Revision: 25403 Log: Removing previous release pulsar-1.21.0-incubating. Removed: release/incubator/pulsar/pulsar-1.21.0-incubating/
svn commit: r25402 - /dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-3/ /release/incubator/pulsar/pulsar-1.22.0-incubating/
Author: jai1 Date: Mon Mar 5 06:18:48 2018 New Revision: 25402 Log: Promoting pulsar-1.22.0-incubating-candidate-3 to release. Added: release/incubator/pulsar/pulsar-1.22.0-incubating/ - copied from r25401, dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-3/ Removed: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-3/
[incubator-pulsar] annotated tag v1.22.0-incubating updated (5d14788 -> 94908a9)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a change to annotated tag v1.22.0-incubating in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git. *** WARNING: tag v1.22.0-incubating was modified! *** from 5d14788 (commit) to 94908a9 (tag) tagging 5d14788e510faec23fd8ed189ed343e93b489dda (commit) replaces v1.22.0-incubating-candidate-2 by jai1 on Sun Mar 4 22:14:47 2018 -0800 - Log - Release v1.22.0-incubating -BEGIN PGP SIGNATURE- iQJEBAABCAAuFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlqc4FcQHGphaTFAYXBh Y2hlLm9yZwAKCRB7oaZMu8EU7L3qD/9wqa0/BzINj0iTYAcv0ZaLh4bi0l/Q6lO8 kcbhA/TsMV6UvQXsiA+RPwi4MYPS+gZMa3Qna4fT5Wkse3N6tEqkFyJ96VoLuQql mpvi1Ar/EMXEFMDCelyubawz8P7AU1gXex1/DInlyJ3uLnahs4Z1C50WDeuQ9Iki e0X9voTuIWDBSzgJztInr033WvX3gw8vywcH6G0G7KDYc5U6dy9MkwJJm7SLrfsU 98gRJmCIfNCJA5GG937gTzEDRr3TyFgDpl301ZZAMqGTybp/Pp1iA1OBdXekXCw+ aRRpkSeUuiV5tNiCmOf6KTGrhvgshodwelStc15o1RfeOjeFTlfim+pWwj71QAn/ JpKlAe9+ZEmzpj8Mcl3CIcltVfTbcpqSpOG8ZtFkufRk8ombJDTB2qvcfkUOylLl K7HtaF0VtOF6fml8+0KVQraZUISe0RKKN1aH/64PojMXdGqBIXvmezvd1aJpFHZ1 s7xBTj7Z0dxBEKWRWXe+iG3qtLiqnZqKXm3JD0+PNh8R5rjTZJMyk/jrxf9+ylj0 6YNEb+rrr2NxTDDqCmKj7Fvtx0JEPIes3pg6s//H2bixGWrDrmZ4jXCwBMkO3Hs2 DXrIipb2CGn6wsedlp6PqFkSGo1/XTpldKuUoWf9R+/5FnooB1aoGtMMnG0mkchy PyVGFQxaSg== =gE22 -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes: -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar] branch branch-1.22 updated: Fix in ServerCnx to prevent using recycled commands (#1264)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new 5d14788 Fix in ServerCnx to prevent using recycled commands (#1264) 5d14788 is described below commit 5d14788e510faec23fd8ed189ed343e93b489dda Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Tue Feb 20 20:04:20 2018 -0800 Fix in ServerCnx to prevent using recycled commands (#1264) --- .../org/apache/pulsar/broker/service/ServerCnx.java | 20 ++-- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java index bdcc6e3..85cedde 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java @@ -209,7 +209,7 @@ public class ServerCnx extends PulsarHandler { @Override protected void handleLookup(CommandLookupTopic lookup) { final long requestId = lookup.getRequestId(); - +final boolean authoritative = lookup.getAuthoritative(); if (log.isDebugEnabled()) { log.debug("[{}] Received Lookup from {} for {}", lookup.getTopic(), remoteAddress, requestId); } @@ -254,9 +254,9 @@ public class ServerCnx extends PulsarHandler { String finalOriginalPrincipal = originalPrincipal; isProxyAuthorizedFuture.thenApply(isProxyAuthorized -> { if (isProxyAuthorized) { -lookupDestinationAsync(getBrokerService().pulsar(), topicName, lookup.getAuthoritative(), +lookupDestinationAsync(getBrokerService().pulsar(), topicName, authoritative, finalOriginalPrincipal != null ? finalOriginalPrincipal : authRole, authenticationData, -lookup.getRequestId()).handle((lookupResponse, ex) -> { +requestId).handle((lookupResponse, ex) -> { if (ex == null) { ctx.writeAndFlush(lookupResponse); } else { @@ -550,7 +550,7 @@ public class ServerCnx extends PulsarHandler { subscribe.getStartMessageId().getLedgerId(), subscribe.getStartMessageId().getEntryId(), subscribe.getStartMessageId().getPartition(), subscribe.getStartMessageId().getBatchIndex()) : null; - +final String subscription = subscribe.getSubscription(); final int priorityLevel = subscribe.hasPriorityLevel() ? subscribe.getPriorityLevel() : 0; final boolean readCompacted = subscribe.getReadCompacted(); final Map<String, String> metadata = CommandUtils.metadataFromCommand(subscribe); @@ -568,7 +568,7 @@ public class ServerCnx extends PulsarHandler { if (service.isAuthorizationEnabled()) { authorizationFuture = service.getAuthorizationService().canConsumeAsync(topicName, originalPrincipal != null ? originalPrincipal : authRole, authenticationData, -subscribe.getSubscription()); +subscription); } else { authorizationFuture = CompletableFuture.completedFuture(true); } @@ -995,13 +995,13 @@ public class ServerCnx extends PulsarHandler { @Override protected void handleSeek(CommandSeek seek) { checkArgument(state == State.Connected); - +final long requestId = seek.getRequestId(); CompletableFuture consumerFuture = consumers.get(seek.getConsumerId()); // Currently only seeking on a message id is supported if (!seek.hasMessageId()) { ctx.writeAndFlush( -Commands.newError(seek.getRequestId(), ServerError.MetadataError, "Message id was not present")); +Commands.newError(requestId, ServerError.MetadataError, "Message id was not present")); return; } @@ -1011,7 +1011,7 @@ public class ServerCnx extends PulsarHandler { MessageIdData msgIdData = seek.getMessageId(); Position position = new PositionImpl(msgIdData.getLedgerId(), msgIdData.getEntryId()); -long requestId = seek.getRequestId(); + subscription.resetCursor(position).thenRun(() -> { log.info("[{}] [{}][{}] Reset subscription to message id {}", remoteAddress, @@ -1019,12 +1019,12 @@ public class ServerCnx extends PulsarHandler { ctx.writeAndFlush(Commands.newSuccess(requestId)); }).exception
svn commit: r25170 - /dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/
Author: jai1 Date: Tue Feb 20 20:35:44 2018 New Revision: 25170 Log: Staging artifacts and signature for Pulsar release 1.22.0-incubating Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz (with props) dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-src.tar.gz (with props) dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-src.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-src.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-src.tar.gz.sha512 Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz == Binary file - no diff available. Propchange: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz -- svn:mime-type = application/octet-stream Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc Tue Feb 20 20:35:44 2018 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlqMhoAACgkQe6GmTLvB +FOyt1hAAwY9L4rDVUs5roDN1yAbx+HgIwl/i4YFMfdz1+grnhVEYezYH1UKBncxh +L9T1eycwRRwFHpkZ5vWxLEQy2UhXCqi5Qumz0hzLi3te53yapSWqPcptVtQAYxy4 +TQXoGyTj5ZkNblEEkv/Rx4+/zqnTYvuXUcLSK3HTOCop7EJydOoTY688Qjj4zxDB +Kw6U2RrRzFyxpCruf0S86LZhFfieR3XXPAgbX3FlX6ZOdMJRjhNed3xq/bToX5Hg +1RmWLJJCuyjBHupMBp/I39OFYjbm5y/R32BMO18xV2hz3FDwMOwT0Ld4NpiWrKv+ +yt2aAMcikU/ry/WlyZ0Wetni0f1crfIDYZhr0lamvWcDbAXY+38xjFMwTGALI5tA +DKAEXlIki2ujtHYclAwcr6YldE9LQinZ64+CfI4JJ8i0H09IoUi/arDlLVn5ZT0m +IVIj65+8VFlKeZqTJwV+QYWMcb3HCu7KHZgMz+h4vDgoNJfTYOVEsbaMFNE+zGpF +nfESWehfXWuUY9SuZP2wanjTCwTMlBV2VlaXzRshdXqJYB8ybdLLI2NqOJi4cnwT +1jU9aiC5ERRm6qbjQaxct5eV17qR01Yeqzo0fWwZVYL3lhIjBmMWGAtWHVUfI3sz +ddWFRKN3/nQPlskIpcgzTPFQ5M156KTz469isJSIkpkr6mWpoUE= +=V/uu +-END PGP SIGNATURE- Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 Tue Feb 20 20:35:44 2018 @@ -0,0 +1,2 @@ +apache-pulsar-1.22.0-incubating-bin.tar.gz: +97 AA FD DB 46 2A 84 34 84 D8 B0 70 28 50 55 70 Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 Tue Feb 20 20:35:44 2018 @@ -0,0 +1,3 @@ +apache-pulsar-1.22.0-incubating-bin.tar.gz: +F8AB02AC DD53FAAB 656529E8 89692F43 FBFBAD73 0C20C166 9685DFE4 D2811989 DAE06F07 + 7532EB14 7C3BF16F 9444BE45 03030C40 5D0E285E 6DD76211 FDD9CCFB Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-src.tar.gz == Binary file - no diff available. Propchange: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-src.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating-src.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-2/apache-pulsar-1.22.0-incubating
svn commit: r25112 - /dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/
Author: jai1 Date: Sat Feb 17 08:49:58 2018 New Revision: 25112 Log: Staging artifacts and signature for Pulsar release 1.22.0-incubating Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz (with props) dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-src.tar.gz (with props) dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-src.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-src.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-src.tar.gz.sha512 Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz == Binary file - no diff available. Propchange: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz -- svn:mime-type = application/octet-stream Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc Sat Feb 17 08:49:58 2018 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlqH7EUACgkQe6GmTLvB +FOzEiBAA0HxoTR1GoD/gSsYOwYqKxegMX/SkgKn2A3HdalnY/lyJMN/XRz3ZT/LF +oCCea2snl1qQuakNVp/uoIGB2d4eAUi4++iEiVSQZZl5rlCTyQJrn6Dda7PebS0u +G86VdZVbKs6uXpcFNY/t/5aS5gYQzOl2pMc2TkSQxgma/6s1Gcq/F7viRxz2Tqcj +Z1MDTvYDuyN4VpXTj885QWkYAGo62+wkigqcjo9/IldRZMS5reMkSAs9LwqwW6WK +zzSqIUWgYNqU0i9tK2TIo4VzNci5+2JWeLsd1WKiSvVEInTyBELMI0PNXs1ggwP2 +CKFMBe9RwCLb01WL5TUeZMf6v9Pjx8pkVfuNpUarcl/Bcq90QMI4LQpvzP9t9ypR +7LHnIalqfMgkIpr+fS2q2h9l7tGTnvTiu5zVgR6GZi+emDhR6coyesfEGEXzgbtJ +tW8btoiCWi3jDHLpgQY1lSSVwmeeLWxh0rEhj+cJnh5VBgRveGtWZwQctCFeMnfO +gdaHBDS2j542sGxedOsQkXGZAmpfaKS9oDg2K/d+SCVJhgM0ZW+jnBeiiRoc7f0V +w16Fqy3q0RjwzpdL9yfQ12pnjGEvQ0a02zGOpxzuP/ZTZhQYRrDnJBSTZ1Bz3EIc +e9GmhHX8k816Idof6p7KTGCHkLMcnogYXrB7bpqjpHKP/LUw3os= +=oyiU +-END PGP SIGNATURE- Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 Sat Feb 17 08:49:58 2018 @@ -0,0 +1,2 @@ +apache-pulsar-1.22.0-incubating-bin.tar.gz: +4B 19 6F A1 E7 73 87 A6 E0 BF 84 53 E0 49 08 AD Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 Sat Feb 17 08:49:58 2018 @@ -0,0 +1,3 @@ +apache-pulsar-1.22.0-incubating-bin.tar.gz: +91453ECF C864A6DB 209224FE 8DF49220 59CD876E 1A9355F6 09C92086 AAE0E3F1 C9E861A5 + CE435963 9B2A81FB 6FCAF6AB 08279E40 564F6ECA 61F5C645 5673EA9E Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-src.tar.gz == Binary file - no diff available. Propchange: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-src.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating-src.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-1/apache-pulsar-1.22.0-incubating
[incubator-pulsar] branch branch-1.22 updated: Created new certs which will expire after ten years (#1244)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new c7c8a40 Created new certs which will expire after ten years (#1244) c7c8a40 is described below commit c7c8a408e377e979350453e06c68340bc66c512c Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Fri Feb 16 22:08:38 2018 -0800 Created new certs which will expire after ten years (#1244) --- .../resources/authentication/tls/broker-cert.pem | 101 +++-- .../resources/authentication/tls/broker-key.pem| 52 +-- .../test/resources/authentication/tls/cacert.pem | 84 - .../resources/authentication/tls/client-cert.pem | 101 +++-- .../resources/authentication/tls/client-key.pem| 52 +-- .../test/resources/authentication/tls/cacert.pem | 84 - .../resources/authentication/tls/client-cert.pem | 101 +++-- .../resources/authentication/tls/client-key.pem| 52 +-- .../resources/authentication/tls/server-cert.pem | 101 +++-- .../resources/authentication/tls/server-key.pem| 52 +-- 10 files changed, 392 insertions(+), 388 deletions(-) diff --git a/pulsar-broker/src/test/resources/authentication/tls/broker-cert.pem b/pulsar-broker/src/test/resources/authentication/tls/broker-cert.pem index 7ace4df..69ad71c 100644 --- a/pulsar-broker/src/test/resources/authentication/tls/broker-cert.pem +++ b/pulsar-broker/src/test/resources/authentication/tls/broker-cert.pem @@ -2,35 +2,35 @@ Certificate: Data: Version: 3 (0x2) Serial Number: -b7:07:a3:fe:2a:7e:03:c9 +88:08:98:b3:13:d8:00:97 Signature Algorithm: sha1WithRSAEncryption -Issuer: C=AU, ST=Some-State, O=Internet Widgits Pty Ltd, CN=testCA +Issuer: C=US, ST=CA, O=Apache, OU=Pulsar Incubator, CN=localhost Validity -Not Before: Feb 16 23:18:35 2017 GMT -Not After : Feb 16 23:18:35 2018 GMT -Subject: C=AU, ST=Some-State, O=Internet Widgits Pty Ltd, CN=localhost +Not Before: Feb 17 02:06:21 2018 GMT +Not After : Nov 16 00:00:00 2030 GMT +Subject: C=US, ST=CA, O=Apache, OU=Apache Pulsar, CN=localhost Subject Public Key Info: Public Key Algorithm: rsaEncryption RSA Public Key: (2048 bit) Modulus (2048 bit): -00:c5:aa:20:d8:d7:37:d7:e5:dd:c2:03:8d:75:fa: -1e:53:7f:c5:3e:9f:12:4b:04:e3:56:97:00:2b:22: -cd:8d:5a:da:23:b4:ef:3a:c9:bf:a1:9c:ac:f4:ab: -ed:53:25:bc:1e:5b:54:ae:e8:f4:be:31:e2:94:64: -61:7e:a1:16:56:26:2a:81:eb:47:b3:89:ea:c4:1d: -20:46:68:75:55:68:c4:63:7d:e8:ee:4f:96:91:71: -2f:9d:4c:39:05:2c:25:b3:b0:d7:ec:18:f6:c4:86: -a3:b0:41:ad:a4:cd:8c:b4:ca:1d:f1:46:e3:84:a5: -f8:09:15:8e:9b:ae:38:44:9d:92:a2:1a:74:6a:11: -e0:37:cb:fb:75:d8:90:6a:d0:c3:fc:e5:92:da:90: -50:01:9f:ce:3b:d2:01:e4:8a:3f:e7:2c:53:51:8f: -e9:32:56:bb:7e:5e:4f:c6:9c:ac:05:9d:41:ac:88: -61:98:df:12:fe:f2:5e:0f:32:5f:10:bc:da:5e:86: -45:1b:11:60:fc:c9:5d:7b:e2:b3:11:27:03:7d:72: -b0:72:75:9e:23:15:f7:af:86:60:7b:dd:7e:3d:cc: -72:55:02:74:9b:de:c5:87:9d:82:be:3f:3b:84:cd: -ba:78:15:c2:d1:d0:d3:a0:af:89:aa:c1:cc:4d:82: -f8:d3 +00:af:bf:b7:2d:98:ad:9d:f6:da:a3:13:d4:62:0f: +98:be:1c:a2:89:22:ba:6f:d5:fd:1f:67:e3:91:03: +98:80:81:0e:ed:d8:f6:70:7f:2c:36:68:3d:53:ea: +58:3a:a6:d5:89:66:4b:bd:1e:57:71:13:6d:4b:11: +e5:40:a5:76:84:24:92:40:58:80:96:c9:1f:2c:c4: +55:eb:a3:79:73:70:5c:37:9a:89:ed:2f:ba:6b:e3: +82:7c:69:4a:02:54:8b:81:5e:3c:bf:4c:8a:cb:ea: +2c:5e:83:e7:b7:10:08:5f:82:58:a3:89:d1:da:92: +ba:2a:28:ee:30:28:3f:5b:ae:10:71:96:c7:e1:12: +c5:b0:1a:ad:44:6f:44:3a:11:4a:9a:3c:0f:8d:06: +80:7b:34:ef:3f:6c:f4:5e:c5:44:54:1e:c8:dd:c7: +80:85:80:d9:68:e6:c6:53:03:77:e1:fe:18:61:07: +77:05:4c:ed:59:bc:5d:41:38:6a:ef:5d:a1:b2:60: +98:d4:48:28:95:02:8a:0e:fd:cf:7b:1b:d2:11:cc: +10:0c:50:73:d7:cc:38:6c:83:dd:79:26:aa:90:c8: +9b:84:86:bc:59:e9:62:69:f4:98:1b:c4:80:78:7e: +a0:1a:81:9d:d2:e1:66:dd:c4:cc:fc:63:04:ac:ec: +a7:35 Exponent: 65537 (0x10001)
[incubator-pulsar] annotated tag v1.22.0-incubating-candidate-0 updated (96d720c -> 15347f1)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a change to annotated tag v1.22.0-incubating-candidate-0 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git. *** WARNING: tag v1.22.0-incubating-candidate-0 was modified! *** from 96d720c (commit) to 15347f1 (tag) tagging 96d720c928b21485df8e055dde379aeeb7f81624 (commit) by jai1 on Thu Feb 15 21:00:51 2018 -0800 - Log - Release v1.22.0-incubating-candidate-0 -BEGIN PGP SIGNATURE- iQJEBAABCAAuFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlqGZYQQHGphaTFAYXBh Y2hlLm9yZwAKCRB7oaZMu8EU7M1VD/wMV6jAf0bo4mYHC3bBjTgWhQWv3vPyUx10 iL/5JVNfwgScVUUH8KvxAWazWt73h1UVndaaooBHvqqR9xgrDTowWK/4ZBscp3LD uXeOCxE9Kk3F8slDDKqWtTdYALAopQ9SB3QrwRqoxTnwduRLlXm9utr4Y6QNduAb imkPhbVo1pMTFCoDahYh3Ruqfj8XtjWQa8ey0+dp4X/gGwGkU/ZXk+tQsQdXuzOr FRCICQdsZDJWmuTz1gFdfMvSJ4NEkIt7sDMnj4Igen8PwmJ3gJHbDJle86dDHBSB J1nmWRrhRGH2XoWRN/jn7v2G4HGTanAybOFiX9Fn9tmSN/ywJvjlbViuq2zjMmNt YbTkDe6GjAGMuKOWaasmyZoDMxAnNIMyPzuC2ADmKm3Cc2AOry3OO6/2NttYoN5F 4W/7EFtzS3UlN6pLYTHB6QknloZC6YclPxR4fsMuwt0NCxRmGMeqj2rrthnKaU8j RRCFh0nhBNu2UahYO0brTsV5B7RSfbA7pZW8ufpI5QG9upyE0QwDAD6XGrxDBRBi vdlcKUQasB7herUgF0QyNkdewQhdor6Sc/77aHWiqIw8lo/6Fi66N+xqLX9OSDsh d12G1B2LvOf2id76+Io2pFpe+vTCHyWR5cIahZRl/LAjAVkewB0vKOnfK7xP2siY eo3E02cOvA== =kv+n -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes: -- To stop receiving notification emails like this one, please contact j...@apache.org.
svn commit: r25081 - /dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/
Author: jai1 Date: Thu Feb 15 02:06:00 2018 New Revision: 25081 Log: Staging artifacts and signature for Pulsar release 1.22.0-incubating Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz (with props) dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 Modified: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.asc Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz == Binary file - no diff available. Propchange: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz -- svn:mime-type = application/octet-stream Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.asc Thu Feb 15 02:06:00 2018 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlqE6tAACgkQe6GmTLvB +FOxOCg/+LOavQKTSrdrtpX6gUCVuXvnDABAAgE37tRNJfsLwmfC8G+ZaNyb6vSLf +nbCnAwNwi/Nj0X/4H9ht4mBxrJZ78Ii3UtBjT3lA4naMDZcyPmN/5ISY5RNscVln +wMi9nt8DdWKV3XR0XWHFx9tgrKOhPfkb9xdTturljj8/a3oW3yhOFpBaUve+KFkJ +CX3ibEAv9Cd5iIvrv0rPTUdPxsK2ht7JYewdLUxtHhAJmWkFKcdT8InLqrqb2tmE +IqT9i/SY2LGW+hyq28pdnjzwa5g6Qu6ilrN69LRBJ/5oSwvfS8+H3C9yPYDh2WVF +vsYclpy1BQftRPqR+LAyIZcmotywmR6CNkGRBEj+/M+CsFpc06E0ixPWlJDV9UEb +adSCnHmohwwD3TS8OmMNI/O7ipcLB5Mamor6Gi9SYjHA+pM0AG+sSRpzV67YxdIi ++x61YBeZ1OnmYhlj9b0tFSMCkQXwlnxoIC1liU8rG133V2+9wt6W4BN4TjB74rWW +50mECdvGDhjty9AF1HbuA54PA2/GwKV2eW0eAd7DYCq1U+CaP7yUrSagSknAnvXB +50tm6EaSt4Hx2S32xvUVg4pn86XAfO6ePOKywCExHQxqDzenTkvMeYssZbnPHxxe +FBYUa0EqSJmbkJ7cq+Hjzv8RNchEjmEWdL1qOquYZeN/qfXXazE= +=/xWX +-END PGP SIGNATURE- Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.md5 Thu Feb 15 02:06:00 2018 @@ -0,0 +1,2 @@ +apache-pulsar-1.22.0-incubating-bin.tar.gz: +98 41 A5 01 81 98 9F 4F 44 E7 0D 6B 1D 15 3E E2 Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-bin.tar.gz.sha512 Thu Feb 15 02:06:00 2018 @@ -0,0 +1,3 @@ +apache-pulsar-1.22.0-incubating-bin.tar.gz: +408DDB47 98355343 23626766 EB2FFD64 7E77105C F7F6FE92 AC42502C A2FBC632 6BCECD5C + 43177395 643A10E7 F080B159 ECB4A2A5 D2D01508 83EBED26 6CECDA9A Modified: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.asc (original) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.asc Thu Feb 15 02:06:00 2018 @@ -1,16 +1,16 @@ -BEGIN PGP SIGNATURE- -iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlqCtq8ACgkQe6GmTLvB -FOyEwhAAt0OFdejzQTJi7KA2Qv+mhazVuBEZfygwyRjNy7pNoX+CI0tIDCo6myDd -jfUjx3Fg6hFR3WGzLW0+n+meHxsWrcpiqoR6vV7PjH+CpxJXY6+ZrS3/0QuDdAT/ -/ZlSStC8S3AT6mSRJzjab9HGWIwsE+QZmuiLzjzkUTBDNZ4QAstbN57MY4DrDDe3 -HbSKoCDrPWp+eWmuimD2U1fhxMpPKaUonXLvH1jAhsLYNUt+yS7o0UOlFm+gbktK -h2t4T+t2QeHzefkh8+Tud1EV0wObTbel54qda3LKGwgGUwPCMs7UxZ/oeSJTd25E -oKAizymEcdcnpPHBYfq7pr/QhPW2bpO1OVjVKBk8mN3SjVO1366MawxrAfr1AKby -wQcy8kVN2YskM0VSYl+Ck5BRJl//NO59oGFIPtp7IXy0F/yqokwkVJC4I7YPM3ua -r5Ozixl8+NFDPE+8SVrmUASiHJLbjG7RBT3SyWuzEMV642uQY6FHp6NMlncBczkK -slkXz/U5i+E/GM+5Q+MZ7HmwzrCmicYgqiUI8pryYLLPxRjtpiZ9f074jiRtXxFO -5HRZFackUg0Zz2e0pBhv8FCfLvMc4NiCt8LvqmcPNnXEjMc6m4/Vz+6UheLRBRK+ -wnVxieyKxZYDxFe47xorGMwuGa7M9S4BIWxBuVQ6
[incubator-pulsar] branch branch-1.20-yahoo deleted (was d5175b9)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a change to branch branch-1.20-yahoo in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git. was d5175b9 Bumped to 1.20.8-incubating-yahoo-SNAPSHOT This change permanently discards the following revisions: discard d5175b9 Bumped to 1.20.8-incubating-yahoo-SNAPSHOT discard 870268e Cancel keep-alive timer task after the proxy switch to TCP proxy (#1210) discard 7c460ac Reset kafka dep (#17) discard 02ec84b Bumped to 1.20.7-incubating-yahoo discard 8ae92d3 CMS-2984: Enable specification of TLS Protocol Versions and Cipher Suites discard d8f6068 Use SecurityUtility class (#16) discard 136c241 Support hostname verification on proxy to broker connection (#1214) (#14) discard 1336b85 Add hostname-verification at client tls connection (#1208) (#13) discard a86e472 Pulsar proxy (#11) discard 5c35550 Bumped to 1.20.7-incubating-yahoo-SNAPSHOT discard fdd255a Release to 1.20.6-incubating-yahoo discard 1b2d720 Add timeout for bundle unloading (#990) discard c24f03a Bumped to 1.20.6-incubating-yahoo-SNAPSHOT discard ab4b30d Release to 1.20.5-incubating-yahoo discard 031d64a add NoSuchEntryException as not-recoverable error (#10) discard fc954a0 Bumped up 1.20.5-incubating-yahoo-SNAPSHOT discard 3cbdb76 Release pulsar to 1.20.4-incubating-yahoo discard 3773830 Make sure nextTuple emits tuple with non-null values #1000 discard 61c6d75 Fix: cursor-ledger leak by deleting cursor-ledger after recovering managed-cursor discard 8a1132a Bumped to 1.20.4-incubating-yahoo-SNAPSHOT discard 403a409 Release pulsar to 1.20.3-incubating-yahoo discard 9b0a98d shade data-sketch (#8) discard 58f Bumped to 1.20.3-incubating-yahoo-SNAPSHOT discard 0b15038 Release pulsar to 1.20.2-incubating-yahoo discard 5eba7c1 Avoid dead-lock on broker service when broker failed to load managed-ledger (#934) discard 90be3c7 Fix: failed producer creation leak (#927) discard 05e6a20 Bumped to 1.20.2-incubating-yahoo-SNAPSHOT discard 67e0b88 Release pulsar to 1.20.1-incubating-yahoo discard dda80f8 Log incompatible client version on partition-metadata access discard 65722cc Fail broker start if broker-znode created by other zk-session (#913) discard 05742e6 PIP-8: Introduce peer cluster for global namespace redirection (#903) discard 564d1cc Avoid logging stacktrace for exclusive consumer-busy exception (#906) discard b979691 Cleanup unsused ApiVersionFilter (#885) discard c9c0a4b Specify rsa transform, aes & tag length (#839) discard 054cc49 Use thread local to allocate temp byte[] instead of allocator (#882) discard 1482cd0 Fix: Non-persistent topic acking sequence for dropped message (#874) discard 624e2f4 Bumped to 1.20.1-incubating-yahoo-SNAPSHOT discard eaf5587 Release pulsar to 1.20.0-incubating-yahoo -- To stop receiving notification emails like this one, please contact j...@apache.org.
svn commit: r25025 - /dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/
Author: jai1 Date: Tue Feb 13 09:59:07 2018 New Revision: 25025 Log: Staging artifacts and signature for Pulsar release 1.22.0-incubating Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz (with props) dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.asc dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.md5 dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.sha512 Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz == Binary file - no diff available. Propchange: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.asc == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.asc (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.asc Tue Feb 13 09:59:07 2018 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCAAdFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlqCtq8ACgkQe6GmTLvB +FOyEwhAAt0OFdejzQTJi7KA2Qv+mhazVuBEZfygwyRjNy7pNoX+CI0tIDCo6myDd +jfUjx3Fg6hFR3WGzLW0+n+meHxsWrcpiqoR6vV7PjH+CpxJXY6+ZrS3/0QuDdAT/ +/ZlSStC8S3AT6mSRJzjab9HGWIwsE+QZmuiLzjzkUTBDNZ4QAstbN57MY4DrDDe3 +HbSKoCDrPWp+eWmuimD2U1fhxMpPKaUonXLvH1jAhsLYNUt+yS7o0UOlFm+gbktK +h2t4T+t2QeHzefkh8+Tud1EV0wObTbel54qda3LKGwgGUwPCMs7UxZ/oeSJTd25E +oKAizymEcdcnpPHBYfq7pr/QhPW2bpO1OVjVKBk8mN3SjVO1366MawxrAfr1AKby +wQcy8kVN2YskM0VSYl+Ck5BRJl//NO59oGFIPtp7IXy0F/yqokwkVJC4I7YPM3ua +r5Ozixl8+NFDPE+8SVrmUASiHJLbjG7RBT3SyWuzEMV642uQY6FHp6NMlncBczkK +slkXz/U5i+E/GM+5Q+MZ7HmwzrCmicYgqiUI8pryYLLPxRjtpiZ9f074jiRtXxFO +5HRZFackUg0Zz2e0pBhv8FCfLvMc4NiCt8LvqmcPNnXEjMc6m4/Vz+6UheLRBRK+ +wnVxieyKxZYDxFe47xorGMwuGa7M9S4BIWxBuVQ6/lVi2TIQXQw= +=KFvU +-END PGP SIGNATURE- Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.md5 == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.md5 (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.md5 Tue Feb 13 09:59:07 2018 @@ -0,0 +1,2 @@ +apache-pulsar-1.22.0-incubating-src.tar.gz: +29 F0 89 45 04 08 AD 06 6F 75 0C B7 91 6F F9 9F Added: dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.sha512 == --- dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.sha512 (added) +++ dev/incubator/pulsar/pulsar-1.22.0-incubating-candidate-0/apache-pulsar-1.22.0-incubating-src.tar.gz.sha512 Tue Feb 13 09:59:07 2018 @@ -0,0 +1,3 @@ +apache-pulsar-1.22.0-incubating-src.tar.gz: +52ED243F 8DE5BAFA BC430118 9629D216 577AC2AF 4B186317 A8BC513C 4D87FE38 82C7088F + ED1E9B1E D7CAD96D A5287730 15A55080 32BA182A D9A60619 C6813D48
[incubator-pulsar] branch master updated: Enable specification of TLS Protocol Versions and Cipher Suites (#1225)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/master by this push: new b990674 Enable specification of TLS Protocol Versions and Cipher Suites (#1225) b990674 is described below commit b99067479ebca5f955c936d396e72cd7eda09095 Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Mon Feb 12 20:57:58 2018 -0800 Enable specification of TLS Protocol Versions and Cipher Suites (#1225) --- .../apache/pulsar/broker/ServiceConfiguration.java | 24 +++- .../broker/service/PulsarChannelInitializer.java | 5 +- .../broker/auth/MockedPulsarServiceBaseTest.java | 4 +- .../org/apache/pulsar/client/impl/ClientCnx.java | 4 + .../apache/pulsar/common/util/SecurityUtility.java | 13 +- .../service/ServiceChannelInitializer.java | 3 +- .../discovery/service/server/ServiceConfig.java| 24 +++- .../pulsar/proxy/server/ProxyConfiguration.java| 24 +++- .../proxy/server/ServiceChannelInitializer.java| 2 +- .../server/ProxyWithProxyAuthorizationTest.java| 146 - 10 files changed, 234 insertions(+), 15 deletions(-) diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java index 74077f4..fcd9a92 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java @@ -180,7 +180,13 @@ public class ServiceConfiguration implements PulsarConfiguration { private String tlsTrustCertsFilePath = ""; // Accept untrusted TLS certificate from client private boolean tlsAllowInsecureConnection = false; - +// Specify the tls protocols the broker will use to negotiate during TLS Handshake. +// Example:- [TLSv1.2, TLSv1.1, TLSv1] +private Set tlsProtocols = Sets.newTreeSet(); +// Specify the tls cipher the broker will use to negotiate during TLS Handshake. +// Example:- [TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256] +private Set tlsCiphers = Sets.newTreeSet(); + /* --- Authentication --- / // Enable authentication private boolean authenticationEnabled = false; @@ -1400,4 +1406,20 @@ public class ServiceConfiguration implements PulsarConfiguration { public void setAuthenticateOriginalAuthData(boolean authenticateOriginalAuthData) { this.authenticateOriginalAuthData = authenticateOriginalAuthData; } + +public Set getTlsProtocols() { +return tlsProtocols; +} + +public void setTlsProtocols(Set tlsProtocols) { +this.tlsProtocols = tlsProtocols; +} + +public Set getTlsCiphers() { +return tlsCiphers; +} + +public void setTlsCiphers(Set tlsCiphers) { +this.tlsCiphers = tlsCiphers; +} } diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java index da10a2d..f77c6e6 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java @@ -50,7 +50,10 @@ public class PulsarChannelInitializer extends ChannelInitializer @Override protected void initChannel(SocketChannel ch) throws Exception { if (enableTLS) { -SslContext sslCtx = SecurityUtility.createNettySslContextForServer(serviceConfig.isTlsAllowInsecureConnection(), serviceConfig.getTlsTrustCertsFilePath(), serviceConfig.getTlsCertificateFilePath(), serviceConfig.getTlsKeyFilePath()); +SslContext sslCtx = SecurityUtility.createNettySslContextForServer( +serviceConfig.isTlsAllowInsecureConnection(), serviceConfig.getTlsTrustCertsFilePath(), +serviceConfig.getTlsCertificateFilePath(), serviceConfig.getTlsKeyFilePath(), +serviceConfig.getTlsCiphers(), serviceConfig.getTlsProtocols()); ch.pipeline().addLast(TLS_HANDLER, sslCtx.newHandler(ch.alloc())); } diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java index 75b91c1..51a4c03 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java @@ -253,13 +253,13 @@ public abstract class MockedPulsarServiceBaseTest { } }; -public static void retryStrategically(Predicate predicate, int
[incubator-pulsar] annotated tag v1.22.0-incubating-candidate-0 updated (9d99dd3 -> e5e3459)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a change to annotated tag v1.22.0-incubating-candidate-0 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git. *** WARNING: tag v1.22.0-incubating-candidate-0 was modified! *** from 9d99dd3 (commit) to e5e3459 (tag) tagging 9d99dd324e5b652e858be31d156d46d8f9afa132 (commit) by jai1 on Mon Feb 12 20:15:58 2018 -0800 - Log - Release v1.22.0-incubating-candidate-0 -BEGIN PGP SIGNATURE- iQJEBAABCAAuFiEEDQCP4t9TLRC/fG0se6GmTLvBFOwFAlqCZn4QHGphaTFAYXBh Y2hlLm9yZwAKCRB7oaZMu8EU7EUcD/4iTomDj/RMJVwdV26Pgs+7aG2ZrmMiPyux EPoK7g7VojExrNFUbHiXkQqWMSLNgQ3NnUKDmJQY1ApeB/O1IqqobMZDhy/DPAR5 0ehaM9uj3gQa7G8KRZjKRKxXLGXBTkzghZcofrXCXVtBHZki2J6bFTAu1mV5FniP 5as1ZHtnghIE0FCQm3OsFFDOZLD2ef783dzqQ/hbLF80ZRyebaHt9hLR3+35h1Wj XlCE00zzd4HmhUjhwAVr2EgKGXvdj6+PAcgZUtNYaT3FwJEyVaQf6Ue1LvKhpBIc hbqwszU9xThJ4+3zMKlX4GRHU9m2vO9XsdtCnPSXaG9qxqbFikPIgezxRXqzh/+f EOABKfXUs65M6Co8biyAMN6dZMOjVsSlJC1bgtusGSA6HibOaL78TpT9w5vxbxZx y4Z9Esk+JqUmj5/UHynX2x/Ye1VPBBF3CY9XeAlUfknCFTP8jGm5O2Q+03YIjygI u6tlk1YRZRI/iHg/wDpJlr3IqpL8on9OYebgwcEEqUaY9jxqsI32A6crnGf8YwuA WZofu/dzL4UyrO0XfqnFbF2xDfihl+Uw9T7TzS3CHjfD8q0OlkqJGTDTdSl4xh4S HDkwvZx8iBpprACon41JJ2RW+fvicQfKZG+V+41pDziI/3ETiIqSOBpJmmWPFEbQ l2e+6Oopsw== =/XVj -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes: -- To stop receiving notification emails like this one, please contact j...@apache.org.
[incubator-pulsar] branch branch-1.22 updated: Release 1.22.0-incubating
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch branch-1.22 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/branch-1.22 by this push: new 9d99dd3 Release 1.22.0-incubating 9d99dd3 is described below commit 9d99dd324e5b652e858be31d156d46d8f9afa132 Author: jai1 <j...@apache.org> AuthorDate: Mon Feb 12 20:14:04 2018 -0800 Release 1.22.0-incubating --- all/pom.xml | 2 +- buildtools/pom.xml | 2 +- managed-ledger/pom.xml | 2 +- pom.xml | 2 +- pulsar-broker-auth-athenz/pom.xml| 2 +- pulsar-broker-common/pom.xml | 2 +- pulsar-broker-shaded/pom.xml | 2 +- pulsar-broker/pom.xml| 2 +- pulsar-checksum/pom.xml | 2 +- pulsar-client-admin-shaded/pom.xml | 2 +- pulsar-client-admin/pom.xml | 2 +- pulsar-client-auth-athenz/pom.xml| 2 +- pulsar-client-kafka-compat/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml | 2 +- pulsar-client-shaded/pom.xml | 2 +- pulsar-client-tools/pom.xml | 2 +- pulsar-client/pom.xml| 2 +- pulsar-common/pom.xml| 2 +- pulsar-discovery-service/pom.xml | 2 +- pulsar-proxy/pom.xml | 2 +- pulsar-spark/pom.xml | 2 +- pulsar-storm/pom.xml | 2 +- pulsar-testclient/pom.xml| 2 +- pulsar-websocket/pom.xml | 2 +- pulsar-zookeeper-utils/pom.xml | 2 +- pulsar-zookeeper/pom.xml | 2 +- 27 files changed, 27 insertions(+), 27 deletions(-) diff --git a/all/pom.xml b/all/pom.xml index d7c2c98..4283f55 100644 --- a/all/pom.xml +++ b/all/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar -1.22.0-incubating-SNAPSHOT +1.22.0-incubating .. diff --git a/buildtools/pom.xml b/buildtools/pom.xml index fc75fe7..11a3bd9 100644 --- a/buildtools/pom.xml +++ b/buildtools/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar -1.22.0-incubating-SNAPSHOT +1.22.0-incubating .. diff --git a/managed-ledger/pom.xml b/managed-ledger/pom.xml index 34a0792..0cdff4a 100644 --- a/managed-ledger/pom.xml +++ b/managed-ledger/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar -1.22.0-incubating-SNAPSHOT +1.22.0-incubating .. diff --git a/pom.xml b/pom.xml index 7320661..b4e63d7 100644 --- a/pom.xml +++ b/pom.xml @@ -33,7 +33,7 @@ org.apache.pulsar pulsar - 1.22.0-incubating-SNAPSHOT + 1.22.0-incubating Pulsar Pulsar is a distributed pub-sub messaging platform with a very diff --git a/pulsar-broker-auth-athenz/pom.xml b/pulsar-broker-auth-athenz/pom.xml index 80c22be..0e5f6b1 100644 --- a/pulsar-broker-auth-athenz/pom.xml +++ b/pulsar-broker-auth-athenz/pom.xml @@ -26,7 +26,7 @@ org.apache.pulsar pulsar -1.22.0-incubating-SNAPSHOT +1.22.0-incubating pulsar-broker-auth-athenz diff --git a/pulsar-broker-common/pom.xml b/pulsar-broker-common/pom.xml index 7a1d356..b65323f 100644 --- a/pulsar-broker-common/pom.xml +++ b/pulsar-broker-common/pom.xml @@ -26,7 +26,7 @@ org.apache.pulsar pulsar -1.22.0-incubating-SNAPSHOT +1.22.0-incubating pulsar-broker-common diff --git a/pulsar-broker-shaded/pom.xml b/pulsar-broker-shaded/pom.xml index bda3037..5794983 100644 --- a/pulsar-broker-shaded/pom.xml +++ b/pulsar-broker-shaded/pom.xml @@ -26,7 +26,7 @@ org.apache.pulsar pulsar -1.22.0-incubating-SNAPSHOT +1.22.0-incubating .. diff --git a/pulsar-broker/pom.xml b/pulsar-broker/pom.xml index 9a703e0..f5c6528 100644 --- a/pulsar-broker/pom.xml +++ b/pulsar-broker/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar -1.22.0-incubating-SNAPSHOT +1.22.0-incubating .. diff --git a/pulsar-checksum/pom.xml b/pulsar-checksum/pom.xml index da4f778..ff0a63a 100644 --- a/pulsar-checksum/pom.xml +++ b/pulsar-checksum/pom.xml @@ -26,7 +26,7 @@ org.apache.pulsar pulsar -1.22.0-incubating-SNAPSHOT +1.22.0-incubating .. diff --git a/pulsar-client-admin-shaded/pom.
svn commit: r24991 - /release/incubator/pulsar/KEYS
Author: jai1 Date: Tue Feb 13 04:10:24 2018 New Revision: 24991 Log: Added gpg key for jai1 Modified: release/incubator/pulsar/KEYS Modified: release/incubator/pulsar/KEYS == --- release/incubator/pulsar/KEYS (original) +++ release/incubator/pulsar/KEYS Tue Feb 13 04:10:24 2018 @@ -379,62 +379,62 @@ Ef5D3zsz3YwR1SMS2ZsX4aHaXhbSRTKYY83x5n0/ 4R/eV1EOkAVSbS98fTm/LlrV =0XPv -END PGP PUBLIC KEY BLOCK- -pub rsa4096 2018-02-05 [SC] - E65D95481B789BB727A9795EAAFE89F7471BAE04 +pub rsa4096 2018-02-13 [SC] + 0D008FE2DF532D10BF7C6D2C7BA1A64CBBC114EC uid [ultimate] Jai Asher (CODE SIGNING KEY) <j...@apache.org> -sig 3AAFE89F7471BAE04 2018-02-05 Jai Asher (CODE SIGNING KEY) <j...@apache.org> -sub rsa4096 2018-02-05 [E] -sig AAFE89F7471BAE04 2018-02-05 Jai Asher (CODE SIGNING KEY) <j...@apache.org> +sig 37BA1A64CBBC114EC 2018-02-13 Jai Asher (CODE SIGNING KEY) <j...@apache.org> +sub rsa4096 2018-02-13 [E] +sig 7BA1A64CBBC114EC 2018-02-13 Jai Asher (CODE SIGNING KEY) <j...@apache.org> -BEGIN PGP PUBLIC KEY BLOCK- -mQINBFp3864BEADJ0p2M664orJ2Q40Ee0t5VQFTW0/FtyaEPBvmDqLQV6rcoZYgq -mhehMPgjGbMSQ3KTYhEqQovPbXh/zdsXIkfNKErt793/DekjVgGxL3j8sfzmYseo -eCIKYofGTHDL3dw5mQ7PzEmerNofNTh/NeooPIfreA0r7guvwlhCAGzlB5YJR7+F -Th+hz9kz+9URMH/Bd4/ZOhobIR1rPe/Ynost+pwT2H7aAIopZ3qH3rr+lbq6Iece -mfxurkvwqSxtd5uatz4ifeJmU60EJ71y43y3oFlYOl32Z1kJfYP3cj3aPYR3cmLT -0VmhoNNI97OogRj5FqYLBMP4aIcRW0YHqKgQ7GsWgTeQ+BxEG0TvWz1RcrVUtGMZ -MfySY9E05R1aolaQNMk2h4mS/R2sDF2efAvBCQx7gwY1v2ORsCcqSBS6S9sRLyO1 -e71mh9TlDJevM5a9RtjigJb6dsF+wYCQ0BdtI8A2xN/c0QhrkeSDt2/Qf9iBkpi3 -irswwc93VwRAWRszXpCk2HdDqJN4X22GRQaFELlZvN8pzPU05rGbfzO73ZtfmTRZ -o7C+hINOAq31+H6p9KnQ8RFh6CC4FAP/tP22JODp7jK7yBt1G4/53bdvFbbgYzf/ -vxhbbQtHrntoXT76DpvfFwdAJyBcIgCWvtrRco3DNqK2Zl6hUfKIJV4HIQARAQAB +mQINBFqCX9MBEADR+/hSQOjmFf/luet05/WSwo24T533ltj2RGRu21DbD9ZmT1zd +IQx1xN8D2BNFvZc+iB9yGASEdAnMZLWKAku4UcZSGaI4e08Pedv7eplEuqKWKe7Q +GgFWCcQ09ZABqboO6cw/+oQqNuiTkrlYIiuCl2DvjZ1SmRucjtNpGj1Mfh1mk3Yq +OJBFI1A9YBh9DsiXjPecjw8zQzdPCnu9nEa/V72N0c4/r0vYbTt3qz3YeaTSC8yd +mWV4ByEBVXWhKPmZnxJoCsqguOCgZvV9+4ANd7DYzFPNanJc43lf/ZCKyAPk7iS+ +ee/b3j3gsFAK5YocGE5QXbXXwHZOajHGjAZRc+3erxkfLDfOol83W9DIzL7IoLcC +TRrCe+Nvu4eP/SBWhn4LOhcLqmyIYdwLY5bQo5cepn2J2x3niME+Hz2fqRq6xB+P +xy9Zl3E2pFjoNW9tfYkjckNgPI4dIgZ8YNNwvHawdkdQHflfs45BlDIFqYGaxbwb ++AJQv1U4G6t1vzt3b8b51tfmRq8yAlHt+BwFVsfFf7HQ/M1Sn/35BdwqvXr+zuFE +WPQ06RLMjvR1EwKbTCJedqHT+e9wS7XYj/WE2Qkp1dUpGzvKSDf6NqGcKi9RBvuv +Vszdw7k2pbfLKOZ4QEn+HxbyLRGA2Eukt590+z4T21erDFWcWzAUy4P/6QARAQAB tC5KYWkgQXNoZXIgKENPREUgU0lHTklORyBLRVkpIDxqYWkxQGFwYWNoZS5vcmc+ -iQJOBBMBCAA4FiEE5l2VSBt4m7cnqXleqv6J90cbrgQFAlp3864CGwMFCwkIBwIG -FQoJCAsCBBYCAwECHgECF4AACgkQqv6J90cbrgQfcA//bjipD4MFRTozqK4kzoPW -7fqnlzkeGY4TAbYWAtQxij9FEg7Q2ypUsfeCM+eLPVZYY+QWYDM2ZiRbL2C3DHEE -cyyBa5U6pb/XAbMHkgoDtekjRGRQS9aZXxpzuUZ//yyhOk5HxIETAKfa/VRu0jxF -pcE+0TJM02ccVoEkfhbdIEilvhBA7zCUKzwiGPPV6eNKUqeF0ErU+kun4FoGtzIs -DJ1n+kGk3a5KKM9jcaRMUptlDTHPqyGhZUhJGqIDIHEjOzrqnD9tsUw1MeQzhX27 -ytghKb9Yu9vSDfayykwWeBg6c+Tkf7YWPpjNEZnH1YTXjgwQXTupBWgycClaAPPz -CsGEimtw0ppE0N1yrCIzD5yZh5M8b3MEOVkKe3mApZ7vxPEdqQwLBBALGMlq1FhR -ECP5tYAbldiARYEcHfjboN1Lfl6/ffj9KXt6MKLPuZ4LH2QIC6n/1RiPE94DLs7J -D3TvyOivJaJCRCaX5GLcwqYYgRJGvEp1LyXW3LeD/552g0njoKyoiYycdPLa2FWd -FJnRlghkG2hkhynlmzPUGtu+UVG6s76z1CUliZc4/Zkc6zqBt5wU82iSST6p9+yW -nYo3vVmVZPM5j/yeDxoJAcsWnA1OANUBCv2TY7xJ6JbAQYJK8sluyO9PddkNl7D5 -YC96naxDUQqNTR6zemG8xVC5Ag0EWnfzrgEQAM5KTSlmTjumWh8pj2RzpQ/DxZd+ -XGGN6k7NNsbwMetZ9j+s8CfOtSrYc2U2y5J5nccrAqkW2LtDyNYcQdsC4mH/z+3J -5Jh3TCreibPV/h5wGUahZgHqrM2MmlEXKkgvKTPSAA+PbNGk2PbtDvuwWPfdfvlg -mhu14vEPVk7D5xQsjrp0tTXmoMKGVwTfLGAEb5ygjOVhWUsB1CVq8YNZjzZ0gcXY -mBnkCAq79lzsshz/9xKbx35Zq5FmtXDusFEVrCNPzXTGLvAX8Z+FB1MG3/tdmfE8 -bmXJnpa368YxgQzq3kfusKSuoIUxcuUJO9e3mezouLuTUrs24097fAnq7dUkT1G/ -SAbXKBkCiTsVMwqBlY2kVXk0JksFdbQOB67n+8k53Ww/qGOkYV/QFsXniQWgAqy2 -zWmVCJUzxGuX3hq8W0eJN/U242AvhxLekJfkZAjLayDC9RF3/X9YTL08MOpDIcIp -RspGZW4gQ21ogOAgID9f4ZM2lWk7mUGh1rvSrliTWXaVRZHJ8sCuyplSuCD75OZE -lXJu0hiCKeR3YPBu1wm8SKYv6/Wec0lsHTNs3j2a39KtEN1iF/maV6vQ8ldjejJU -MfYWBGTvvQMquhSmOI2nGq9x2FbuTw0c9XPAe5iTfOIeBZKk/n5EpV6oPQqBHbI/ -5CA9aYKWvFPf5qCrABEBAAGJAjYEGAEIACAWIQTmXZVIG3ibtyepeV6q/on3Rxuu -BAUCWnfzrgIbDAAKCRCq/on3RxuuBKiiD/99GsXHeCwbgZHuRK0rckMjVu+nU96D -4wjHTQiZ6tKtEbrDGwBnVrEUD0B0Bs3M9Bs2E4NU2Yf24Yx9qO4XKCrKTXeK9v0A -joQLEHixoSoYMq7tke1Lph1/DY2PIzoYjvdu/ArfFBjZXsCy3BoEkN0SCIFfT1+x -qDQkjvOAMK1bY/AFZRy0ActgVTmZV4uwSV8KzXEayPM8jN9Un2eyYD4jghAqI35X -sfPmUVoajWIHXXFFDDBDcoagNP7Hw5kC3KSkQfUkOb8kQy7S9gEsufgHxF18ZNuY -kNgsWsimeDfHKpXx2qxpa1SW3HRfuHjGUreGB/GlSzWGWx2ruIuq8ttKYbVcWypG -P0ZaSgY5+0CPhti0s6aciq27iRbYlN1Y8Tt8ywAHikubqF1STXP7hSt1Swt6rCil -ik+cUuc2GUCQ0/9DLuxk0cINygdV49QpMJqTEbAvGW3kHMO0Q1Fu+sBpK6HdScQg -MwWLLaaYnyEckLv84IyznCtMEEd/DupcO2lLHMAXQjKhFxlRiKndS9AYUSyz/QZd -1B/JE/P4Thcg0jgdQSq4k3yMxjbXe2ahvTBmigwKw/Cklppzl42Jk1AoHigmPI/e -qTz5OQeBe5jlFF
svn commit: r24990 - /dev/incubator/pulsar/KEYS
Author: jai1 Date: Tue Feb 13 04:09:43 2018 New Revision: 24990 Log: Replaced gpg key for jai1 Modified: dev/incubator/pulsar/KEYS Modified: dev/incubator/pulsar/KEYS == --- dev/incubator/pulsar/KEYS (original) +++ dev/incubator/pulsar/KEYS Tue Feb 13 04:09:43 2018 @@ -380,13 +380,6 @@ Ef5D3zsz3YwR1SMS2ZsX4aHaXhbSRTKYY83x5n0/ 4R/eV1EOkAVSbS98fTm/LlrV =0XPv -END PGP PUBLIC KEY BLOCK- -pub rsa4096 2018-02-05 [SC] - E65D95481B789BB727A9795EAAFE89F7471BAE04 -uid [ultimate] Jai Asher (CODE SIGNING KEY) <j...@apache.org> -sig 3AAFE89F7471BAE04 2018-02-05 Jai Asher (CODE SIGNING KEY) <j...@apache.org> -sub rsa4096 2018-02-05 [E] -sig AAFE89F7471BAE04 2018-02-05 Jai Asher (CODE SIGNING KEY) <j...@apache.org> - pub rsa4096 2018-02-13 [SC] 0D008FE2DF532D10BF7C6D2C7BA1A64CBBC114EC uid [ultimate] Jai Asher (CODE SIGNING KEY) <j...@apache.org> @@ -396,100 +389,53 @@ sig 7BA1A64CBBC114EC 2018-02-13 -BEGIN PGP PUBLIC KEY BLOCK- -mQINBFp3864BEADJ0p2M664orJ2Q40Ee0t5VQFTW0/FtyaEPBvmDqLQV6rcoZYgq -mhehMPgjGbMSQ3KTYhEqQovPbXh/zdsXIkfNKErt793/DekjVgGxL3j8sfzmYseo -eCIKYofGTHDL3dw5mQ7PzEmerNofNTh/NeooPIfreA0r7guvwlhCAGzlB5YJR7+F -Th+hz9kz+9URMH/Bd4/ZOhobIR1rPe/Ynost+pwT2H7aAIopZ3qH3rr+lbq6Iece -mfxurkvwqSxtd5uatz4ifeJmU60EJ71y43y3oFlYOl32Z1kJfYP3cj3aPYR3cmLT -0VmhoNNI97OogRj5FqYLBMP4aIcRW0YHqKgQ7GsWgTeQ+BxEG0TvWz1RcrVUtGMZ -MfySY9E05R1aolaQNMk2h4mS/R2sDF2efAvBCQx7gwY1v2ORsCcqSBS6S9sRLyO1 -e71mh9TlDJevM5a9RtjigJb6dsF+wYCQ0BdtI8A2xN/c0QhrkeSDt2/Qf9iBkpi3 -irswwc93VwRAWRszXpCk2HdDqJN4X22GRQaFELlZvN8pzPU05rGbfzO73ZtfmTRZ -o7C+hINOAq31+H6p9KnQ8RFh6CC4FAP/tP22JODp7jK7yBt1G4/53bdvFbbgYzf/ -vxhbbQtHrntoXT76DpvfFwdAJyBcIgCWvtrRco3DNqK2Zl6hUfKIJV4HIQARAQAB +mQINBFqCX9MBEADR+/hSQOjmFf/luet05/WSwo24T533ltj2RGRu21DbD9ZmT1zd +IQx1xN8D2BNFvZc+iB9yGASEdAnMZLWKAku4UcZSGaI4e08Pedv7eplEuqKWKe7Q +GgFWCcQ09ZABqboO6cw/+oQqNuiTkrlYIiuCl2DvjZ1SmRucjtNpGj1Mfh1mk3Yq +OJBFI1A9YBh9DsiXjPecjw8zQzdPCnu9nEa/V72N0c4/r0vYbTt3qz3YeaTSC8yd +mWV4ByEBVXWhKPmZnxJoCsqguOCgZvV9+4ANd7DYzFPNanJc43lf/ZCKyAPk7iS+ +ee/b3j3gsFAK5YocGE5QXbXXwHZOajHGjAZRc+3erxkfLDfOol83W9DIzL7IoLcC +TRrCe+Nvu4eP/SBWhn4LOhcLqmyIYdwLY5bQo5cepn2J2x3niME+Hz2fqRq6xB+P +xy9Zl3E2pFjoNW9tfYkjckNgPI4dIgZ8YNNwvHawdkdQHflfs45BlDIFqYGaxbwb ++AJQv1U4G6t1vzt3b8b51tfmRq8yAlHt+BwFVsfFf7HQ/M1Sn/35BdwqvXr+zuFE +WPQ06RLMjvR1EwKbTCJedqHT+e9wS7XYj/WE2Qkp1dUpGzvKSDf6NqGcKi9RBvuv +Vszdw7k2pbfLKOZ4QEn+HxbyLRGA2Eukt590+z4T21erDFWcWzAUy4P/6QARAQAB tC5KYWkgQXNoZXIgKENPREUgU0lHTklORyBLRVkpIDxqYWkxQGFwYWNoZS5vcmc+ -iQJOBBMBCAA4FiEE5l2VSBt4m7cnqXleqv6J90cbrgQFAlp3864CGwMFCwkIBwIG -FQoJCAsCBBYCAwECHgECF4AACgkQqv6J90cbrgQfcA//bjipD4MFRTozqK4kzoPW -7fqnlzkeGY4TAbYWAtQxij9FEg7Q2ypUsfeCM+eLPVZYY+QWYDM2ZiRbL2C3DHEE -cyyBa5U6pb/XAbMHkgoDtekjRGRQS9aZXxpzuUZ//yyhOk5HxIETAKfa/VRu0jxF -pcE+0TJM02ccVoEkfhbdIEilvhBA7zCUKzwiGPPV6eNKUqeF0ErU+kun4FoGtzIs -DJ1n+kGk3a5KKM9jcaRMUptlDTHPqyGhZUhJGqIDIHEjOzrqnD9tsUw1MeQzhX27 -ytghKb9Yu9vSDfayykwWeBg6c+Tkf7YWPpjNEZnH1YTXjgwQXTupBWgycClaAPPz -CsGEimtw0ppE0N1yrCIzD5yZh5M8b3MEOVkKe3mApZ7vxPEdqQwLBBALGMlq1FhR -ECP5tYAbldiARYEcHfjboN1Lfl6/ffj9KXt6MKLPuZ4LH2QIC6n/1RiPE94DLs7J -D3TvyOivJaJCRCaX5GLcwqYYgRJGvEp1LyXW3LeD/552g0njoKyoiYycdPLa2FWd -FJnRlghkG2hkhynlmzPUGtu+UVG6s76z1CUliZc4/Zkc6zqBt5wU82iSST6p9+yW -nYo3vVmVZPM5j/yeDxoJAcsWnA1OANUBCv2TY7xJ6JbAQYJK8sluyO9PddkNl7D5 -YC96naxDUQqNTR6zemG8xVC5Ag0EWnfzrgEQAM5KTSlmTjumWh8pj2RzpQ/DxZd+ -XGGN6k7NNsbwMetZ9j+s8CfOtSrYc2U2y5J5nccrAqkW2LtDyNYcQdsC4mH/z+3J -5Jh3TCreibPV/h5wGUahZgHqrM2MmlEXKkgvKTPSAA+PbNGk2PbtDvuwWPfdfvlg -mhu14vEPVk7D5xQsjrp0tTXmoMKGVwTfLGAEb5ygjOVhWUsB1CVq8YNZjzZ0gcXY -mBnkCAq79lzsshz/9xKbx35Zq5FmtXDusFEVrCNPzXTGLvAX8Z+FB1MG3/tdmfE8 -bmXJnpa368YxgQzq3kfusKSuoIUxcuUJO9e3mezouLuTUrs24097fAnq7dUkT1G/ -SAbXKBkCiTsVMwqBlY2kVXk0JksFdbQOB67n+8k53Ww/qGOkYV/QFsXniQWgAqy2 -zWmVCJUzxGuX3hq8W0eJN/U242AvhxLekJfkZAjLayDC9RF3/X9YTL08MOpDIcIp -RspGZW4gQ21ogOAgID9f4ZM2lWk7mUGh1rvSrliTWXaVRZHJ8sCuyplSuCD75OZE -lXJu0hiCKeR3YPBu1wm8SKYv6/Wec0lsHTNs3j2a39KtEN1iF/maV6vQ8ldjejJU -MfYWBGTvvQMquhSmOI2nGq9x2FbuTw0c9XPAe5iTfOIeBZKk/n5EpV6oPQqBHbI/ -5CA9aYKWvFPf5qCrABEBAAGJAjYEGAEIACAWIQTmXZVIG3ibtyepeV6q/on3Rxuu -BAUCWnfzrgIbDAAKCRCq/on3RxuuBKiiD/99GsXHeCwbgZHuRK0rckMjVu+nU96D -4wjHTQiZ6tKtEbrDGwBnVrEUD0B0Bs3M9Bs2E4NU2Yf24Yx9qO4XKCrKTXeK9v0A -joQLEHixoSoYMq7tke1Lph1/DY2PIzoYjvdu/ArfFBjZXsCy3BoEkN0SCIFfT1+x -qDQkjvOAMK1bY/AFZRy0ActgVTmZV4uwSV8KzXEayPM8jN9Un2eyYD4jghAqI35X -sfPmUVoajWIHXXFFDDBDcoagNP7Hw5kC3KSkQfUkOb8kQy7S9gEsufgHxF18ZNuY -kNgsWsimeDfHKpXx2qxpa1SW3HRfuHjGUreGB/GlSzWGWx2ruIuq8ttKYbVcWypG -P0ZaSgY5+0CPhti0s6aciq27iRbYlN1Y8Tt8ywAHikubqF1STXP7hSt1Swt6rCil -ik+cUuc2GUCQ0/9DLuxk0cINygdV49QpMJqTEbAvGW3kHMO0Q1Fu+sBpK6HdScQg -MwWLLaaYnyEckLv84IyznCtMEEd/DupcO2lLHMAXQjKhFxlRiKndS9AYUSyz/QZd -1B/JE/P4Thcg0jgdQSq4k3yMxjbXe2ahvTBmigwKw/Cklppzl42Jk1AoHigmPI/e -qTz5OQeBe5jlFFbL0APLRz4Xoy7Kc/xW3ES4wp5Y1Svo+nSaPHPTioHkXFZs92x8 -8s7lT8GGT3K90ZkCDQRagl/TARAA0fv4UkDo5hX/
svn commit: r24989 - /dev/incubator/pulsar/KEYS
Author: jai1 Date: Tue Feb 13 04:06:25 2018 New Revision: 24989 Log: Replaced gpg key for jai1 Modified: dev/incubator/pulsar/KEYS Modified: dev/incubator/pulsar/KEYS == --- dev/incubator/pulsar/KEYS (original) +++ dev/incubator/pulsar/KEYS Tue Feb 13 04:06:25 2018 @@ -387,6 +387,13 @@ sig 3AAFE89F7471BAE04 2018-02-05 sub rsa4096 2018-02-05 [E] sig AAFE89F7471BAE04 2018-02-05 Jai Asher (CODE SIGNING KEY) <j...@apache.org> +pub rsa4096 2018-02-13 [SC] + 0D008FE2DF532D10BF7C6D2C7BA1A64CBBC114EC +uid [ultimate] Jai Asher (CODE SIGNING KEY) <j...@apache.org> +sig 37BA1A64CBBC114EC 2018-02-13 Jai Asher (CODE SIGNING KEY) <j...@apache.org> +sub rsa4096 2018-02-13 [E] +sig 7BA1A64CBBC114EC 2018-02-13 Jai Asher (CODE SIGNING KEY) <j...@apache.org> + -BEGIN PGP PUBLIC KEY BLOCK- mQINBFp3864BEADJ0p2M664orJ2Q40Ee0t5VQFTW0/FtyaEPBvmDqLQV6rcoZYgq @@ -436,6 +443,53 @@ ik+cUuc2GUCQ0/9DLuxk0cINygdV49QpMJqTEbAv MwWLLaaYnyEckLv84IyznCtMEEd/DupcO2lLHMAXQjKhFxlRiKndS9AYUSyz/QZd 1B/JE/P4Thcg0jgdQSq4k3yMxjbXe2ahvTBmigwKw/Cklppzl42Jk1AoHigmPI/e qTz5OQeBe5jlFFbL0APLRz4Xoy7Kc/xW3ES4wp5Y1Svo+nSaPHPTioHkXFZs92x8 -8s7lT8GGT3K90Q== -=y+ns +8s7lT8GGT3K90ZkCDQRagl/TARAA0fv4UkDo5hX/5bnrdOf1ksKNuE+d95bY9kRk +bttQ2w/WZk9c3SEMdcTfA9gTRb2XPogfchgEhHQJzGS1igJLuFHGUhmiOHtPD3nb ++3qZRLqilinu0BoBVgnENPWQAam6DunMP/qEKjbok5K5WCIrgpdg742dUpkbnI7T +aRo9TH4dZpN2KjiQRSNQPWAYfQ7Il4z3nI8PM0M3Twp7vZxGv1e9jdHOP69L2G07 +d6s92Hmk0gvMnZlleAchAVV1oSj5mZ8SaArKoLjgoGb1ffuADXew2MxTzWpyXON5 +X/2QisgD5O4kvnnv29494LBQCuWKHBhOUF2118B2TmoxxowGUXPt3q8ZHyw3zqJf +N1vQyMy+yKC3Ak0awnvjb7uHj/0gVoZ+CzoXC6psiGHcC2OW0KOXHqZ9idsd54jB +Ph89n6kausQfj8cvWZdxNqRY6DVvbX2JI3JDYDyOHSIGfGDTcLx2sHZHUB35X7OO +QZQyBamBmsW8G/gCUL9VOBurdb87d2/G+dbX5kavMgJR7fgcBVbHxX+x0PzNUp/9 ++QXcKr16/s7hRFj0NOkSzI70dRMCm0wiXnah0/nvcEu12I/1hNkJKdXVKRs7ykg3 ++jahnCovUQb7r1bM3cO5NqW3yyjmeEBJ/h8W8i0RgNhLpLefdPs+E9tXqwxVnFsw +FMuD/+kAEQEAAbQuSmFpIEFzaGVyIChDT0RFIFNJR05JTkcgS0VZKSA8amFpMUBh +cGFjaGUub3JnPokCTgQTAQgAOBYhBA0Aj+LfUy0Qv3xtLHuhpky7wRTsBQJagl/T +AhsDBQsJCAcCBhUKCQgLAgQWAgMBAh4BAheAAAoJEHuhpky7wRTsGpkP/31Hlfcd +dTKp/C8Ng+kJHz1+AfK+MOoCKKC2GVWiF4h0z3NWfnRL7R4f8ZVXYg5FhhXHs4u3 +whOiYEqgNu95IV8Ui3KLmdWSO2EzeylAkLZgBHQ6teaWYW8C6UuBvl4dl4pTwjBA +9nQwdXlNVTW7TT/L1UkZl+rC8TqU94NqQjCSrd78zvCvQJzEdWy6GaHD0gBAEduS +5e9B7d5oHR16KW9b/tbAlF+gBk1NoIozEzwq9bWJfHEMo2AxxtTyhxsBU1MGZUXe +FNleyxP5y4hreUeDeUyTjB54Z+MugTOmSMnXOPIrMSvNUqNVoToWGmS9S5D2NI/L +fR3Zf+j/FGBDmP/kTbcWL6AVBFE6W4eXWRX5J1QJG+MuftVLTr54w9RSQaxD0jyX +vphwN35zKdtPGPYUlOg36BaBSwk5/Z9aF4ZdhxQOFxppruwuaVTDSvmIFo4HFCjI +m4lgJMFoFpGjWSKeObpJ5uW4Pb9wtZwkJBIQSz2q2k9ak93JeJHl8iXiGkIsGYg6 +wfRJyDXSTwDMaOwdgBEWxq+hoqrZkIeuBiKyjF+5SHa3v7920H+RT/xf6jGJKoT6 +bu0Ql6tbheZ1AmhzkMa9LDKMAybzUzBEp7TF+CXlJVnlsc/66UtJa9Gu3d+lLG8m +R8XG+7AVY3ItkBTxNNQ22d8G+kTcJM90ENQmuQINBFqCX9MBEACxD7XDiw4z2vZg +MsVNNq79q0eF/+CV3B55CQZqwToByNbhN9ZzAtQTn0MI7qcS0LOP0WEdgLTD+KBE +rgsC+/BNQQHR21el/VASZj7/URt2G2s1LOSCUXMnxZOznIYM1TZGiHz2kZKg17Fv +W2MJm0YkITIlZN9v8b6444GcwCvGEDQWi+ugLNuc/jSrKbbRA90K1EAa6NU6stUa +RUnlFfIJfE8RYSywoKnKf8IX19vujLKCql6AwOjiMMXTZgfrdgKEJqI8LnZlspsh +j+5/R08HQS/SNxOtp980rk/wcppKTjAr5gxNpyQFYvfbEYuEFWcmrThF/Rjug4yQ +/D3L0Jd5wQ2rkM1GZm3RvZkRYmr7VVfbrv0yc6v3IjBvtnzIdJ/6ffi3uKr/t2OM +Xph3o84ALv+OC4F2W9zOXg35FMhcX5YffAdyWZSEsmgLMMEyE+FI3SFcfpgTk2KK +6yD8TdMGU8KRG+vLHeg89cKAJiG/MTfgMVPnBkdbQj/nuO7fdqSR5EwdOwukCXBz +V13dJRSaSGT4wp8wsBtFz8IRM6MGAd4q3nOgqocz7yi9l7Fb9gIruLIRnVR4q3o0 +9uQ4nnUNc/VQk7MXyZtcuYHaUt1CiQDtYTUgSR00wHlfDoJARxMGdap8+khDoQ8I +obUn+QS3Vx31bwpbllXV8ZVgkdoUuwARAQABiQI2BBgBCAAgFiEEDQCP4t9TLRC/ +fG0se6GmTLvBFOwFAlqCX9MCGwwACgkQe6GmTLvBFOzb9w//XfzpvsTisnbse52q +lMsQOUrgS9b3KNAW6NoVEmz2nudJJvJcqiDdNUPn1ySXT0Ldoo89Mwe/EEK/oTfY +U6kMbnz/UffB+oF8ktoVXCdBNkRL8zT+V7hBcA+pwLHYyys/TrqWMU+SDOyMoU5X +KKlourl7+yjXr2xb/mCAco+XjyysdSWAKT8qx3TeybnAGyFas+bNohCNdzdTeSbF +bhicuySCszgrFRtyQED6dnreFTqqe3HSrkJswk8yGJmRi0XDCtFtlXNw74EKbJNs +CfSBE3CTwHdVRIAQfeRAEY+nyU2HTuWDmPDscLMNipGRvwqmmNuPAnBwqJhq3k0s +jeYCoP/p1DAwJCOVZdR1TshaIkZZbB/oncSMA/fmq1XVfN2zRCnaUmQ0tkFwBoyl +9l18WAvfrfT2JciqAW4ZVaVE8f5wYnLlNDfoETUusAyhjjYBMCDjiYyOX5Fg6Lw7 +CYTzcmwkpvBw2mwWAlRyokAJDbVyW8elE5JcrXW+g0GYB5mc5v27+xSNVsbX0kCN +y27r6sP7mmyiFE0slYoqf+S5+SHYT0Zxdh8nv0aQ//4U6mNESQv35iQaiFf7WTI6 +eRBD60O/IJZ+w0jklQ1yKrTgEzGclOhWMW8x7mwv/z++AAU70pGrLeYZpwGbckTD +yu3ojTS7qC6iUe+Me4f+5oxTSpY= +=mB+g -END PGP PUBLIC KEY BLOCK-
[incubator-pulsar] branch master updated: Proxy forward auth data (#1169)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/master by this push: new b429931 Proxy forward auth data (#1169) b429931 is described below commit b429931e1de2f430c72b751e237b446f95fedb3c Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Wed Feb 7 18:14:24 2018 -0800 Proxy forward auth data (#1169) --- conf/broker.conf | 7 + conf/proxy.conf| 4 + conf/standalone.conf | 7 + .../apache/pulsar/broker/ServiceConfiguration.java | 12 + .../apache/pulsar/broker/service/ServerCnx.java| 93 +++- .../pulsar/broker/service/ServerCnxTest.java | 2 +- .../org/apache/pulsar/common/api/Commands.java | 53 +- .../apache/pulsar/common/api/proto/PulsarApi.java | 564 + pulsar-common/src/main/proto/PulsarApi.proto | 24 +- .../pulsar/proxy/server/DirectProxyHandler.java| 15 +- .../pulsar/proxy/server/LookupProxyHandler.java| 7 +- .../pulsar/proxy/server/ProxyConfiguration.java| 13 +- .../pulsar/proxy/server/ProxyConnection.java | 7 + ...mentTest.java => ProxyForwardAuthDataTest.java} | 150 +- .../proxy/server/ProxyRolesEnforcementTest.java| 6 +- 15 files changed, 796 insertions(+), 168 deletions(-) diff --git a/conf/broker.conf b/conf/broker.conf index 780b192..609cddd 100644 --- a/conf/broker.conf +++ b/conf/broker.conf @@ -169,6 +169,13 @@ enableRunBookieTogether=false enableRunBookieAutoRecoveryTogether=false ### --- Authentication --- ### +# Role names that are treated as "proxy roles". If the broker sees a request with +#role as proxyRoles - it will demand to see a valid original principal. +proxyRoles= + +# If this flag is set then the broker authenticates the original Auth data +# else it just accepts the originalPrincipal and authorizes it (if required). +authenticateOriginalAuthData=false # Enable TLS tlsEnabled=false diff --git a/conf/proxy.conf b/conf/proxy.conf index 2ecc9b1..dafcfc4 100644 --- a/conf/proxy.conf +++ b/conf/proxy.conf @@ -57,6 +57,10 @@ brokerClientAuthenticationParameters= # operations and publish/consume from all topics (comma-separated) superUserRoles= +# Forward client authorization Credentials to Broker for re authorization +# make sure authentication is enabled for this to take effect +forwardAuthorizationCredentials=false + # --- TLS --- # # Enable TLS in the proxy diff --git a/conf/standalone.conf b/conf/standalone.conf index 2ebca6a..d2533e1 100644 --- a/conf/standalone.conf +++ b/conf/standalone.conf @@ -152,6 +152,13 @@ enablePersistentTopics=true enableNonPersistentTopics=true ### --- Authentication --- ### +# Role names that are treated as "proxy roles". If the broker sees a request with +#role as proxyRoles - it will demand to see a valid original principal. +proxyRoles= + +# If this flag is set then the broker authenticates the original Auth data +# else it just accepts the originalPrincipal and authorizes it (if required). +authenticateOriginalAuthData=false # Enable authentication authenticationEnabled=false diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java index 0a3c399..de27fd9 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java @@ -197,6 +197,10 @@ public class ServiceConfiguration implements PulsarConfiguration { // role as proxyRoles - it will demand to see the original client role or certificate. private Set proxyRoles = Sets.newTreeSet(); +// If this flag is set then the broker authenticates the original Auth data +// else it just accepts the originalPrincipal and authorizes it (if required). +private boolean authenticateOriginalAuthData = false; + // Allow wildcard matching in authorization // (wildcard matching only applicable if wildcard-char: // * presents at first or last position eg: *.pulsar.service, pulsar.service.*) @@ -1377,4 +1381,12 @@ public class ServiceConfiguration implements PulsarConfiguration { public void setExposeTopicLevelMetricsInPrometheus(boolean exposeTopicLevelMetricsInPrometheus) { this.exposeTopicLevelMetricsInPrometheus = exposeTopicLevelMetricsInPrometheus; } + +public boolean authenticateOriginalAuthData() { +return authenticateOriginalAuthData; +} + +public void setAuthenticateOriginalAuthData(boolean authenticateOriginalAuthData) { +this.authenticateOriginalAuthData = authenticateOriginalAuthData; +} } diff --git
[incubator-pulsar] branch master updated: Proxy roles enforcement (#1168)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git The following commit(s) were added to refs/heads/master by this push: new 15e6655 Proxy roles enforcement (#1168) 15e6655 is described below commit 15e665545b1610df362bf58d730bf3b8a2699308 Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Mon Feb 5 18:50:50 2018 -0800 Proxy roles enforcement (#1168) --- .../apache/pulsar/broker/ServiceConfiguration.java | 14 +- .../broker/authorization/AuthorizationManager.java | 22 +- .../apache/pulsar/broker/service/ServerCnx.java| 52 +++- .../pulsar/broker/service/ServerCnxTest.java | 1 + .../proxy/server/ProxyRolesEnforcementTest.java| 266 + 5 files changed, 343 insertions(+), 12 deletions(-) diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java index 0cc4001..b542ee4 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java @@ -193,6 +193,10 @@ public class ServiceConfiguration implements PulsarConfiguration { // do all admin operations and publish/consume from all topics private Set superUserRoles = Sets.newTreeSet(); +// Role names that are treated as "proxy roles". If the broker sees a request with +// role as proxyRoles - it will demand to see the original client role or certificate. +private Set proxyRoles = Sets.newTreeSet(); + // Allow wildcard matching in authorization // (wildcard matching only applicable if wildcard-char: // * presents at first or last position eg: *.pulsar.service, pulsar.service.*) @@ -794,7 +798,15 @@ public class ServiceConfiguration implements PulsarConfiguration { public Set getSuperUserRoles() { return superUserRoles; } - + +public Set getProxyRoles() { +return proxyRoles; +} + +public void setProxyRoles(Set proxyRoles) { +this.proxyRoles = proxyRoles; +} + public boolean getAuthorizationAllowWildcardsMatching() { return authorizationAllowWildcardsMatching; } diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationManager.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationManager.java index 2bf7ce6..0950ae2 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationManager.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationManager.java @@ -171,9 +171,12 @@ public class AuthorizationManager { finalResult.complete(produceAuthorized); return; } -} else if (log.isDebugEnabled()) { -log.debug("Destination [{}] Role [{}] exception occured while trying to check Produce permissions. {}", -destination.toString(), role, ex.getMessage()); +} else { +if (log.isDebugEnabled()) { +log.debug( +"Destination [{}] Role [{}] exception occured while trying to check Produce permissions. {}", +destination.toString(), role, ex.getMessage()); +} } canConsumeAsync(destination, role, null).whenComplete((consumeAuthorized, e) -> { if (e == null) { @@ -181,10 +184,15 @@ public class AuthorizationManager { finalResult.complete(consumeAuthorized); return; } -} else if (log.isDebugEnabled()) { -log.debug( -"Destination [{}] Role [{}] exception occured while trying to check Consume permissions. {}", -destination.toString(), role, e.getMessage()); +} else { +if (log.isDebugEnabled()) { +log.debug( +"Destination [{}] Role [{}] exception occured while trying to check Consume permissions. {}", +destination.toString(), role, e.getMessage()); + +} +finalResult.completeExceptionally(e); +return; } finalResult.complete(false); }); diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java index c97..dfa4fd7 100644 --- a/pulsar-broker/src/main/
svn commit: r24690 - /release/incubator/pulsar/KEYS
Author: jai1 Date: Mon Feb 5 06:05:44 2018 New Revision: 24690 Log: Added gpg key for jai1 Modified: release/incubator/pulsar/KEYS Modified: release/incubator/pulsar/KEYS == --- release/incubator/pulsar/KEYS (original) +++ release/incubator/pulsar/KEYS Mon Feb 5 06:05:44 2018 @@ -379,3 +379,62 @@ Ef5D3zsz3YwR1SMS2ZsX4aHaXhbSRTKYY83x5n0/ 4R/eV1EOkAVSbS98fTm/LlrV =0XPv -END PGP PUBLIC KEY BLOCK- +pub rsa4096 2018-02-05 [SC] + E65D95481B789BB727A9795EAAFE89F7471BAE04 +uid [ultimate] Jai Asher (CODE SIGNING KEY) <j...@apache.org> +sig 3AAFE89F7471BAE04 2018-02-05 Jai Asher (CODE SIGNING KEY) <j...@apache.org> +sub rsa4096 2018-02-05 [E] +sig AAFE89F7471BAE04 2018-02-05 Jai Asher (CODE SIGNING KEY) <j...@apache.org> + +-BEGIN PGP PUBLIC KEY BLOCK- + +mQINBFp3864BEADJ0p2M664orJ2Q40Ee0t5VQFTW0/FtyaEPBvmDqLQV6rcoZYgq +mhehMPgjGbMSQ3KTYhEqQovPbXh/zdsXIkfNKErt793/DekjVgGxL3j8sfzmYseo +eCIKYofGTHDL3dw5mQ7PzEmerNofNTh/NeooPIfreA0r7guvwlhCAGzlB5YJR7+F +Th+hz9kz+9URMH/Bd4/ZOhobIR1rPe/Ynost+pwT2H7aAIopZ3qH3rr+lbq6Iece +mfxurkvwqSxtd5uatz4ifeJmU60EJ71y43y3oFlYOl32Z1kJfYP3cj3aPYR3cmLT +0VmhoNNI97OogRj5FqYLBMP4aIcRW0YHqKgQ7GsWgTeQ+BxEG0TvWz1RcrVUtGMZ +MfySY9E05R1aolaQNMk2h4mS/R2sDF2efAvBCQx7gwY1v2ORsCcqSBS6S9sRLyO1 +e71mh9TlDJevM5a9RtjigJb6dsF+wYCQ0BdtI8A2xN/c0QhrkeSDt2/Qf9iBkpi3 +irswwc93VwRAWRszXpCk2HdDqJN4X22GRQaFELlZvN8pzPU05rGbfzO73ZtfmTRZ +o7C+hINOAq31+H6p9KnQ8RFh6CC4FAP/tP22JODp7jK7yBt1G4/53bdvFbbgYzf/ +vxhbbQtHrntoXT76DpvfFwdAJyBcIgCWvtrRco3DNqK2Zl6hUfKIJV4HIQARAQAB +tC5KYWkgQXNoZXIgKENPREUgU0lHTklORyBLRVkpIDxqYWkxQGFwYWNoZS5vcmc+ +iQJOBBMBCAA4FiEE5l2VSBt4m7cnqXleqv6J90cbrgQFAlp3864CGwMFCwkIBwIG +FQoJCAsCBBYCAwECHgECF4AACgkQqv6J90cbrgQfcA//bjipD4MFRTozqK4kzoPW +7fqnlzkeGY4TAbYWAtQxij9FEg7Q2ypUsfeCM+eLPVZYY+QWYDM2ZiRbL2C3DHEE +cyyBa5U6pb/XAbMHkgoDtekjRGRQS9aZXxpzuUZ//yyhOk5HxIETAKfa/VRu0jxF +pcE+0TJM02ccVoEkfhbdIEilvhBA7zCUKzwiGPPV6eNKUqeF0ErU+kun4FoGtzIs +DJ1n+kGk3a5KKM9jcaRMUptlDTHPqyGhZUhJGqIDIHEjOzrqnD9tsUw1MeQzhX27 +ytghKb9Yu9vSDfayykwWeBg6c+Tkf7YWPpjNEZnH1YTXjgwQXTupBWgycClaAPPz +CsGEimtw0ppE0N1yrCIzD5yZh5M8b3MEOVkKe3mApZ7vxPEdqQwLBBALGMlq1FhR +ECP5tYAbldiARYEcHfjboN1Lfl6/ffj9KXt6MKLPuZ4LH2QIC6n/1RiPE94DLs7J +D3TvyOivJaJCRCaX5GLcwqYYgRJGvEp1LyXW3LeD/552g0njoKyoiYycdPLa2FWd +FJnRlghkG2hkhynlmzPUGtu+UVG6s76z1CUliZc4/Zkc6zqBt5wU82iSST6p9+yW +nYo3vVmVZPM5j/yeDxoJAcsWnA1OANUBCv2TY7xJ6JbAQYJK8sluyO9PddkNl7D5 +YC96naxDUQqNTR6zemG8xVC5Ag0EWnfzrgEQAM5KTSlmTjumWh8pj2RzpQ/DxZd+ +XGGN6k7NNsbwMetZ9j+s8CfOtSrYc2U2y5J5nccrAqkW2LtDyNYcQdsC4mH/z+3J +5Jh3TCreibPV/h5wGUahZgHqrM2MmlEXKkgvKTPSAA+PbNGk2PbtDvuwWPfdfvlg +mhu14vEPVk7D5xQsjrp0tTXmoMKGVwTfLGAEb5ygjOVhWUsB1CVq8YNZjzZ0gcXY +mBnkCAq79lzsshz/9xKbx35Zq5FmtXDusFEVrCNPzXTGLvAX8Z+FB1MG3/tdmfE8 +bmXJnpa368YxgQzq3kfusKSuoIUxcuUJO9e3mezouLuTUrs24097fAnq7dUkT1G/ +SAbXKBkCiTsVMwqBlY2kVXk0JksFdbQOB67n+8k53Ww/qGOkYV/QFsXniQWgAqy2 +zWmVCJUzxGuX3hq8W0eJN/U242AvhxLekJfkZAjLayDC9RF3/X9YTL08MOpDIcIp +RspGZW4gQ21ogOAgID9f4ZM2lWk7mUGh1rvSrliTWXaVRZHJ8sCuyplSuCD75OZE +lXJu0hiCKeR3YPBu1wm8SKYv6/Wec0lsHTNs3j2a39KtEN1iF/maV6vQ8ldjejJU +MfYWBGTvvQMquhSmOI2nGq9x2FbuTw0c9XPAe5iTfOIeBZKk/n5EpV6oPQqBHbI/ +5CA9aYKWvFPf5qCrABEBAAGJAjYEGAEIACAWIQTmXZVIG3ibtyepeV6q/on3Rxuu +BAUCWnfzrgIbDAAKCRCq/on3RxuuBKiiD/99GsXHeCwbgZHuRK0rckMjVu+nU96D +4wjHTQiZ6tKtEbrDGwBnVrEUD0B0Bs3M9Bs2E4NU2Yf24Yx9qO4XKCrKTXeK9v0A +joQLEHixoSoYMq7tke1Lph1/DY2PIzoYjvdu/ArfFBjZXsCy3BoEkN0SCIFfT1+x +qDQkjvOAMK1bY/AFZRy0ActgVTmZV4uwSV8KzXEayPM8jN9Un2eyYD4jghAqI35X +sfPmUVoajWIHXXFFDDBDcoagNP7Hw5kC3KSkQfUkOb8kQy7S9gEsufgHxF18ZNuY +kNgsWsimeDfHKpXx2qxpa1SW3HRfuHjGUreGB/GlSzWGWx2ruIuq8ttKYbVcWypG +P0ZaSgY5+0CPhti0s6aciq27iRbYlN1Y8Tt8ywAHikubqF1STXP7hSt1Swt6rCil +ik+cUuc2GUCQ0/9DLuxk0cINygdV49QpMJqTEbAvGW3kHMO0Q1Fu+sBpK6HdScQg +MwWLLaaYnyEckLv84IyznCtMEEd/DupcO2lLHMAXQjKhFxlRiKndS9AYUSyz/QZd +1B/JE/P4Thcg0jgdQSq4k3yMxjbXe2ahvTBmigwKw/Cklppzl42Jk1AoHigmPI/e +qTz5OQeBe5jlFFbL0APLRz4Xoy7Kc/xW3ES4wp5Y1Svo+nSaPHPTioHkXFZs92x8 +8s7lT8GGT3K90Q== +=y+ns +-END PGP PUBLIC KEY BLOCK-
svn commit: r24689 - /dev/incubator/pulsar/KEYS
Author: jai1 Date: Mon Feb 5 06:04:59 2018 New Revision: 24689 Log: Added gpg key for jai1 Modified: dev/incubator/pulsar/KEYS Modified: dev/incubator/pulsar/KEYS == --- dev/incubator/pulsar/KEYS (original) +++ dev/incubator/pulsar/KEYS Mon Feb 5 06:04:59 2018 @@ -380,3 +380,62 @@ Ef5D3zsz3YwR1SMS2ZsX4aHaXhbSRTKYY83x5n0/ 4R/eV1EOkAVSbS98fTm/LlrV =0XPv -END PGP PUBLIC KEY BLOCK- +pub rsa4096 2018-02-05 [SC] + E65D95481B789BB727A9795EAAFE89F7471BAE04 +uid [ultimate] Jai Asher (CODE SIGNING KEY) <j...@apache.org> +sig 3AAFE89F7471BAE04 2018-02-05 Jai Asher (CODE SIGNING KEY) <j...@apache.org> +sub rsa4096 2018-02-05 [E] +sig AAFE89F7471BAE04 2018-02-05 Jai Asher (CODE SIGNING KEY) <j...@apache.org> + +-BEGIN PGP PUBLIC KEY BLOCK- + +mQINBFp3864BEADJ0p2M664orJ2Q40Ee0t5VQFTW0/FtyaEPBvmDqLQV6rcoZYgq +mhehMPgjGbMSQ3KTYhEqQovPbXh/zdsXIkfNKErt793/DekjVgGxL3j8sfzmYseo +eCIKYofGTHDL3dw5mQ7PzEmerNofNTh/NeooPIfreA0r7guvwlhCAGzlB5YJR7+F +Th+hz9kz+9URMH/Bd4/ZOhobIR1rPe/Ynost+pwT2H7aAIopZ3qH3rr+lbq6Iece +mfxurkvwqSxtd5uatz4ifeJmU60EJ71y43y3oFlYOl32Z1kJfYP3cj3aPYR3cmLT +0VmhoNNI97OogRj5FqYLBMP4aIcRW0YHqKgQ7GsWgTeQ+BxEG0TvWz1RcrVUtGMZ +MfySY9E05R1aolaQNMk2h4mS/R2sDF2efAvBCQx7gwY1v2ORsCcqSBS6S9sRLyO1 +e71mh9TlDJevM5a9RtjigJb6dsF+wYCQ0BdtI8A2xN/c0QhrkeSDt2/Qf9iBkpi3 +irswwc93VwRAWRszXpCk2HdDqJN4X22GRQaFELlZvN8pzPU05rGbfzO73ZtfmTRZ +o7C+hINOAq31+H6p9KnQ8RFh6CC4FAP/tP22JODp7jK7yBt1G4/53bdvFbbgYzf/ +vxhbbQtHrntoXT76DpvfFwdAJyBcIgCWvtrRco3DNqK2Zl6hUfKIJV4HIQARAQAB +tC5KYWkgQXNoZXIgKENPREUgU0lHTklORyBLRVkpIDxqYWkxQGFwYWNoZS5vcmc+ +iQJOBBMBCAA4FiEE5l2VSBt4m7cnqXleqv6J90cbrgQFAlp3864CGwMFCwkIBwIG +FQoJCAsCBBYCAwECHgECF4AACgkQqv6J90cbrgQfcA//bjipD4MFRTozqK4kzoPW +7fqnlzkeGY4TAbYWAtQxij9FEg7Q2ypUsfeCM+eLPVZYY+QWYDM2ZiRbL2C3DHEE +cyyBa5U6pb/XAbMHkgoDtekjRGRQS9aZXxpzuUZ//yyhOk5HxIETAKfa/VRu0jxF +pcE+0TJM02ccVoEkfhbdIEilvhBA7zCUKzwiGPPV6eNKUqeF0ErU+kun4FoGtzIs +DJ1n+kGk3a5KKM9jcaRMUptlDTHPqyGhZUhJGqIDIHEjOzrqnD9tsUw1MeQzhX27 +ytghKb9Yu9vSDfayykwWeBg6c+Tkf7YWPpjNEZnH1YTXjgwQXTupBWgycClaAPPz +CsGEimtw0ppE0N1yrCIzD5yZh5M8b3MEOVkKe3mApZ7vxPEdqQwLBBALGMlq1FhR +ECP5tYAbldiARYEcHfjboN1Lfl6/ffj9KXt6MKLPuZ4LH2QIC6n/1RiPE94DLs7J +D3TvyOivJaJCRCaX5GLcwqYYgRJGvEp1LyXW3LeD/552g0njoKyoiYycdPLa2FWd +FJnRlghkG2hkhynlmzPUGtu+UVG6s76z1CUliZc4/Zkc6zqBt5wU82iSST6p9+yW +nYo3vVmVZPM5j/yeDxoJAcsWnA1OANUBCv2TY7xJ6JbAQYJK8sluyO9PddkNl7D5 +YC96naxDUQqNTR6zemG8xVC5Ag0EWnfzrgEQAM5KTSlmTjumWh8pj2RzpQ/DxZd+ +XGGN6k7NNsbwMetZ9j+s8CfOtSrYc2U2y5J5nccrAqkW2LtDyNYcQdsC4mH/z+3J +5Jh3TCreibPV/h5wGUahZgHqrM2MmlEXKkgvKTPSAA+PbNGk2PbtDvuwWPfdfvlg +mhu14vEPVk7D5xQsjrp0tTXmoMKGVwTfLGAEb5ygjOVhWUsB1CVq8YNZjzZ0gcXY +mBnkCAq79lzsshz/9xKbx35Zq5FmtXDusFEVrCNPzXTGLvAX8Z+FB1MG3/tdmfE8 +bmXJnpa368YxgQzq3kfusKSuoIUxcuUJO9e3mezouLuTUrs24097fAnq7dUkT1G/ +SAbXKBkCiTsVMwqBlY2kVXk0JksFdbQOB67n+8k53Ww/qGOkYV/QFsXniQWgAqy2 +zWmVCJUzxGuX3hq8W0eJN/U242AvhxLekJfkZAjLayDC9RF3/X9YTL08MOpDIcIp +RspGZW4gQ21ogOAgID9f4ZM2lWk7mUGh1rvSrliTWXaVRZHJ8sCuyplSuCD75OZE +lXJu0hiCKeR3YPBu1wm8SKYv6/Wec0lsHTNs3j2a39KtEN1iF/maV6vQ8ldjejJU +MfYWBGTvvQMquhSmOI2nGq9x2FbuTw0c9XPAe5iTfOIeBZKk/n5EpV6oPQqBHbI/ +5CA9aYKWvFPf5qCrABEBAAGJAjYEGAEIACAWIQTmXZVIG3ibtyepeV6q/on3Rxuu +BAUCWnfzrgIbDAAKCRCq/on3RxuuBKiiD/99GsXHeCwbgZHuRK0rckMjVu+nU96D +4wjHTQiZ6tKtEbrDGwBnVrEUD0B0Bs3M9Bs2E4NU2Yf24Yx9qO4XKCrKTXeK9v0A +joQLEHixoSoYMq7tke1Lph1/DY2PIzoYjvdu/ArfFBjZXsCy3BoEkN0SCIFfT1+x +qDQkjvOAMK1bY/AFZRy0ActgVTmZV4uwSV8KzXEayPM8jN9Un2eyYD4jghAqI35X +sfPmUVoajWIHXXFFDDBDcoagNP7Hw5kC3KSkQfUkOb8kQy7S9gEsufgHxF18ZNuY +kNgsWsimeDfHKpXx2qxpa1SW3HRfuHjGUreGB/GlSzWGWx2ruIuq8ttKYbVcWypG +P0ZaSgY5+0CPhti0s6aciq27iRbYlN1Y8Tt8ywAHikubqF1STXP7hSt1Swt6rCil +ik+cUuc2GUCQ0/9DLuxk0cINygdV49QpMJqTEbAvGW3kHMO0Q1Fu+sBpK6HdScQg +MwWLLaaYnyEckLv84IyznCtMEEd/DupcO2lLHMAXQjKhFxlRiKndS9AYUSyz/QZd +1B/JE/P4Thcg0jgdQSq4k3yMxjbXe2ahvTBmigwKw/Cklppzl42Jk1AoHigmPI/e +qTz5OQeBe5jlFFbL0APLRz4Xoy7Kc/xW3ES4wp5Y1Svo+nSaPHPTioHkXFZs92x8 +8s7lT8GGT3K90Q== +=y+ns +-END PGP PUBLIC KEY BLOCK-
[incubator-pulsar.wiki] branch master updated: Updated Create GPG keys to sign release artifacts (markdown)
This is an automated email from the ASF dual-hosted git repository. jai1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.wiki.git The following commit(s) were added to refs/heads/master by this push: new 8841c56 Updated Create GPG keys to sign release artifacts (markdown) 8841c56 is described below commit 8841c56fc5e7fed09ce09436b95c059c4780f1da Author: Jai Asher <j...@ccs.neu.edu> AuthorDate: Sun Feb 4 21:59:55 2018 -0800 Updated Create GPG keys to sign release artifacts (markdown) --- Create-GPG-keys-to-sign-release-artifacts.md | 1 + 1 file changed, 1 insertion(+) diff --git a/Create-GPG-keys-to-sign-release-artifacts.md b/Create-GPG-keys-to-sign-release-artifacts.md index 8ea2a48..19a670f 100644 --- a/Create-GPG-keys-to-sign-release-artifacts.md +++ b/Create-GPG-keys-to-sign-release-artifacts.md @@ -21,6 +21,7 @@ personal-digest-preferences SHA512 cert-digest-algo SHA512 default-preference-list SHA512 SHA384 SHA256 SHA224 AES256 AES192 AES CAST5 ZLIB BZIP2 ZIP Uncompressed EOL >> ~/.gnupg/gnupg.conf +chmod 700 ~/.gnupg/gnupg.conf ``` Check the version. -- To stop receiving notification emails like this one, please contact j...@apache.org.