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.
