)]}' { "log": [ { "commit": "63b5c7081f5cdfeb6bfd82af2816de1d06fa4286", "tree": "90d69e2d8e24ea082cedd1a420d77a3a3c96c04a", "parents": [ "608455d5aa9511e733f25f075ae368f7ea919e29" ], "author": { "name": "Lari Hotari", "email": "lhotari@users.noreply.github.com", "time": "Wed Nov 11 08:37:06 2020 +0200" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Nov 10 23:37:06 2020 -0700" }, "message": "PIP-62: Remove tests and examples related to pulsar-adapters (#8511)\n\nrelated to #8480\r\n\r\nremove remaining modules related to pulsar-adapters:\r\n- examples/flink\r\n- examples/spark\r\n- tests/pulsar-kafka-compat-client-test\r\n- tests/pulsar-spark-test\r\n- tests/pulsar-storm-test" }, { "commit": "608455d5aa9511e733f25f075ae368f7ea919e29", "tree": "13745f430bd6b402ad00bf69746230b5d8ce00ec", "parents": [ "723ab991f8cf755e9274a59fefb54489358e106a" ], "author": { "name": "Jia Zhai", "email": "zhaijia@apache.org", "time": "Tue Nov 10 17:54:09 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Nov 10 02:54:09 2020 -0700" }, "message": "[Bouncy Castle] include bc into pulsar-client fix docs (#8491)\n\n### Motivation\r\nThe docs of bc need an update after merge PR #7453, also we could include bc in the pulsar client to avoid reference it in other modules.\r\n\r\n### Modifications\r\n\r\n- fix the docs after fix PR 7453;\r\n- make pulsar client include bc module; avoid other modules to include bc.\r\n- fix the pulsar-function bc jar issue.\r\n\r\n### Verifying this change\r\nall the tests passed.\r\n" }, { "commit": "723ab991f8cf755e9274a59fefb54489358e106a", "tree": "177a4f30f15423fec94297c537679561dbae6c1e", "parents": [ "f956bd87ff58866d3aaee2b65698c8d0a199c4bb" ], "author": { "name": "Enrico Olivelli", "email": "eolivelli@gmail.com", "time": "Mon Nov 09 09:35:54 2020 +0100" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Nov 09 16:35:54 2020 +0800" }, "message": "Update deps, allow to run tests with forkCount\u003d1 (#8465)\n\n\r\n# Motivation\r\nIn current master you cannot run the tests with \"forkCount\u003d1\", this is very annoying as by default we are running all of the tests in parallel.\r\nThis change upgrades a few testing dependencies and fixes a problem with PowerMock + Testng + Log4j2 + forkCount\u003d1\r\n\r\n# Modifications\r\nUpgrade TestNG\r\nUpgrade PowerMock\r\nUpgrade Mockito\r\nVerifying this change\r\nAll tests should pass\r\n\r\nThis change is a trivial rework / code cleanup without any test coverage.\r\n\r\n\r\n* Update deps, allow to run tests with forkCount\u003d1\r\n\r\n* revert log4j2\r\n\r\n* fix build\r\n\r\n* revert javaassist\r\n\r\n* revert surefire\r\n\r\n* use https for TestNG DTDs\r\n\r\n* remove SnakeYAML\r\n\r\nCo-authored-by: Enrico Olivelli \u003ceolivelli@apache.org\u003e" }, { "commit": "f956bd87ff58866d3aaee2b65698c8d0a199c4bb", "tree": "f67a96a4684410abb4cb6c476321bdd522feca7e", "parents": [ "718b60c18fe2f0f66cf2d1e48aa35e07ce2473fd" ], "author": { "name": "ran", "email": "gaoran_10@126.com", "time": "Wed Nov 04 08:46:36 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Nov 04 08:46:36 2020 +0800" }, "message": "[Tiered Storage] Support Azure BlobStore offload configuration (#8436)\n\nFix https://github.com/streamnative/pulsar/issues/1606\r\n\r\n### Motivation\r\n\r\nSupport Azure BlobStore offload configuration. \r\n\r\n### Modifications\r\n\r\nThe new tiered-storage configuration was introduced in the offload refinement.\r\nAdd new universal configurations in `OffloadPolicies`" }, { "commit": "718b60c18fe2f0f66cf2d1e48aa35e07ce2473fd", "tree": "40574db27be11dccd621f6195139292d51ada6f4", "parents": [ "5137b3f56a12a479185f5572f344e41d61c0943e" ], "author": { "name": "Masahiro Sakamoto", "email": "massakam@yahoo-corp.jp", "time": "Mon Nov 02 09:38:07 2020 +0900" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Nov 02 08:38:07 2020 +0800" }, "message": "Upgrade jetty to 9.4.33.v20201020 (#8413)\n\nJetty versions 9.4.32.v20200930 and earlier have a security vulnerability, so upgraded to the latest stable version.\r\nhttps://cve.mitre.org/cgi-bin/cvename.cgi?name\u003dCVE-2020-27216" }, { "commit": "5137b3f56a12a479185f5572f344e41d61c0943e", "tree": "73f9ca4f51f712dd25cacae23eae13dda6915b56", "parents": [ "e8ba4499988e55d79d210b117a34310c29c57844" ], "author": { "name": "Enrico Olivelli", "email": "eolivelli@gmail.com", "time": "Fri Oct 30 13:03:28 2020 +0100" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri Oct 30 20:03:28 2020 +0800" }, "message": "Upgrade Apache BookKeeper Client to 4.11.1 (#8270)\n\nMotivation\r\nUpgrade Apache BookKeeper client to version 4.11.1 and RocksDB to 6.10.2 (needed by Bookie)\r\n\r\nModifications\r\nUpgrade Apache BookKeeper client, fix a few build errors, due to the introduction of BookieServiceInfo structure (see BP-38).\r\n\r\nVerifying this change\r\nThis change is already covered by existing tests\r\n\r\n* Upgrade Apache BookKeeper to 4.11.1\r\n\r\n* fix build\r\n\r\n* fix LICENSE files\r\n\r\n* Use BK 4.11.1\r\n\r\n* Upgrade RocksDB to 6.10.2\r\n\r\n* Fix license and upgrade maven assembly plugin\r\n\r\n* update license\r\n\r\n* restore bouncy castle license\r\n\r\n* fix licenses\r\n\r\n* Exclude BouncyCastle inherited from BK\r\n\r\nCo-authored-by: Enrico Olivelli \u003cenrico.olivelli@diennea.com\u003e\r\nCo-authored-by: Enrico Olivelli \u003ceolivelli@apache.org\u003e" }, { "commit": "e8ba4499988e55d79d210b117a34310c29c57844", "tree": "4bd15db0889569a82d11fdc3139e38212e121062", "parents": [ "1abf91a5fcaea0b51fe31aafb355a6e79b28a18a" ], "author": { "name": "Enrico Olivelli", "email": "eolivelli@gmail.com", "time": "Thu Oct 29 08:24:07 2020 +0100" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Oct 29 15:24:07 2020 +0800" }, "message": "Allow building Apache Pulsar on JDK15+ - upgrade Maven Assembly Plugin (#8360)\n\nMotivation\r\nCurrently Pulsar does not build on JDK15\r\n\r\nModifications\r\nupdate Maven Assembly plugin\r\nmove maven-git-commit-id plugin execution only inside Pulsar Common (in order to speed up the build)\r\nupgrading the Maven Assembly Plugin resulted in a different output for the \"binaries\", I had to update license files\r\nforced version of Jersey to 2.31 in \"Presto\" distribution (otherwise the license check failed, because it does not handle different versions between main pulsar binaries and presto distribution inside lib/presto/lib, and this makes sense to me)\r\nVerifying this change\r\nThis change is already covered by existing tests\r\n\r\n\r\n* Allow to build Pulsar on JDK14+\r\n- update Apache Maven Assembly Plugin\r\n- use explicit import for Record class (prevent clash with java.lang.Record)\r\n\r\n* revert Apache pom update\r\n\r\n* fix\r\n\r\n* Fix presto distribution - due to maven assembly plugin upgrade\r\n\r\n* fix licenses\r\n\r\n* Fix kafka clients\r\n\r\n* fix LICENSE\r\n\r\nCo-authored-by: Enrico Olivelli \u003cenrico.olivelli@diennea.com\u003e\r\nCo-authored-by: Enrico Olivelli \u003ceolivelli@apache.org\u003e" }, { "commit": "1abf91a5fcaea0b51fe31aafb355a6e79b28a18a", "tree": "dc6c8e1c45bed18990251d8447fc880f3c28929c", "parents": [ "4a84de646f8d43dca675b379d6d889e084876e19" ], "author": { "name": "ran", "email": "gaoran_10@126.com", "time": "Wed Oct 28 16:53:31 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Oct 28 16:53:31 2020 +0800" }, "message": "[Offload] Make the field name in `OffloadPolicies` match with config file (#8310)\n\nFixes #8220 \r\n\r\n### Motivation\r\n\r\nCurrently, the fields\u0027 values couldn\u0027t be set properly by the Pulsar broker config file(`broker.conf` or `standalone.conf`). \r\n\r\n### Modifications\r\n\r\nchanged fields in `OffloadPolicies`\r\n\r\n1. managedLedgerOffloadAutoTriggerSizeThresholdBytes\r\n2. managedLedgerOffloadDeletionLagMs\r\n" }, { "commit": "4a84de646f8d43dca675b379d6d889e084876e19", "tree": "d4af68564b9a976e88910476be5d812b77ec2f1b", "parents": [ "b10fc0ad277300ff0ac681983ff2548c60355dab" ], "author": { "name": "Yunze Xu", "email": "xyzinfernity@163.com", "time": "Tue Oct 27 11:34:31 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Oct 27 11:34:31 2020 +0800" }, "message": "Delete associated ledgers before deleting cluster metadata (#8244)\n\n### Motivation\r\n\r\n#8169 introduced a command tool to delete a cluster\u0027s metadata from ZK. This PR intends to delete the cluster\u0027s ledgers from BK.\r\n\r\n### Modifications\r\n\r\n- Retrieve ledger ids from related ZK nodes\r\n- Add an optional argument to specify BK metadata service URI, then delete these ledgers if it\u0027s specified" }, { "commit": "b10fc0ad277300ff0ac681983ff2548c60355dab", "tree": "6cfee95f3d5318dd1955016b3db8c33225105f1f", "parents": [ "0fe695100f31721cfb5a2a1587ae75627ffda94c" ], "author": { "name": "Jia Zhai", "email": "zhaijia@apache.org", "time": "Fri Oct 23 14:36:13 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri Oct 23 14:36:13 2020 +0800" }, "message": "Remove bouncy castle shaded module to avoid bring error of verifySingleJar (#7453)\n\n### Motivation\r\n\r\nshade bouncy castle will cause some signature errors, this PR tries to remove the bouncy castle shaded module.\r\n\r\nHere is the related error stack:\r\n```\r\n10:01:34.257 [pulsar-client-io-33-1] ERROR org.apache.pulsar.client.impl.ConsumerImpl - MessageCryptoBc may not included in the jar. e:\r\njava.lang.SecurityException: JCE cannot authenticate the provider BC\r\n\tat javax.crypto.Cipher.getInstance(Cipher.java:657) ~[?:1.8.0_121]\r\n\tat javax.crypto.Cipher.getInstance(Cipher.java:596) ~[?:1.8.0_121]\r\n\tat org.apache.pulsar.client.impl.crypto.MessageCryptoBc.\u003cinit\u003e(MessageCryptoBc.java:147) ~[classes/:?]\r\n\tat org.apache.pulsar.client.impl.ConsumerImpl.\u003cinit\u003e(ConsumerImpl.java:270) ~[classes/:?]\r\n\tat org.apache.pulsar.client.impl.ConsumerImpl.newConsumerImpl(ConsumerImpl.java:209) ~[classes/:?]\r\n\tat org.apache.pulsar.client.impl.PulsarClientImpl.lambda$doSingleTopicSubscribeAsync$5(PulsarClientImpl.java:364) ~[classes/:?]\r\n\tat java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:656) ~[?:1.8.0_131]\r\n\tat java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) ~[?:1.8.0_131]\r\n...\r\n\r\nCaused by: java.util.jar.JarException: file:/Users/jia/.m2/repository/org/apache/pulsar/bouncy-castle-bc-shaded/2.7.0-SNAPSHOT/bouncy-castle-bc-shaded-2.7.0-SNAPSHOT.jar has unsigned entries - org/bouncycastle/cert/AttributeCertificateHolder.class\r\n\tat javax.crypto.JarVerifier.verifySingleJar(JarVerifier.java:500) ~[?:1.8.0_121]\r\n\tat javax.crypto.JarVerifier.verifyJars(JarVerifier.java:361) ~[?:1.8.0_121]\r\n\tat javax.crypto.JarVerifier.verify(JarVerifier.java:289) ~[?:1.8.0_121]\r\n\tat javax.crypto.JceSecurity.verifyProviderJar(JceSecurity.java:159) ~[?:1.8.0_121]\r\n\tat javax.crypto.JceSecurity.getVerificationResult(JceSecurity.java:185) ~[?:1.8.0_121]\r\n\tat javax.crypto.Cipher.getInstance(Cipher.java:653) ~[?:1.8.0_121]\r\n```\r\n\r\n### Modifications\r\n\r\n- Remove bouncy castle shaded module, avoid package bouncy castle into a dependency jar.\r\n- enhance test case to identify this error.\r\n\r\n### Verifying this change\r\n\r\nut passed.\r\n\r\n\r\n* remove dep of bc-shaded from other module\r\n\r\n* remove bc-shaded module\r\n\r\n* enhance testECDSAEncryption and testRSAEncryption to cover error case\r\n\r\n* fix license check\r\n\r\n* remove bc-shaded module\r\n\r\n* build a jar in jar to avoid break bc signature\r\n\r\n* use new bc dependency by classifier in maven\r\n\r\n* build pulsar-all docker image instead of pull from dockerhub in integration tests\r\n\r\n* remove nar\r\n\r\n* fix licence, fix error brings in #7640\r\n\r\n* add bc when broker/client is referenced in pom\r\n\r\n* add missing bc reference in pom\r\n\r\n* change ci back to not build docker image" }, { "commit": "0fe695100f31721cfb5a2a1587ae75627ffda94c", "tree": "8a1a73a2d6a1456ae152d91ff68cab1f09e6d6a8", "parents": [ "66fe1e14f6d42743a2e2240269c368847a619952" ], "author": { "name": "feynmanlin", "email": "315157973@qq.com", "time": "Thu Oct 22 00:57:57 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Oct 22 00:57:57 2020 +0800" }, "message": "Support exclude the message when reset cursor by message ID (#8306)\n\nFixes #8259\r\n### Motivation\r\nCurrently, when reset the cursor to a position, the broker will set the mark delete position to the previous position of the reset position. For some usecase, we don\u0027t want to consume the reset position again, so it\u0027s better to provide a way to reset the cursor to a specific position and exclude this position. So that the consumers under the subscription can start consume messages from the next position of the reset position.\r\n\r\n### Modifications\r\nAdd a new API to exclude the message when reset cursor by message ID\r\n\r\n### Verifying this change\r\nSimpleProducerConsumerTest#testResetPosition" }, { "commit": "66fe1e14f6d42743a2e2240269c368847a619952", "tree": "0e25668b27c0b3c670b69bb5a882d3ad55b9f7aa", "parents": [ "26589491d13641a167ee3cceb65b7fec8eb37e9c" ], "author": { "name": "David Kjerrumgaard", "email": "35466513+david-streamlio@users.noreply.github.com", "time": "Sun Oct 18 18:56:24 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Oct 19 09:56:24 2020 +0800" }, "message": "Refactored JCloud Tiered Storage (#6335)\n\nMotivation\r\n\r\nIn order to facilitate the support of additional JClouds-supported providers, we first needed to clean up the existing code, as there were a lot of if/then/else constructs throughout the code that were based on the assumption that we either supported AWS S3 or Google Cloud Storage. I didn\u0027t want to keep adding else if\u0027s to these code blocks for every new provider we add, so I decided to refactor the code to make it a bit cleaner\r\n\r\nModifications\r\n\r\nin addition to being home for most of the aforementioned if/then/else blocks, the BlobStoreManagedLedgerOffloader class had multiple responsibilities in addition to providing an implementation for the LedgerOffloader interface. My goal was to simplify this class such that its only responsibility was to implement the LedgerOffloader interface.\r\n\r\nThe other major change was the addition of the JCloudBlobStoreProvider enum, which implements 3 interfaces that allow for it to handle the provider specific logic for things such as acquiring the credentials, validating the configuration, and creating a provider-specific instance of BlobStore.\r\n\r\nResult\r\n\r\nAfter this change, we will be able to easily add support for additional JClouds-supported providers by simply adding new elements to the JCloudBlobStoreProvider Enums since the other logic has been isolated and is not vendor specific.\r\n\r\nSee #2865 for more details\r\n\r\n* Refactored JCloud Tiered Storage\r\n\r\n* Refactored JCloud Tiered Storage\r\n\r\n* Added missing import statements\r\n\r\n* Refactored JCloud Tiered Storage\r\n\r\n* Refactored JCloud Tiered Storage\r\n\r\n* Added missing import statements\r\n\r\n* Refactored JCloud Tiered Storage\r\n\r\n* Refactored JCloud Tiered Storage\r\n\r\n* Added missing import statements\r\n\r\n* fix test\r\n\r\n* add test logs\r\n\r\n* fix logs\r\n\r\n* fix test\r\n\r\n* fix\r\n\r\n* fix\r\n\r\n* fix broker log\r\n\r\n* fix configuration\r\n\r\n* fix\r\n\r\n* fix\r\n\r\n* fix\r\n\r\n* fix get BlobStore\r\n\r\n* repair test presto query tiered storage data\r\n\r\n* fix test\r\n\r\n* fix test\r\n\r\n* fix test TestPrestoQueryTieredStorage\r\n\r\n* fix\r\n\r\n* fix\r\n\r\nCo-authored-by: Sijie Guo \u003csijie@apache.org\u003e\r\nCo-authored-by: gaoran10 \u003cgaoran_10@126.com\u003e\r\nCo-authored-by: xiaolong.ran \u003crxl@apache.org\u003e" }, { "commit": "26589491d13641a167ee3cceb65b7fec8eb37e9c", "tree": "188dfb014bf7443be606fc5f59959d7619163f18", "parents": [ "3459657ebfb2855ba7a3265d8973d178d7bded59" ], "author": { "name": "Sanjeev Kulkarni", "email": "sanjeevrk@gmail.com", "time": "Wed Oct 07 13:23:51 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Oct 07 13:23:51 2020 -0700" }, "message": "Upgrade Jcommander to 1.78 (#8206)\n\n* Upgrade Jcommander to 1.80\r\n\r\n* Fix build\r\n\r\n* 1.78 is the stable version\r\n\r\n* Fix test\r\n\r\nCo-authored-by: Sanjeev Kulkarni \u003csanjeevk@splunk.com\u003e" }, { "commit": "3459657ebfb2855ba7a3265d8973d178d7bded59", "tree": "4d43fe9c1e2e92c1b9da462e701f64d8b63c6993", "parents": [ "31c31ab28e89eb3a165f4c4556d05ec782369e91" ], "author": { "name": "Boyang Jerry Peng", "email": "jerry.boyang.peng@gmail.com", "time": "Wed Sep 23 14:52:01 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Sep 23 14:52:01 2020 -0700" }, "message": "Fix pulsar functions threaded integration tests (#8118)\n\nCo-authored-by: Jerry Peng \u003cjerryp@splunk.com\u003e" }, { "commit": "31c31ab28e89eb3a165f4c4556d05ec782369e91", "tree": "9b31cc892d0c04d754df249d2f79dcedd1dad4aa", "parents": [ "d98eeb0835af7720853c0e4f1670973d25580b7a" ], "author": { "name": "Yong Zhang", "email": "zhangyong1025.zy@gmail.com", "time": "Wed Sep 16 21:39:56 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Sep 16 21:39:56 2020 +0800" }, "message": "Cancel retry if the error is autheticate failed (#8058)\n\n---\r\n\r\nFixes #7929\r\n\r\n*Motivation*\r\n\r\nWe shouldn\u0027t retry to connect to the server if the client has authenticate error." }, { "commit": "d98eeb0835af7720853c0e4f1670973d25580b7a", "tree": "3286cc2a99aece22fce91e84efffb83373c29a88", "parents": [ "992bdd140bc2fd264770627772247411e1201be3" ], "author": { "name": "冉小龙", "email": "rxl@apache.org", "time": "Fri Sep 11 17:31:36 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri Sep 11 17:31:36 2020 +0800" }, "message": "Fix protobuf version to 3.11.4 (#8028)\n\n* Fix protobuf version to 3.11.4\r\n\r\nSigned-off-by: xiaolong.ran \u003crxl@apache.org\u003e\r\n\r\n* fix ci error\r\n\r\nSigned-off-by: xiaolong.ran \u003crxl@apache.org\u003e" }, { "commit": "992bdd140bc2fd264770627772247411e1201be3", "tree": "dd9945552cac3c0bce5fcff9dee650128678705f", "parents": [ "005abd96341910b6d90e01bf476e2247a8255584" ], "author": { "name": "冉小龙", "email": "rxl@apache.org", "time": "Fri Sep 11 17:31:21 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri Sep 11 17:31:21 2020 +0800" }, "message": "Upgrade jetty-util version to 9.4.31 (#8035)\n\nSigned-off-by: xiaolong.ran \u003crxl@apache.org\u003e" }, { "commit": "005abd96341910b6d90e01bf476e2247a8255584", "tree": "1279868f4bbc7125807502a23c9d1b26375345e5", "parents": [ "b19ea5132084b67b021d9ec8d093585e3ad8f2e6" ], "author": { "name": "Yong Zhang", "email": "zhangyong1025.zy@gmail.com", "time": "Tue Sep 08 21:24:58 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Sep 08 21:24:58 2020 +0800" }, "message": "Remove python2 from the pulsar images build (#7936)\n\n\r\nThe pulsar docker and pulsar standalone docker image build failed by:\r\n```\r\nProcessing ./pulsar-client/pulsar_client-2.6.0-cp27-cp27mu-manylinux1_x86_64.whl\r\n2020-08-25T02:23:28.9567844Z [INFO] Collecting fastavro\r\n2020-08-25T02:23:29.0080316Z [INFO] Downloading fastavro-1.0.0.tar.gz (658 kB)\r\n2020-08-25T02:23:29.3108074Z [INFO] ERROR: Command errored out with exit status 1:\r\n2020-08-25T02:23:29.3109489Z [INFO] command: /usr/bin/python2.7 -c \u0027import sys, setuptools, tokenize; sys.argv[0] \u003d \u0027\"\u0027\"\u0027/tmp/pip-install-jvZueR/fastavro/setup.py\u0027\"\u0027\"\u0027; __file__\u003d\u0027\"\u0027\"\u0027/tmp/pip-install-jvZueR/fastavro/setup.py\u0027\"\u0027\"\u0027;f\u003dgetattr(tokenize, \u0027\"\u0027\"\u0027open\u0027\"\u0027\"\u0027, open)(__file__);code\u003df.read().replace(\u0027\"\u0027\"\u0027\\r\\n\u0027\"\u0027\"\u0027, \u0027\"\u0027\"\u0027\\n\u0027\"\u0027\"\u0027);f.close();exec(compile(code, __file__, \u0027\"\u0027\"\u0027exec\u0027\"\u0027\"\u0027))\u0027 egg_info --egg-base /tmp/pip-pip-egg-info-iH1mMy\r\n2020-08-25T02:23:29.3110061Z [INFO] cwd: /tmp/pip-install-jvZueR/fastavro/\r\n2020-08-25T02:23:29.3110303Z [INFO] Complete output (5 lines):\r\n2020-08-25T02:23:29.3110520Z [INFO] Traceback (most recent call last):\r\n2020-08-25T02:23:29.3110741Z [INFO] File \"\u003cstring\u003e\", line 1, in \u003cmodule\u003e\r\n2020-08-25T02:23:29.3111190Z [INFO] File \"/tmp/pip-install-jvZueR/fastavro/setup.py\", line 58, in \u003cmodule\u003e\r\n2020-08-25T02:23:29.3111437Z [INFO] if sys.implementation.name !\u003d \"pypy\":\r\n2020-08-25T02:23:29.3111886Z [INFO] AttributeError: \u0027module\u0027 object has no attribute \u0027implementation\u0027\r\n```\r\n\r\nI remove the python2.7 and using the python3 to build images.\r\n\r\n* Remove python2 in images\r\n\r\n* Remove python2 stuff\r\n\r\n* Update the default python version" }, { "commit": "b19ea5132084b67b021d9ec8d093585e3ad8f2e6", "tree": "15cb62bd9c8085e3affa9e278c9903136fe26602", "parents": [ "e46434604407033cec51435eaa27f9769b72fda6" ], "author": { "name": "冉小龙", "email": "rxl@apache.org", "time": "Tue Sep 08 16:05:39 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Sep 08 16:05:39 2020 +0800" }, "message": "Exclude vertx from bookkeeper-http package (#7997)\n\nSigned-off-by: xiaolong.ran \u003crxl@apache.org\u003e\r\n\r\n### Motivation\r\n\r\n```\r\n$ mvn dependency:tree|grep vertx\r\n```\r\n\r\nOutput:\r\n```\r\n[INFO] +- org.apache.bookkeeper.http:vertx-http-server:jar:4.10.0:compile\r\n[INFO] +- io.vertx:vertx-core:jar:3.5.3:compile\r\n[INFO] +- io.vertx:vertx-web:jar:3.5.3:compile\r\n[INFO] | +- io.vertx:vertx-auth-common:jar:3.5.3:compile\r\n[INFO] | \\- io.vertx:vertx-bridge-common:jar:3.5.3:compile\r\n[INFO] | +- org.apache.bookkeeper.http:vertx-http-server:jar:4.10.0:provided\r\n[INFO] | +- io.vertx:vertx-core:jar:3.5.3:provided\r\n[INFO] | \\- io.vertx:vertx-web:jar:3.5.3:provided\r\n[INFO] | +- io.vertx:vertx-auth-common:jar:3.5.3:provided\r\n[INFO] | \\- io.vertx:vertx-bridge-common:jar:3.5.3:provided\r\n```\r\n\r\n### Modifications\r\n\r\n- exclude `vertx` from bookkeeper-http package and include vertx of `3.5.3` to `vertx-http-server`\r\n" }, { "commit": "e46434604407033cec51435eaa27f9769b72fda6", "tree": "5e1788325cd46ef7e4c02757849e123a9345e1d5", "parents": [ "5c8a5b9deca865e11587711322965a097e567ec5" ], "author": { "name": "冉小龙", "email": "rxl@apache.org", "time": "Tue Sep 08 09:05:23 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Sep 08 09:05:23 2020 +0800" }, "message": "[Security] Upgrade the snakeyaml verion to 1.26 (#7994)\n\nFixes #7928\r\n\r\n### Motivation\r\n\r\nAs https://nvd.nist.gov/vuln/detail/CVE-2017-18640 said, the `snakeyaml` \u003c 1.26\r\n\r\n### Modifications\r\n\r\nIn `pulsar-functions` model:\r\n\r\n- The `snakeyaml` 1.19 appears to be included from dependency on org.apache.pulsar:pulsar-functions-secrets:jar:2.6.1 based on included dependency of io.kubernetes:client-java-api:jar:2.0.0:compile Fixed in 9.0.2\r\n\r\n- The `snakeyaml` 1.16 appears to be included from the dependency on org.apache.pulsar:pulsar-functions-instance:jar:2.6.1 based on io.prometheus.jmx:collector:jar:0.12.0 Fixed in 0.13.0\r\n\r\n- The 1.17 org.apache.pulsar.tests:integration:test-jar:tests:2.6.1:test depends on org.elasticsearch.client:elasticsearch-rest-high-level-client:jar:6.3.2:test Fixed in elasticsearch \u003e\u003d 7.7.1 (7.9.1 current)\r\n\r\n" }, { "commit": "5c8a5b9deca865e11587711322965a097e567ec5", "tree": "d600aaa303363d4833ee368831680f0b284b69bf", "parents": [ "ad3d45ae3ae1439cff325ab5156fc52a2c54e80d" ], "author": { "name": "jianyun", "email": "yihy8023@gmail.com", "time": "Fri Aug 28 21:50:32 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri Aug 28 21:50:32 2020 +0800" }, "message": "add java8 date and time type to pulsar\u0027s primitive schemas (#7874)\n\n### Motivation\r\n\r\n*Compatible with flink 1.11 need to use java8 date api in pulsar\u0027s primitive schemas.*\r\n\r\n### Modifications\r\n\r\n*Add Instant, LocalDate, LocalTime, LocalDateTime to pulsar\u0027s primitive schemas*\r\n\r\n### Verifying this change\r\n\r\nAdd Instant, LocalDate, LocalTime, LocalDateTime types to the Schema type test" }, { "commit": "ad3d45ae3ae1439cff325ab5156fc52a2c54e80d", "tree": "43df5d97b0c0ec36c694ecfacffcf67d6cd25286", "parents": [ "62afa2cefaef2c604b964a36a448cdfebf5a10ef" ], "author": { "name": "冉小龙", "email": "rxl@apache.org", "time": "Fri Aug 21 21:47:01 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri Aug 21 21:47:01 2020 +0800" }, "message": "[Python Build] Add python-dev to pulsar standalone docker image (#7871)\n\nMotivation\r\nFollow #7857 In the pulsar standalone Dockerfile, we also need to do the same operation\r\n\r\nModifications\r\nAdd python2.7-dev to pulsar standalone docker image" }, { "commit": "62afa2cefaef2c604b964a36a448cdfebf5a10ef", "tree": "fe5519784ca1666700c674a6b3b4ff41886116a8", "parents": [ "a4b1c945c6e30890baf288db3ec18ed920af1eb7" ], "author": { "name": "Masahiro Sakamoto", "email": "massakam@yahoo-corp.jp", "time": "Fri Aug 21 00:04:59 2020 +0900" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Aug 20 23:04:59 2020 +0800" }, "message": "Add python-dev to pulsar docker image (#7857)\n\n### Motivation\r\n\r\nRecently, building Pulsar Docker image in CI jobs has continued to fail. It seems that the header file \"Python.h\" does not exist.\r\n```\r\n[INFO] building \u0027fastavro._read\u0027 extension\r\n[INFO] creating build/temp.linux-x86_64-2.7\r\n[INFO] creating build/temp.linux-x86_64-2.7/fastavro\r\n[INFO] x86_64-linux-gnu-gcc -pthread -DNDEBUG -g -fwrapv -O2 -Wall -Wstrict-prototypes -fno-strict-aliasing -Wdate-time -D_FORTIFY_SOURCE\u003d2 -g -fdebug-prefix-map\u003d/build/python2.7-2.7.16\u003d. -fstack-protector-strong -Wformat -Werror\u003dformat-security -fPIC -I/usr/include/python2.7 -c fastavro/_read.c -o build/temp.linux-x86_64-2.7/fastavro/_read.o\r\n[INFO] fastavro/_read.c:4:10: fatal error: Python.h: No such file or directory\r\n[INFO] #include \"Python.h\"\r\n[INFO] ^~~~~~~~~~\r\n[INFO] compilation terminated.\r\n[INFO] error: command \u0027x86_64-linux-gnu-gcc\u0027 failed with exit status 1\r\n[INFO] ----------------------------------------\r\n[INFO]\r\n[INFO] ERROR: Failed building wheel for fastavro\r\n```\r\n\r\n### Modifications\r\n\r\nI\u0027m not sure why the build has recently failed, but added `python2.7-dev` and `python3.7-dev` to the Docker image." }, { "commit": "a4b1c945c6e30890baf288db3ec18ed920af1eb7", "tree": "67ac86073333603c7e9c65af52d9e8ab761366cb", "parents": [ "4b7abc133064db24ee80d7211ff55e93b3305e30" ], "author": { "name": "冉小龙", "email": "rxl@apache.org", "time": "Fri Aug 14 10:29:48 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri Aug 14 10:29:48 2020 +0800" }, "message": "Fix security vulnerabilities of Pulsar (#7801)\n\n### Motivation\r\n\r\nBased on the scan results of `Black Duck`, we found that there are security vulnerabilities in the components currently used by pulsar, some are directly referenced by pulsar, and some are indirectly referenced by the pulsar." }, { "commit": "4b7abc133064db24ee80d7211ff55e93b3305e30", "tree": "d166ad86d120ce7cacb0ceda90a9c4cc15660d9f", "parents": [ "7eb61084160cbe68bfb23e61a23d65db02b02f5f" ], "author": { "name": "ran", "email": "gaoran_10@126.com", "time": "Wed Aug 05 17:07:52 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Aug 05 17:07:52 2020 +0800" }, "message": "[Pulsar SQL] Make Pulsar SQL get correct offload configurations (#7701)\n\n### Motivation\r\n\r\nCurrently, Pulsar SQL can\u0027t get the correct offload configurations.\r\n\r\n### Modifications\r\n\r\nMake Pulsar SQL get the complete offload configurations.\r\n\r\n### Verifying this change\r\n\r\nAdd a new integration test." }, { "commit": "7eb61084160cbe68bfb23e61a23d65db02b02f5f", "tree": "c73b7b98aaa3b7d37d43e0dc87e642597a819266", "parents": [ "8be4884392d362c1c26f834ec1bafae16d929f90" ], "author": { "name": "Yong Zhang", "email": "zhangyong1025.zy@gmail.com", "time": "Mon Aug 03 22:10:19 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Aug 03 22:10:19 2020 +0800" }, "message": "Fix the nondurable consumer can not specify the initial position (#7702)\n\nFixes #7619\r\n\r\nMotivation\r\n\r\nWhen using nondurable consumer to consumer message and specify the initial position\r\nfrom earliest, the consumer can not start consume from the earliest message." }, { "commit": "8be4884392d362c1c26f834ec1bafae16d929f90", "tree": "5c61314139b6d3215890525062ba4ada769501ee", "parents": [ "fce67287136e5c89789f2b3efe97f8c88d7f821a" ], "author": { "name": "lipenghui", "email": "penghui@apache.org", "time": "Tue Jul 28 23:49:42 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Jul 28 23:49:42 2020 +0800" }, "message": "Fix backward compatibility issues with batch index acknowledgment. (#7655)\n\n### Motivation\r\n\r\nFix backward compatibility issues with batch index acknowledgment.\r\n\r\n### Modifications\r\n\r\nDisable batch index acknowledgment by default at the consumer side." }, { "commit": "fce67287136e5c89789f2b3efe97f8c88d7f821a", "tree": "83004738af7f961470e7ee2e394c3e1a26dd6559", "parents": [ "9471f3eb7ef4b7ef7fb3a530012ec31a22ab96f6" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Mon Jul 27 09:36:39 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Jul 27 09:36:39 2020 -0700" }, "message": "Avoid dependency on Apache HTTP client for TLS hostname verifier (#7612) (#7664)\n\n" }, { "commit": "9471f3eb7ef4b7ef7fb3a530012ec31a22ab96f6", "tree": "25fbb2c4d15644845b47e4e07d9f18785145d816", "parents": [ "3d70ec95b2cc8411c0d545d581a5b3a84472a876" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Thu Jul 16 20:10:58 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Jul 16 20:10:58 2020 -0700" }, "message": "Update Jersey to 2.31 (#7515)\n\n* Update Jersey to 2.31\r\n\r\n* Update shade plugin to pick up bug fix\r\n\r\n* Updated license files\r\n\r\n* More license file fixes\r\n\r\n* Added missing license file\r\n\r\n* More license file fixes\r\n\r\n* Fixed shading config for pulsar-client-admin\r\n\r\n* wrong group name\r\n\r\n* Another typo" }, { "commit": "3d70ec95b2cc8411c0d545d581a5b3a84472a876", "tree": "e263992b04ec6a9dfbe93deab83bf408848be7f1", "parents": [ "0e6d8a8ecf19dafd0f6fbf62050d607450ba53f9" ], "author": { "name": "Varghese Cottagiri", "email": "varghese.cottagiri@zafin.com", "time": "Thu Jul 16 01:24:26 2020 -0400" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Jul 15 22:24:26 2020 -0700" }, "message": "#5922 - Update poms to use project.groupId instead of org.apache.pulsar where applicable (#7548)\n\n" }, { "commit": "0e6d8a8ecf19dafd0f6fbf62050d607450ba53f9", "tree": "556219dc7bd05aabd6039de4e9426fca66d03085", "parents": [ "166309ce77cd0f63b2aed8e46da04d09a4c9c248" ], "author": { "name": "Ali Ahmed", "email": "alahmed.se@gmail.com", "time": "Wed Jul 15 16:32:06 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Jul 15 16:32:06 2020 -0700" }, "message": "Add limited module set profile to the pom files (#7541)\n\n" }, { "commit": "166309ce77cd0f63b2aed8e46da04d09a4c9c248", "tree": "4f66782732f37d7e2757735ca5fac2d5b6766181", "parents": [ "4471d2ffe948cfcb4a070795a34f768cce8f37cf" ], "author": { "name": "Ali Ahmed", "email": "alahmed.se@gmail.com", "time": "Wed Jul 15 09:33:26 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Jul 15 09:33:26 2020 -0700" }, "message": "Add test group tags for functions and state integration tests (#7529)\n\nCo-authored-by: Ali Ahmed \u003calia@splunk.com\u003e" }, { "commit": "4471d2ffe948cfcb4a070795a34f768cce8f37cf", "tree": "733b67b427f612b4999a9251d2693d2ce5685e56", "parents": [ "6657e7f23ce23d5680e70a0630637e658ec44538" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Mon Jul 13 16:45:51 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Jul 13 16:45:51 2020 -0700" }, "message": "Update Jackson to 2.11.1 and ensure all dependencies are pinned (#7519)\n\n* Update Jackson to 2.11.1 and ensure all dependencies are pinned\r\n\r\n* Fixed license file\r\n\r\n* More license file fixes\r\n\r\n* Fixed passing annotation introspector which is now required" }, { "commit": "6657e7f23ce23d5680e70a0630637e658ec44538", "tree": "b0bda4522ef880bb7c6244d3dece8cba9227d124", "parents": [ "69272f202ef1f020ecc7e5c19e1558d49cb73472" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Mon Jun 29 22:44:44 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Jun 29 22:44:44 2020 -0700" }, "message": "Update Jetty to 9.4.29 (#7235)\n\n* Update Jetty to 9.4.29\r\n\r\n* Fixed test exception message expectation\r\n\r\n* Fixed test\r\n\r\n* Fixed difference in extracting exception message" }, { "commit": "69272f202ef1f020ecc7e5c19e1558d49cb73472", "tree": "6e5227e9e7d158383d11db10f0b9b8eff64572c5", "parents": [ "092ea1f5ec87781bdd770404e9c74b461012c4fd" ], "author": { "name": "Yuya Ebihara", "email": "ebyhry@gmail.com", "time": "Sun Jun 14 10:14:19 2020 +0900" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Sat Jun 13 18:14:19 2020 -0700" }, "message": "Upgrade Presto version to 332 (#7194)\n\n* Upgrade Presto version to 332\r\n\r\n* Update LICENSE file in pulsar-sql module\r\n\r\n* Wrap ClassLoaderSafeConnectorMetadata around PulsarMetadata\r\n\r\n* Update LICENSE file in pulsar-sql module" }, { "commit": "092ea1f5ec87781bdd770404e9c74b461012c4fd", "tree": "e76ea05d1acb4a863a051e344b6de09a406231a9", "parents": [ "c9c4b5b36e378158418e85ddf469b66313163362" ], "author": { "name": "lipenghui", "email": "penghui@apache.org", "time": "Thu Jun 11 16:30:26 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Jun 11 16:30:26 2020 +0800" }, "message": "Bumped version to 2.7.0-SNAPSHOT (#7233)\n\n* Bumped version to 2.7.0-SNAPSHOT" }, { "commit": "c9c4b5b36e378158418e85ddf469b66313163362", "tree": "3586e49eaa44aa77c01f888c8ff32537cb8d4890", "parents": [ "fcf36a87c3b9b52c251c1decd115d052daa60839" ], "author": { "name": "Sanjeev Kulkarni", "email": "sanjeevrk@gmail.com", "time": "Tue Jun 09 18:11:51 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Jun 09 18:11:51 2020 -0700" }, "message": "During Function update, cleanup should only happen for temp files that were generated (#7201)\n\n* Fix logic while updating functions. Cleanup should only happen for temp files that were generated\r\n\r\n* Fix integration tests\r\n\r\n* Fix test\r\n\r\n* Fix logic for parallelism \u003e 1\r\n\r\n* Fix test\r\n\r\n* Address comments\r\n\r\nCo-authored-by: Sanjeev Kulkarni \u003csanjeevk@splunk.com\u003e" }, { "commit": "fcf36a87c3b9b52c251c1decd115d052daa60839", "tree": "fb729e72d00f2388769d7fe2edb037f835afd8da", "parents": [ "80e7572bdc100842701a3cf5dbcf12b8e963dff2" ], "author": { "name": "wangjialing218", "email": "65590138+wangjialing218@users.noreply.github.com", "time": "Tue Jun 09 12:54:26 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Jun 08 21:54:26 2020 -0700" }, "message": "[Issue 7202] Upgrade commons-lang3 version to 3.6 (#7203)\n\n* [Upgrade commons-lang3 version to 3.6\r\n\r\n* Upgrade commons-lang3 version to 3.6\r\n\r\n* Upgrade commons-lang3 version to 3.6 in LICENSE\r\n\r\nCo-authored-by: wangjialing \u003cwangjialing@cmss.chinamobile.com\u003e" }, { "commit": "80e7572bdc100842701a3cf5dbcf12b8e963dff2", "tree": "92f865ae4fab0869aa7e7d88cd3380f7e4fbe2bd", "parents": [ "de9134b0460d992af74b08690f74c5a25a8d47ca" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Wed Jun 03 23:23:49 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Jun 04 14:23:49 2020 +0800" }, "message": "Use pure-java Air-Compressor instead of JNI based libraries (#5390)\n\n* Use pure-java Air-Compressor instead of JNI based libraries\r\n\r\n* Fixed license files\r\n\r\n* Fixed non-needed exclusion\r\n\r\n* Added compat tests with JNI implementations\r\n\r\n* Ensure direct buffer is used in the test\r\n\r\n* Ensure direct bytebuf for both compression and decompression test\r\n\r\nCo-authored-by: penghui \u003cpenghui@apache.org\u003e" }, { "commit": "de9134b0460d992af74b08690f74c5a25a8d47ca", "tree": "5e3c7f36c44c29dc67a4721881619bd1a02ec316", "parents": [ "b40796ee4dff7f7f0bc9d342b1328d9a51d9ee83" ], "author": { "name": "Fangbin Sun", "email": "sunfangbin@gmail.com", "time": "Tue Jun 02 15:54:04 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Jun 02 15:54:04 2020 +0800" }, "message": "Correct tokenSecretKey base64 inline description. (#6959)\n\n### Motivation\r\n\r\nFixes #6761\r\n\r\n### Modifications\r\n\r\nCorrect tokenSecretKey base64 inline description in documents (based master \u0026 version 2.5.1) and examples." }, { "commit": "b40796ee4dff7f7f0bc9d342b1328d9a51d9ee83", "tree": "bb910d55351c26272f4ff5704d5e8fde785a3d58", "parents": [ "0e0fae36779ae7738d22507c5bbd865d4a0bcf7d" ], "author": { "name": "Jia Zhai", "email": "zhaijia@apache.org", "time": "Sat May 30 05:39:40 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri May 29 14:39:40 2020 -0700" }, "message": "update asynchttpclient verison (#7087)\n\n* update asynchttpclient verison\r\n\r\n* add default config for new version of asynchttp\r\n\r\n* update license version\r\n\r\n* fix ut\r\n\r\n* add default config for asynchttp to avoid npe" }, { "commit": "0e0fae36779ae7738d22507c5bbd865d4a0bcf7d", "tree": "8d4306a493152c47c12ac5a77c01c9b55806ce26", "parents": [ "520cc3c9d0593b32232c02e41b1f01c5c461f5d3" ], "author": { "name": "dockerzhang", "email": "zhchao_beyond@outlook.com", "time": "Sat May 30 05:38:56 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri May 29 14:38:56 2020 -0700" }, "message": "add postgresql to supervisord for pulsar-standalone image (#7086)\n\n" }, { "commit": "520cc3c9d0593b32232c02e41b1f01c5c461f5d3", "tree": "8aa6f7efda372cb52a2db79297f379cf43d9f7ea", "parents": [ "95bf642fa9d7c9917f45b51e3e89e53e16e56ae5" ], "author": { "name": "Jacob Burroughs", "email": "maths22@gmail.com", "time": "Tue May 19 10:16:51 2020 -0500" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue May 19 23:16:51 2020 +0800" }, "message": "Add dynamodb streams source (#6874)\n\n### Motivation\r\n\r\nThe goal is to allow consuming dynamodb streams directly into pulsar\r\n\r\n### Modifications\r\n\r\nI created a new source for dynamo, which shares less code than ideal with the kinesis source, since the dynamodb kinesis client adapter supports KCL v1.x only, while, the kinesis source is using KCL v2.x. I also abstracted the aws credential management pieces into their own package.\r\n\r\n### Verifying this change\r\n\r\nCreate a dynamodb table with streams enabled. Configure this connector with the stream ARN and appropriate credentials. Create/update an entry in the table and ensure it is written to pulsar by the connector." }, { "commit": "95bf642fa9d7c9917f45b51e3e89e53e16e56ae5", "tree": "69bf01933bc8acf62b4c0d2c08a4a5cbf69a0ee3", "parents": [ "0e85a3cadb29e48da6ae77e025bf2945438416f7" ], "author": { "name": "Sergii Zhevzhyk", "email": "vzhikserg@users.noreply.github.com", "time": "Mon May 18 22:53:51 2020 +0200" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon May 18 13:53:51 2020 -0700" }, "message": "[Issue 5215,4601,5215][pulsar-io] Add jdbc sinks: postgres, mariadb, clickhouse (#6835)\n\nFixes #5215 #4601 #5215\r\n\r\n### Motivation\r\n\r\nRight now, the number of supported JDBC connectors is rather limited. There are a couple of open issues related to the missing connectors. \r\n\r\n### Modifications\r\n\r\nAs a base for this pull request, I took the [changes](https://github.com/apache/pulsar/pull/5624) from @huangdx0726 Unfortunately, I was not able to reach him to merge my changes to his branch, so I created a new one.\r\n\r\nThe main modification is a split of one JDBC module into a bunch of them. One module serves as a core and provides the main logic of the connector. Other modules are real connectors and add only an appropriate JDBC driver." }, { "commit": "0e85a3cadb29e48da6ae77e025bf2945438416f7", "tree": "2bf3d24b7729019055f0bc8b9a1cf2dceba5b96e", "parents": [ "040ae01e8d41e4bcb82d46179abba1a59f5be6ef" ], "author": { "name": "guangning", "email": "guangning@apache.org", "time": "Thu Apr 30 21:29:05 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Apr 30 21:29:05 2020 +0800" }, "message": "[Pulsar IO][Issue 5633]Support avro schema for debezium connector (#6034)\n\nFixes #5633 \r\n\r\n\r\n### Motivation\r\n\r\nCurrently, some users want to support Avro schema in debezium, so this pr supports this feature.\r\nFor Kafka\u0027s Avro schema, it depends on the Avro 1.8 version, but Avro version has just been upgraded to 1.9 in pulsar, so shade is needed to avoid finding `addProp` function\r\n\r\n### Modifications\r\n\r\n* Add a package `kafka-connect-avro-converter-shaded`\r\n* Add class KafkaSchema to converter Kafka\u0027s Avro schema to pulsar\u0027s schema\r\n\r\n### Verifying this change \r\n\r\nUnit test and integration tests\r\n" }, { "commit": "040ae01e8d41e4bcb82d46179abba1a59f5be6ef", "tree": "3fb6d4de51f42790f96c2eaa087f4f724f6e45e4", "parents": [ "ff2cd0aeb2964760e9ed54c5c595118cb036f7e5" ], "author": { "name": "Sergii Zhevzhyk", "email": "vzhikserg@users.noreply.github.com", "time": "Mon Apr 27 09:51:38 2020 +0200" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Apr 27 00:51:38 2020 -0700" }, "message": "[Grafana] Add tags to all grafana dashboards (#6770)\n\n" }, { "commit": "ff2cd0aeb2964760e9ed54c5c595118cb036f7e5", "tree": "c95233d6dd419dc038a039c23bda36165e6f2110", "parents": [ "460b552c2f42d59c4da0ec269eb43dc0dcb70763" ], "author": { "name": "Masahiro Sakamoto", "email": "massakam@yahoo-corp.jp", "time": "Sat Apr 18 02:31:02 2020 +0900" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri Apr 17 10:31:02 2020 -0700" }, "message": "Bump netty version to 4.1.48.Final (#6746)\n\n" }, { "commit": "460b552c2f42d59c4da0ec269eb43dc0dcb70763", "tree": "4d3605ef79e1e3b696644436f179b58ca6a69dbc", "parents": [ "c851fc8149e015aae4ef7c28fc7cb955164e40c8" ], "author": { "name": "Jia Zhai", "email": "zhaijia@apache.org", "time": "Thu Apr 16 14:50:17 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Apr 16 14:50:17 2020 +0800" }, "message": "[Issue #6711]: add audience verify in AuthenticationProviderToken (#6716)\n\nFixes #6711\r\n\r\n### Motivation\r\nUser like to be able to configure the JWT authentication provider to verify the audience on incoming tokens. I believe this will improve security because it would prevent a spoofer from reusing a token that was intended for another purpose (yet signed by the same issuer). [RFC 6749 section 4.1.3](https://tools.ietf.org/html/rfc7519#section-4.1.3) has some guidance on this. In my scenario, the token is an OAuth 2.0 token, and OAuth 2.0 makes extensive use of the audience claim ([ref](https://auth0.com/docs/tokens/guides/validate-access-tokens#check-additional-standard-claims)).\r\n\r\n1. a configurable audience claim name (e.g. `aud`).\r\n2. if audience isn\u0027t configured, do not validate the audience (for back-compatibility).\r\n3. if audience is configured, validate that the value is present in the token.\r\n\r\n### Modifications\r\n- Add the logic in AuthenticationProviderToken.\r\n- Add related tests.\r\n\r\n### Verifying this change\r\n- Ut passed\r\n" }, { "commit": "c851fc8149e015aae4ef7c28fc7cb955164e40c8", "tree": "181b4d180ccc6994a5f4f26c4b0ce7c366f609e3", "parents": [ "d6399a799f7ed53b1c9f6ce4aadbae5ca04824a1" ], "author": { "name": "lipenghui", "email": "penghui@apache.org", "time": "Sun Apr 12 01:58:06 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Sat Apr 11 10:58:06 2020 -0700" }, "message": "Add Joda time logical type conversion. (#6704)\n\n### Motivation\r\n\r\nAfter upgrade to Apache Avro 1.9.x, the default time conversion changed to JSR-310. For forwarding compatibility, we\u0027d better add the Joda time conversion.\r\n\r\nrelated to #5938 \r\n\r\n### Modifications\r\n\r\nAdd joda time conversions\r\n\r\n### Verifying this change\r\n\r\nNew integration test added" }, { "commit": "d6399a799f7ed53b1c9f6ce4aadbae5ca04824a1", "tree": "c975167af2e95c355acd7bd3620bfc3b080e6f89", "parents": [ "d93d6e4a80c1b5343a345e9257ea6bacb5ebb748" ], "author": { "name": "ran", "email": "gaoran_10@126.com", "time": "Sun Apr 05 08:33:42 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Sun Apr 05 08:33:42 2020 +0800" }, "message": "Fixed avro schema decode error in functions (#6662)\n\nFixes #5503 \r\nFrom #6445 \r\n\r\n# Motivation\r\nIn functions, it will encounter ```ClassCastException``` when using the Avro schema for topics.\r\n\r\n```\r\nException in thread \"main\" java.lang.ClassCastException: org.apache.pulsar.shade.org.apache.avro.generic.GenericData$Record cannot be cast to io.streamnative.KeyValueSchemaTest$Foo2\r\n\tat io.streamnative.KeyValueSchemaTest.testConsumerByPythonProduce(KeyValueSchemaTest.java:412)\r\n\tat io.streamnative.KeyValueSchemaTest.main(KeyValueSchemaTest.java:305)\r\n```\r\n\r\n# Modifications\r\nIn functions, when using Avro schema specific the ClassLoader for ReflectDatumReader.\r\n\r\nAdd integration test ```testAvroSchemaFunction``` in class ```PulsarFunctionsTest```." }, { "commit": "d93d6e4a80c1b5343a345e9257ea6bacb5ebb748", "tree": "e978faec3dd3a7df3524728dbc75e10e0ae0fbfe", "parents": [ "e84902c4c54ac41ea5dc8aa2cdde0282beb56f1f" ], "author": { "name": "guangning", "email": "guangning@apache.org", "time": "Tue Mar 31 20:58:29 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Mar 31 20:58:29 2020 +0800" }, "message": "[hotfix]Python function protobuf missing field and broker test failed (#6641)\n\n### Motivation\r\n\r\nAt present, in the test, we found that due to the addition of a field `forwardSourceMessageProperty` in the proto file of function, this field was lost in the proto file generated by python and go. Due to python parsing with the following code:\r\n\r\n\r\n```\r\njson_format.Parse(args.function_details, function_details)\r\n```\r\n\r\nthe following exception will be thrown. \r\n\r\n```\r\n2020-03-30T13:13:25.2339031Z 13:13:24.379 [pulsar-external-listener-20-1] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntime - Started process successfully\r\n2020-03-30T13:13:25.2339190Z Traceback (most recent call last):\r\n2020-03-30T13:13:25.2340782Z File \"/pulsar/instances/python-instance/python_instance_main.py\", line 211, in \u003cmodule\u003e\r\n2020-03-30T13:13:25.2340944Z main()\r\n2020-03-30T13:13:25.2342589Z File \"/pulsar/instances/python-instance/python_instance_main.py\", line 98, in main\r\n2020-03-30T13:13:25.2342744Z json_format.Parse(args.function_details, function_details)\r\n2020-03-30T13:13:25.2354119Z File \"/usr/local/lib/python2.7/dist-packages/google/protobuf/json_format.py\", line 430, in Parse\r\n2020-03-30T13:13:25.2354284Z return ParseDict(js, message, ignore_unknown_fields, descriptor_pool)\r\n2020-03-30T13:13:25.2354689Z File \"/usr/local/lib/python2.7/dist-packages/google/protobuf/json_format.py\", line 450, in ParseDict\r\n2020-03-30T13:13:25.2354882Z parser.ConvertMessage(js_dict, message)\r\n2020-03-30T13:13:25.2355386Z File \"/usr/local/lib/python2.7/dist-packages/google/protobuf/json_format.py\", line 481, in ConvertMessage\r\n2020-03-30T13:13:25.2355537Z self._ConvertFieldValuePair(value, message)\r\n2020-03-30T13:13:25.2356082Z File \"/usr/local/lib/python2.7/dist-packages/google/protobuf/json_format.py\", line 590, in _ConvertFieldValuePair\r\n2020-03-30T13:13:25.2356559Z raise ParseError(\u0027Failed to parse {0} field: {1}.\u0027.format(name, e))\r\n2020-03-30T13:13:25.2357199Z google.protobuf.json_format.ParseError: Failed to parse sink field: Message type \"proto.SinkSpec\" has no field named \"forwardSourceMessageProperty\".\r\n2020-03-30T13:13:25.2357634Z Available Fields(except extensions): [\u0027className\u0027, \u0027configs\u0027, \u0027typeClassName\u0027, \u0027topic\u0027, \u0027serDeClassName\u0027, \u0027builtin\u0027, \u0027schemaType\u0027].\r\n```\r\n\r\nThis pr is mainly to fix the proto file generated by python first. In order to make the test pass smoothly, I will gradually fix this problem in other languages in the next pull request.\r\n\r\n\r\n### Modifications\r\n\r\n* Enable build docker image to pulsar and pulsar-all.\r\n* Add new generated protobuf file for python\r\n* Disable go function integration test\r\n* Add sleep for method testGetPartitionedStatsInternal\r\n\r\n### Verifying this change\r\n\r\nThe integration process test passed https://github.com/AmateurEvents/pulsar/pull/22" }, { "commit": "e84902c4c54ac41ea5dc8aa2cdde0282beb56f1f", "tree": "e30874fbc146569a4f75b509712e241e5c7efde9", "parents": [ "adf38675ec52e038b14c408c35bddd50c0e7c841" ], "author": { "name": "Jia Zhai", "email": "zhaijia@apache.org", "time": "Sat Mar 28 18:34:57 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Sat Mar 28 03:34:57 2020 -0700" }, "message": "Support BouncyCastle FIPS provider (#6588)\n\n### Motivation\r\n\r\nTry to make user able to use both \"org.bouncycastle.jce.provider.BouncyCastleProvider\" and \"org.bouncycastle.jcajce.provider.BouncyCastleFipsProvider\".\r\n\r\nCurrent code, bouncycastle (bc) jars are used in both broker and client, and are tied strongly in both broker and client. We need to make it easy config. This change try to split bc and module that depends on it. Then user could freely include/exclude it.\r\n\r\n### Changes\r\n- build a shaded jar for bouncycastle non-fips version. other module depends on this module.\r\n- build nar for both fips and non-fips version of bouncycastle, user could able to load bouncycastle by these 2 nar.\r\n- split MessageCrypto out from client and made it an individual module. so client is able to exclude bouncycastle.\r\n- Add 2 test examples: 1, exclude bc-non-fips version, and include bc-fips version; 2, exclude bc-non-fips version and load bc-fips version by nar.\r\n\r\n" }, { "commit": "adf38675ec52e038b14c408c35bddd50c0e7c841", "tree": "9a681feb5416f551648e91629530c92f8ab62319", "parents": [ "d2bb50800c71edb1c25d77d5341533e227277831" ], "author": { "name": "Yang Yang", "email": "yyang@streamnative.io", "time": "Thu Mar 26 14:31:31 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Mar 25 23:31:31 2020 -0700" }, "message": "Do not apply env values to conf/pulsar_env.sh and conf/bkenv.sh implicitly when running apply-config-from-env.py. (#6579)\n\n" }, { "commit": "d2bb50800c71edb1c25d77d5341533e227277831", "tree": "60485a7e6ce8594e29fd0a4e77291e09d84cb62c", "parents": [ "c86b58ceb5d5260437506cee39e7902fdf6304aa" ], "author": { "name": "guangning", "email": "guangning@apache.org", "time": "Thu Mar 26 14:31:03 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Mar 25 23:31:03 2020 -0700" }, "message": "[docker]Docker standalone build error (#6586)\n\n* Fixed docker build package\r\n\r\n* Fixed docker build package" }, { "commit": "c86b58ceb5d5260437506cee39e7902fdf6304aa", "tree": "f8f1189dcd0cb32818ab06dc4aec512eef898639", "parents": [ "2f85d487f4d693c5f8df71e5be8d302b8a5a4215" ], "author": { "name": "lan", "email": "liangyuanpengem@163.com", "time": "Thu Mar 19 13:43:43 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Mar 18 22:43:43 2020 -0700" }, "message": "[Issue 6507][deployment]fix k8s config and env py (#6508)\n\n* fix k8s config and env py\r\n\r\n* fix BOOKIE_MEN parmater for k8s" }, { "commit": "2f85d487f4d693c5f8df71e5be8d302b8a5a4215", "tree": "73d21b947150bac7bfee60b45b5a87b8d6eb2f1b", "parents": [ "e9444a8d12ee59d0e9631e40c2a2b8e240756cf9" ], "author": { "name": "Yijie Shen", "email": "henry.yijieshen@gmail.com", "time": "Wed Mar 11 09:31:00 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Mar 10 18:31:00 2020 -0700" }, "message": "[Maven Cleanup] Remove managed-ledger and zk-utils test-jar dependencies when possible (#6513)\n\nCurrently, many modules depend on `managed-ledger-test.jar` just because they want to use MockBookkeeper and MockZookeeper. This made module dependencies hard to understand and track.\r\n\r\nThis PR introduces a new `testmocks` module and pulls all mocks from managed-ledger tests into the new module." }, { "commit": "e9444a8d12ee59d0e9631e40c2a2b8e240756cf9", "tree": "fe0cb87b990044463d21661284994383eea6518a", "parents": [ "0e8b1b35e0c3b0ad65f1f57484df5af7251e3892" ], "author": { "name": "Dzmitry Kazimirchyk", "email": "dzmitryk@users.noreply.github.com", "time": "Wed Feb 26 22:43:57 2020 -0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Feb 27 14:43:57 2020 +0800" }, "message": "Bump netty version to 4.1.45.Final (#6424)\n\nnetty 4.1.43 has a bug preventing it from using Linux native Epoll transport\r\n\r\nThis results in pulsar brokers failing over to NioEventLoopGroup even when running on Linux.\r\n\r\nThe bug is fixed in netty releases 4.1.45.Final" }, { "commit": "0e8b1b35e0c3b0ad65f1f57484df5af7251e3892", "tree": "5e6167fc3ca0b94035d3e9312457a15f7e3784a2", "parents": [ "5c13384c9fe877e9c787d04af210530d7a9b1dc2" ], "author": { "name": "Sergii Zhevzhyk", "email": "vzhikserg@users.noreply.github.com", "time": "Wed Feb 26 10:14:23 2020 +0100" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Wed Feb 26 02:14:23 2020 -0700" }, "message": "Cleanup pom files in the tests module (#6421)\n\n### Modifications\r\n\r\n- Removed dependencies on test libraries that were already imported in the parent pom file.\r\n\r\n- Removed groupId tags that are inherited from the parent pom file.\r\n\r\n" }, { "commit": "5c13384c9fe877e9c787d04af210530d7a9b1dc2", "tree": "6449c5884ff12ce4c9b9e2193dac82d6a85b9782", "parents": [ "e64cf1f1b2691338b096faa7cf5000e9ccb72538" ], "author": { "name": "Sergii Zhevzhyk", "email": "vzhikserg@users.noreply.github.com", "time": "Tue Feb 25 05:02:25 2020 +0100" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Feb 25 12:02:25 2020 +0800" }, "message": "Remove duplicated lombok annotations in the tests module (#6412)\n\n" }, { "commit": "e64cf1f1b2691338b096faa7cf5000e9ccb72538", "tree": "2c89a2ff9e72fe55d6f6d0a8b8a5e82272c5f11f", "parents": [ "a3b33d990a73dd57fbcd1982e1101e8bfede087d" ], "author": { "name": "Devin Bost", "email": "devinbost@users.noreply.github.com", "time": "Sat Feb 15 22:29:53 2020 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Sat Feb 15 21:29:53 2020 -0800" }, "message": "[Issue 4175] [pulsar-function-go] Create integration tests for Go Functions for production-readiness (#6104)\n\nThis PR is to provide integration tests that test execution of Go functions that are managed by the Java FunctionManager. This will allow us to test things like behavior during function timeouts, heartbeat failures, and other situations that can only be effectively tested in an integration test. \r\n\r\nMaster issue: #4175\r\nFixes issue: #6204 \r\n\r\n### Modifications\r\n\r\nWe must add Go to the integration testing logic. We must also build the Go dependencies into the test Dockerfile to ensure the Go binaries are available at runtime for the integration tests. " }, { "commit": "a3b33d990a73dd57fbcd1982e1101e8bfede087d", "tree": "6a5728a9e862b6efbf88e957913a1c1d28963200", "parents": [ "207290dfc006b6cffeb23ff37a30ea2ef7b203dd" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Sat Feb 15 05:04:26 2020 -0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Sat Feb 15 21:04:26 2020 +0800" }, "message": "Upgrade ZooKeeper to 3.5.7 (#6329)\n\nUpgrade ZK to latest stable version. In particular we need to include:\r\n\r\n- Split brain on log disk full https://issues.apache.org/jira/browse/ZOOKEEPER-3701\r\n- Data loss after upgrading standalone ZK server 3.4.14 to 3.5.6 with snapshot.trust.empty\u003dtrue https://issues.apache.org/jira/browse/ZOOKEEPER-3644" }, { "commit": "207290dfc006b6cffeb23ff37a30ea2ef7b203dd", "tree": "922de17906e1811b2c8c8e13e4aaf7950ef4d607", "parents": [ "6bd009e63ba8826e874b13ed0e7fa51dd0a8b9bb" ], "author": { "name": "Andres Garagiola", "email": "andresgaragiola@gmail.com", "time": "Wed Feb 12 00:19:07 2020 +0100" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Tue Feb 11 15:19:07 2020 -0800" }, "message": "Fix script apply-config-from-env.py (#6293)\n\n" }, { "commit": "6bd009e63ba8826e874b13ed0e7fa51dd0a8b9bb", "tree": "80302b6bb05ded32c4c66cb5b827e2d3d45b605d", "parents": [ "ffe877c2461497fb568750d32217124dce8acda6" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Mon Feb 10 09:36:03 2020 -0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Feb 10 09:36:03 2020 -0800" }, "message": "When building docker image, copy tarball at the end to use build cache (#5334)\n\n* When building docker image, copy tarball at the end to use build cache\r\n\r\n* Install the pulsar python client wheel file after copy the pulsar tarball\r\n\r\n* When building docker image, copy tarball at the end to use build cache\r\n" }, { "commit": "ffe877c2461497fb568750d32217124dce8acda6", "tree": "ffd14a1841cfa42ee04bd0cd7e7defa7eb9e558b", "parents": [ "78d7158ceb81979603c897dc7326822bff0da33b" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Mon Feb 10 08:59:18 2020 -0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Feb 10 08:59:18 2020 -0800" }, "message": "PIP-55: Refresh Authentication Credentials (#6074)\n\n* PIP-55: Refresh Authentication Credentials\r\n\r\n* Fixed import order\r\n\r\n* Do not check for original client credential if it\u0027s not coming through proxy\r\n\r\n* Fixed import order\r\n\r\n* Fixed mocked test assumption\r\n\r\n* Addressed comments\r\n\r\n* Avoid to print NPE on auth refresh check if auth is disabled\r\n" }, { "commit": "78d7158ceb81979603c897dc7326822bff0da33b", "tree": "f0e6473b9bc155e89f28f622090cd60d0a4c2ba6", "parents": [ "6b70c41c2e18a84e013cb5f1194ac3173e0afe4e" ], "author": { "name": "Guangning", "email": "guangning@apache.org", "time": "Mon Feb 10 07:00:58 2020 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Sun Feb 09 15:00:58 2020 -0800" }, "message": "[Issue 6274][Test] Fixed integration Pulsar SQL test failed (#6279)\n\n* Delete no use docker image\r\n\r\n* Add get docker images for delete docker images\r\n\r\n* Add command for get space size\r\n\r\n* Add delete docker images\r\n\r\n* Fixed error\r\n\r\n* Upgrade postgresql from version 9.6 to 11\r\n\r\n* Delete no used image first\r\n\r\n* Fixed delete image\r\n\r\n* Fixed docker images order\r\n\r\n* Add maven install step\r\n\r\n* Add option docker.nocache\u003dtrue\r\n\r\n* Fixed correct docker image\r\n\r\n* Fixed integration test failed\r\n\r\n* Delete debug info\r\n" }, { "commit": "6b70c41c2e18a84e013cb5f1194ac3173e0afe4e", "tree": "d6dfd9db2f7830dd9ad176e310a804cf23b3ed29", "parents": [ "fddce2e90695abfab6e9f2d9f00c863e3a42cfbf" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Fri Feb 07 20:17:18 2020 -0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri Feb 07 20:17:18 2020 -0800" }, "message": "Pin the netty-transport-native-epoll to avoid conflicts (#6194)\n\n### Motivation\r\n\r\nCurrently the version pinning for `netty-transport-native-epoll` is not including the native library artifact. \r\n\r\nThat results, depending on the Maven version, to be picking up an earlier version of `transport-native-epoll-4.1.33.Final-linux-x86_64.jar`, where the version is 4.1.33 as opposed to 4.1.43 which is the correct expected version. \r\n\r\nThis results in using Java NIO based transport instead of the more effiecient/performant epoll based one.\r\n\r\nThis affects 2.5.0 as well." }, { "commit": "fddce2e90695abfab6e9f2d9f00c863e3a42cfbf", "tree": "012d6f053c4c2b24fcdbdea9fb5c7434e433006e", "parents": [ "e3888dd8478ec94f20aa367dbb658edf22aab0ed" ], "author": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Thu Feb 06 15:27:36 2020 -0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Feb 06 15:27:36 2020 -0800" }, "message": "Revert \"Support for python native logging from python wrapper (#6113)\" (#6174)\n\nAs stated in #6171, change #6113 broke the function instance runner. This change attempts to revert #6113 first to make sure CI back to normal.\r\n\r\nAdditionally, it fixes and improves a bunch of integration tests. (unfortunately, we have to couple these changes to make sure it pass CI)." }, { "commit": "e3888dd8478ec94f20aa367dbb658edf22aab0ed", "tree": "3120f76b1b5deb9c9e768d78357d0191d97db59f", "parents": [ "2ea4f2e62a4f975d61bf834c40ecabec943afbca" ], "author": { "name": "Guangning", "email": "guangning@apache.org", "time": "Tue Jan 21 01:37:40 2020 +0800" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Mon Jan 20 09:37:40 2020 -0800" }, "message": "[Github actions]Fix integration test disk space is full (#6098)\n\n### Motivation\r\n\r\nAt present, there are about 28 GB of space available on the running machine of Github action, and there is less than 10GB of disk space left after packing with the `mvn install -DskipTests -Pdocker` command. therefore, the bookie is very easy to exit due to insufficient disk in the integration test. therefore, fix this problem and pack only the needed images.\r\n\r\nThe current integration tests `PulsarFunctionsTest` are all in one class, which is very inconvenient to manage. For example, after the relevant tests of debezium are run, we can clean up the unused images of debezium, so adding groups to the integration test cases, so that we can control the tests more conveniently in the future.\r\n\r\nNow we have about 20G of space for testing.\r\n```\r\ndf -h\r\nFilesystem Size Used Avail Use% Mounted on\r\nudev 3.4G 0 3.4G 0% /dev\r\ntmpfs 695M 688K 694M 1% /run\r\n/dev/sda1 84G 64G 20G 77% /\r\ntmpfs 3.4G 8.0K 3.4G 1% /dev/shm\r\ntmpfs 5.0M 0 5.0M 0% /run/lock\r\ntmpfs 3.4G 0 3.4G 0% /sys/fs/cgroup\r\n/dev/sda15 105M 3.6M 101M 4% /boot/efi\r\n/dev/sdb1 14G 41M 13G 1% /mnt\r\n```\r\n\r\n```\r\ndocker images\r\nREPOSITORY TAG IMAGE ID CREATED SIZE\r\napachepulsar/pulsar-test-latest-version 2.6.0-SNAPSHOT c599fe91d80e 2 seconds ago 2.82GB\r\napachepulsar/pulsar-test-latest-version latest c599fe91d80e 2 seconds ago 2.82GB\r\napachepulsar/pulsar-all latest 77d849fb13b7 3 days ago 2.76GB\r\nnode 10 ea119cebc1c3 3 weeks ago 908MB\r\nnode 12 6b5991bf650f 3 weeks ago 913MB\r\nbuildpack-deps stretch 2adbcf3b6aff 3 weeks ago 835MB\r\ndebian 9 f6c68e2ad82a 3 weeks ago 101MB\r\ndebian 8 5d7d9c6338e8 3 weeks ago 129MB\r\nnode 10-alpine d32bf7fc7d5f 3 weeks ago 80.5MB\r\nnode 12-alpine 1cbcaddb8074 3 weeks ago 85.2MB\r\nalpine 3.10 965ea09ff2eb 3 months ago 5.55MB\r\njekyll/builder latest 4605d94a6b36 3 months ago 564MB\r\nalpine 3.9 055936d39205 8 months ago 5.53MB\r\nalpine 3.7 6d1ef012b567 10 months ago 4.21MB\r\nalpine 3.8 dac705114996 10 months ago 4.41MB\r\nmcr.microsoft.com/azure-pipelines/node8-typescript latest 9a948d360778 15 months ago 595MB\r\n```\r\n\r\n### Modifications\r\n\r\n* Add groups for integration tests\r\n* Delete no used Docker image\r\n* Pack images as needed\r\n\r\n### Verifying this change\r\nNow the integration test can pass normally, please refer to https://github.com/AmateurEvents/pulsar/pull/5/checks?check_run_id\u003d398472038\r\n" }, { "commit": "2ea4f2e62a4f975d61bf834c40ecabec943afbca", "tree": "7655f6b974f481c9602661271edc7fd1ae1f7acc", "parents": [ "c0f76cb9264115f40f375e1697089a111180b03e" ], "author": { "name": "Yang Yang", "email": "yang.yang@elastic.co", "time": "Tue Jan 14 02:02:02 2020 +0800" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Tue Jan 14 02:02:02 2020 +0800" }, "message": "[pulsar-io-rabbitmq] Added integration test for RabbitMQ. (#6033)\n\nFixes https://github.com/apache/pulsar/issues/5920\r\n\r\n### Motivation\r\n\r\nThe current RabbitMQ connector lacks an integration test.\r\n\r\n### Modifications\r\n\r\nAdds an integration test for the RabbitMQ connector(both source and sink):\r\n- A container definition using `rabbitmq:3.8-management` as suggested.\r\n- A RabbitMQ source tester, which provides configurations for the RabbitMQ source connector and publishes messages to the RabbitMQ.\r\n- A RabbitMQ sink tester, which provides configurations for the RabbitMQ sink connector and consumes messages from the RabbitMQ for verification.\r\n- A test case that invokes the testers with the current test framework.\r\n\r\n\r\n### Verifying this change\r\n\r\nThis change added tests and can be verified as follows:\r\n\r\n*(example:)*\r\n - *Added integration tests for the RabbitMQ connector*" }, { "commit": "c0f76cb9264115f40f375e1697089a111180b03e", "tree": "ca60c133bfee185e5e4e5f9b8542949d874c48d6", "parents": [ "2c2f894dd72088f87c181ad98cd157715c4da97e" ], "author": { "name": "Masahiro Sakamoto", "email": "massakam@yahoo-corp.jp", "time": "Mon Jan 06 13:06:05 2020 +0900" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Mon Jan 06 12:06:05 2020 +0800" }, "message": "Upgrade Avro to 1.9.1 (#5938)\n\n### Motivation\r\n\r\nCurrently, Pulsar uses Avro 1.8.2, a version released two years ago. The latest version of Avro is 1.9.1, which uses FasterXML\u0027s Jackson 2.x instead of Codehaus\u0027s Jackson 1.x. Jackson is prone to security issues, so we should not keep using older versions.\r\nhttps://blog.godatadriven.com/apache-avro-1-9-release\r\n\r\n### Modifications\r\n\r\nAvro 1.9 has some major changes:\r\n\r\n- The library used to handle logical datetime values has changed from Joda-Time to JSR-310 (https://github.com/apache/avro/pull/631)\r\n- Namespaces no longer include \"$\" when generating schemas containing inner classes using ReflectData (https://github.com/apache/avro/pull/283)\r\n- Validation of default values has been enabled (https://github.com/apache/avro/pull/288). This results in a validation error when parsing the following schema:\r\n```json\r\n{\r\n \"name\": \"fieldName\",\r\n \"type\": [\r\n \"null\",\r\n \"string\"\r\n ],\r\n \"default\": \"defaultValue\"\r\n}\r\n```\r\nThe default value of a nullable field must be null (cf. https://issues.apache.org/jira/browse/AVRO-1803), and the default value of the field as above is actually null. However, this PR disables the validation in order to maintain the traditional behavior." }, { "commit": "2c2f894dd72088f87c181ad98cd157715c4da97e", "tree": "999965d69bdb24a482053bbc39b7abc16aa674ae", "parents": [ "92cdce6e960c30a14f0a10642af3ddfac90392a6" ], "author": { "name": "Yong Zhang", "email": "zhangyong1025.zy@gmail.com", "time": "Mon Jan 06 10:48:09 2020 +0800" }, "committer": { "name": "冉小龙", "email": "rxl@apache.org", "time": "Mon Jan 06 10:48:09 2020 +0800" }, "message": "[Github Action] Clean up space before running backwards compatibility test (#5977)\n\n---\r\n\r\n*Motivation*\r\n\r\nBackwards compatibility test always failed with\r\n`Docker environment should have more than 2GB free disk space`.\r\n\r\n*Modifications*\r\n\r\nClean up space before running test." }, { "commit": "92cdce6e960c30a14f0a10642af3ddfac90392a6", "tree": "24180fa27d5fbc66f785d0ba0d96a8a3ae580389", "parents": [ "f96355a7a31d3ed130bdbbbaf2a11dcd94d35886" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Sun Jan 05 12:44:27 2020 -0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Sun Jan 05 12:44:27 2020 -0800" }, "message": "Make unit tests to only use dynamically allocated ports (#5486)\n\n* Make unit tests to only use dynamically allocated ports\r\n\r\n* Fixed proxy tests\r\n\r\n* Fixed zk test utils after merge\r\n\r\n* Fixed multi host client test\r\n\r\n* Fix for testConcurrentConsumerReceiveWhileReconnect\r\n\r\n* Increased timeout on testPulsarSourceLocalRunWithFile\r\n\r\n* Fixed newer test to also avoid port manager\r\n\r\n* Fixed test race condition with thread starting in PulsarFunctionLocalRunTest\r\n\r\n* Fixed ProxyWithAuthorizationNegTest\r\n\r\n* Fixed ProxySaslAuthenticationTest\r\n" }, { "commit": "f96355a7a31d3ed130bdbbbaf2a11dcd94d35886", "tree": "dd3339cdc39bc7f6c4ef4812df97f5729c75df87", "parents": [ "674b33ec9692db461123afa240a565217a106b93" ], "author": { "name": "Guangning", "email": "guangning@apache.org", "time": "Wed Jan 01 08:26:03 2020 +0800" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Wed Jan 01 08:26:03 2020 +0800" }, "message": "Add diskUsageThreshold to 0.99 (#5970)\n\n### Motivation\r\n\r\nThe current GitHub action test will show that the disk space exceeds 95%, and then the bookie will detect that bookie exits, so fix this problem.\r\n\r\n![image](https://user-images.githubusercontent.com/1907867/71616693-8748da00-2bf2-11ea-82f2-e54eda012136.png)\r\n\r\n\r\n### Modifications\r\n\r\n* Configuration parameter disUsageThreshold is 0.99 to prevent bookie exit.\r\n\r\n### Verifying this change\r\n\r\nIntegration test pass" }, { "commit": "674b33ec9692db461123afa240a565217a106b93", "tree": "eb3d017f261cf4e506174077a406b44724b37638", "parents": [ "c295a5792ea523ebedba316df3cab651135182b5" ], "author": { "name": "Nathan Mills", "email": "rivernate@gmail.com", "time": "Mon Dec 23 19:39:51 2019 -0700" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Tue Dec 24 10:39:51 2019 +0800" }, "message": "[functions] Added default metrics for Prometheus (#5885)\n\nCurrently functions do not report the default Prometheus metrics\r\nlike the broker does, or any JMX metrics that normally get\r\nreported by kafka clients.\r\n\r\nThis add the default Prometheus exports used by the broker as\r\nwell as JMX exports that are reported by kafka clients when\r\nusing the kafka wrapper.\r\n\r\nThis change is a trivial rework / code cleanup without any test coverage." }, { "commit": "c295a5792ea523ebedba316df3cab651135182b5", "tree": "e4972f90a6950f00be45142dce686d9bad895b8e", "parents": [ "0cf6f993630943b2686a2e08f9302c22070be350" ], "author": { "name": "tuteng", "email": "guangning@apache.org", "time": "Fri Dec 20 14:05:46 2019 +0800" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Thu Dec 19 22:05:46 2019 -0800" }, "message": "[Issue 5832][Pulsar IO]Fix npe of debezium delete event (#5876)\n\nFixes https://github.com/apache/pulsar/issues/5832\r\n\r\nMaster Issue: https://github.com/apache/pulsar/issues/5832\r\n\r\n### Motivation\r\n\r\nCurrently, in debezium, for delete events, in order to be compatible with Kafka\u0027s compaction, each delete event will be followed by a record with a null value. For records with a null value, the null value is not currently processed in pulsar, resulting in an exception of throwing a null pointer. Now, we considered to ignore the null value or use it in combination with pulsar\u0027s compaction feature in the future.\r\n\r\n![image](https://user-images.githubusercontent.com/1907867/70976050-21cef680-20e6-11ea-963f-56471c915c98.png)\r\nhttps://debezium.io/documentation/reference/0.10/connectors/mysql.html\r\n\r\n### Modifications\r\n\r\n* Ignore the record of the null value.\r\n* Add more integrations, such as insert, delete, update." }, { "commit": "0cf6f993630943b2686a2e08f9302c22070be350", "tree": "ed6d831edd01d172edf9dec5271aaa22a8a16c46", "parents": [ "c32b15226a8a4b7e3a947f2b2b83900dbf92c54b" ], "author": { "name": "tuteng", "email": "guangning@apache.org", "time": "Fri Dec 20 13:35:06 2019 +0800" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Thu Dec 19 21:35:06 2019 -0800" }, "message": "[Pulsar Client Tools]Support generate documentation of pulsar admin cli automatically (#5738)\n\n### Motivation\r\n\r\nCurrently, the commands on the page http://pulsar.apache.org/docs/en/pulsar-admin/ are all manually added. when the document changes, there are often wrong contents. in order to solve this problem, we expect the commands on this page to be automatically generated. this pr is the first step. If it passes, we will add a new page on the website to show the automatically generated commands later.\r\n" }, { "commit": "c32b15226a8a4b7e3a947f2b2b83900dbf92c54b", "tree": "e6945c776f5d280b0065447356761c9962b179b7", "parents": [ "d71ab8616937a97cb23ae20a73c42ecdb8842013" ], "author": { "name": "tuteng", "email": "guangning@apache.org", "time": "Tue Dec 17 22:55:55 2019 +0800" }, "committer": { "name": "lipenghui", "email": "penghui@apache.org", "time": "Tue Dec 17 22:55:55 2019 +0800" }, "message": "Fix flaky test for debezium (#5878)\n\n" }, { "commit": "d71ab8616937a97cb23ae20a73c42ecdb8842013", "tree": "26c57b8ed7125116eba4814278aa01388c3052d9", "parents": [ "0466bacf3303646c3bfbf2fb179a80ad590e9ba9" ], "author": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Mon Dec 09 10:16:38 2019 -0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Dec 09 10:16:38 2019 -0800" }, "message": "[build] Allow skipping deploying docker artifacts to maven repo (#5821)\n\n*Motivation*\r\n\r\nAllow skipping deploying docker artifacts to maven repo if `skipBuildDistribution` is specified" }, { "commit": "0466bacf3303646c3bfbf2fb179a80ad590e9ba9", "tree": "a3c94e68929728a24def2ab3fa9934d521d73eca", "parents": [ "6fe1c3d618cecb1aff2f3c1b034954de8ae70678" ], "author": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Mon Dec 09 08:50:21 2019 -0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Dec 09 08:50:21 2019 -0800" }, "message": "Bump version to 2.6.0 (#5820)\n\n*Motivation*\r\n\r\nBump the development version to 2.6.0-SNAPSHOT" }, { "commit": "6fe1c3d618cecb1aff2f3c1b034954de8ae70678", "tree": "217edea583ab9a01ccebbcb91f46a2242fc5b4e9", "parents": [ "5439e82f70a6e54ac819512a4fb10b0e6dc9fec3" ], "author": { "name": "Masahiro Sakamoto", "email": "massakam@yahoo-corp.jp", "time": "Wed Dec 04 02:45:20 2019 +0900" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Tue Dec 03 09:45:20 2019 -0800" }, "message": "Bump jackson libraries to 2.10.1 (#5758)\n\nUpdated jackson libraries to the latest version. There is a security vulnerability in `jackson-databind` currently used by Pulsar.\r\nhttps://cve.mitre.org/cgi-bin/cvename.cgi?name\u003dCVE-2019-17531" }, { "commit": "5439e82f70a6e54ac819512a4fb10b0e6dc9fec3", "tree": "aa98f2d7f03eb47268047657ba789f5be53fa449", "parents": [ "3c5a7025fb8f3ba4185f326473c10745e2165dbe" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Tue Nov 19 10:03:50 2019 -0800" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Tue Nov 19 10:03:50 2019 -0800" }, "message": "Use simple GC settings when running integration tests (#5342)\n\n### Motivation\r\n\r\nServices started in integration tests are using a very aggressive GC config, with many threads and trading more memory for pause times. \r\n\r\nAdditionally, multiple variables are being passed in the wrong way to the bookie container, resulting in bookies using the default Xmx of 2 GB." }, { "commit": "3c5a7025fb8f3ba4185f326473c10745e2165dbe", "tree": "488016df665382b177ce649f8397fad19e559732", "parents": [ "5ea33cfbd523b03e61c51ff59bb84d30be579f1b" ], "author": { "name": "lipenghui", "email": "penghui@apache.org", "time": "Tue Nov 19 15:30:10 2019 +0800" }, "committer": { "name": "Jia Zhai", "email": "zhaijia@apache.org", "time": "Tue Nov 19 15:30:10 2019 +0800" }, "message": "[PIP-38] Support batch receive in java client. (#4621)\n\nMotivation\r\nSupport messages batch receiving, some application scenarios can be made simpler. Users often increase application throughput through batch operations. For example, batch insert or update database.\r\n\r\nAt present, we provide the ability to receive a single message. If users want to take advantage of batch operating advantages, need to implement a message collector him self. So this proposal aims to provide a universal interface and mechanism for batch receiving messages.\r\n\r\nFor example:\r\n```\r\nMessages messages \u003d consumer.batchReceive();\r\ninsertToDB(messages);\r\nconsumer.acknowledge(messages);\r\nVerifying this change\r\nAdded new UT to verify this change.\r\n```" }, { "commit": "5ea33cfbd523b03e61c51ff59bb84d30be579f1b", "tree": "c960dcbf648149ca56affbbcfd70268ae919dbea", "parents": [ "889db795f6349580e4784d7c5b84f1207e28e47b" ], "author": { "name": "huangdx0726", "email": "localhost80@foxmail.com", "time": "Tue Nov 19 09:53:37 2019 +0800" }, "committer": { "name": "tuteng", "email": "guangning@apache.org", "time": "Tue Nov 19 09:53:37 2019 +0800" }, "message": "[Issue 5474][pulsar-io-debezium] Support CDC Connector for MongoDB (#5590)\n\n* support mongodb connector\r\n\r\n* add tester\r\n\r\n* add tester\r\n\r\n* add tester\r\n\r\n* add license header\r\n\r\n* fix by some comments\r\n\r\n* add jdbc source sink\r\n\r\n* add init data\r\n\r\n* fix code style and default port 27017 of mongodb\r\n" }, { "commit": "889db795f6349580e4784d7c5b84f1207e28e47b", "tree": "a44dcf617154e64a0184412d56ca54ebe37ae06b", "parents": [ "f6e72f31b1913afe1fc075b5167be50c95c60b0f" ], "author": { "name": "lipenghui", "email": "penghui@apache.org", "time": "Fri Nov 15 15:03:29 2019 +0800" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Fri Nov 15 15:03:29 2019 +0800" }, "message": "Add highest sequenceId for CommandSendReceipt. (#5653)\n\n## Motivation\r\n\r\nSince #5491 merged, while user use new pulsar client to produce batch messages to older version broker(e.g. 2.4.0), send ack error will occur:\r\n\r\n```\r\n[pulsar-client-io-8-2] WARN org.apache.pulsar.client.impl.ProducerImpl - [persistent://sandbox/pressure-test/test-A-partition-11] [pulsar-cluster-test-13-294] Got ack for msg. expecting: 13 - got: 224 - queue-size: 9\r\n```\r\n\r\nThe problem is client use highest sequence id to match the response sequence id, but in old version broker can not return the highest id.\r\n\r\nSo, this pr is try to fix the problem of produce batch message with new version client and old version broker.\r\n\r\n### Modifications\r\n\r\nAdd highest sequence id to CommandSendReceipt. If the response highest sequence id of send receipt \u003e lowest sequence id, it means broker is a new version broker, so we need to verify the highest sequence id, otherwise we only verify the lowest sequence id." }, { "commit": "f6e72f31b1913afe1fc075b5167be50c95c60b0f", "tree": "e55e365a02592cda5975663c8f68e9f5165b4a69", "parents": [ "4f4f523178d87f40b94a499a23e4c81830485b54" ], "author": { "name": "冉小龙", "email": "ranxiaolong716@gmail.com", "time": "Thu Nov 14 14:50:07 2019 +0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Nov 14 14:50:07 2019 +0800" }, "message": "Upgrade bk version to 4.10.0 (#5607)\n\n* Upgrade bk version to 4.10.0\r\n\r\nSigned-off-by: xiaolong.ran \u003cranxiaolong716@gmail.com\u003e\r\n\r\n* Handle NoSuchLedgerExistsOnMetadataServer error\r\n\r\n" }, { "commit": "4f4f523178d87f40b94a499a23e4c81830485b54", "tree": "fbccdd0c7f49775e9f1b3ab6b932a56cb46223ab", "parents": [ "2553efa60fda0f6509a5d4114577ee18d038cb2a" ], "author": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Fri Nov 08 02:13:17 2019 +0800" }, "committer": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Thu Nov 07 10:13:17 2019 -0800" }, "message": "Remove old Pulsar website (#5576)\n\n* Remove old Pulsar website\r\n\r\n* Remove `site/` reference\r\n" }, { "commit": "2553efa60fda0f6509a5d4114577ee18d038cb2a", "tree": "34102c16f975bbd45962b4298e419f732104d3f3", "parents": [ "83d3afb6aa26ce618ba2bdbf172e6c5c7b54fbe5" ], "author": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Thu Nov 07 18:47:24 2019 +0800" }, "committer": { "name": "Ali Ahmed", "email": "alahmed.se@gmail.com", "time": "Thu Nov 07 02:47:24 2019 -0800" }, "message": "Fix license file in the distribution package (#5578)\n\n" }, { "commit": "83d3afb6aa26ce618ba2bdbf172e6c5c7b54fbe5", "tree": "018a728ebea0dc1ac3c9da46f124629f3617cce0", "parents": [ "f1cda97d44f6cb3c4156b20f646d2c212c59355e" ], "author": { "name": "Ali Ahmed", "email": "alahmed.se@gmail.com", "time": "Tue Nov 05 09:16:34 2019 -0800" }, "committer": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Tue Nov 05 09:16:34 2019 -0800" }, "message": "Fix Test Assertion retry (#5544)\n\n" }, { "commit": "f1cda97d44f6cb3c4156b20f646d2c212c59355e", "tree": "38d4db72e85e5ce0f54aee0f31308e99067be0e6", "parents": [ "04b2625edf3791da86ce5ce3e3dd9c91bcb4fdae" ], "author": { "name": "congbo", "email": "39078850+congbobo184@users.noreply.github.com", "time": "Mon Nov 04 23:12:38 2019 +0800" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Mon Nov 04 23:12:38 2019 +0800" }, "message": "[PIP-44] Separate schema compatibility checker for producer and consumer (#5227)\n\n* Change import org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy;\r\n\r\n* Schema compatibility check change\r\n\r\n* Add the test\r\n\r\n* modify the cmdNamespaces\r\n\r\n* Modify the variable name\r\n\r\n* Delete the configuration\r\n\r\n* Modify the variable name\r\n\r\n* modify the method\r\n\r\n* Fix some tests\r\n\r\n* add the integration test\r\n\r\n* Modify the test\r\n\r\n* modity the Timeout time\r\n\r\n* Modify the test\u0027s sequence\r\n\r\n* modify the exception message\r\n\r\n* Add the test\r\n\r\n* modify the httpLookupService\r\n\r\n* Add the license\r\n\r\n* add the method\r\n\r\n* Modify decode message throw exception\r\n\r\n* Add the import class\r\n\r\n* fix some comment\r\n\r\n* Modify the implments method\r\n\r\n* add the judgement for consumer schema compatibility check\r\n\r\n* add the import\r\n" }, { "commit": "04b2625edf3791da86ce5ce3e3dd9c91bcb4fdae", "tree": "6f456287c79e0c1368cb46134fb7f051805b29b1", "parents": [ "ad5e0b08a29858cc634f5f502627c17757ab88df" ], "author": { "name": "Yong Zhang", "email": "zhangyong1025.zy@gmail.com", "time": "Fri Nov 01 10:10:06 2019 +0800" }, "committer": { "name": "冉小龙", "email": "ranxiaolong716@gmail.com", "time": "Fri Nov 01 10:10:06 2019 +0800" }, "message": "Fix list non-persistent topics shows the persistent topics (#5502)\n\n* Fix list non-persistent topics shows the persistent topics\r\n---\r\n\r\nFixes #5414\r\n\r\n*Motivation*\r\n\r\nWhen using the REST API to request to list all the non-persistent\r\ntopics, it will show the persistent topics.\r\n\r\n*Modifications*\r\n\r\n- Add a filter when before sending the response\r\n" }, { "commit": "ad5e0b08a29858cc634f5f502627c17757ab88df", "tree": "4a631d2a4e49e3ae66453baf2f1efc85afc8bdf4", "parents": [ "e4d886996c712b6083008a8838f142d77e3b22d9" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Wed Oct 30 23:38:27 2019 -0700" }, "committer": { "name": "冉小龙", "email": "ranxiaolong716@gmail.com", "time": "Thu Oct 31 14:38:27 2019 +0800" }, "message": "Upgrade dependencies for security fixes (#5232)\n\n* Upgrade dependencies for security fixes\r\n\r\n* Use guava 18 for jclouds-shaded\r\n\r\n* Fix the guava version for HDFS tiered storage component\r\n\r\n* Rollback guava to 25.1 since there are API breaking changes\r\n\r\n* Rollback to Maven 3.0.5 which has the fix for sec issue\r\n\r\n* Fixed Jetty SslContextFactory creation\r\n\r\n* Roll back to 9.4.20.v20190813\r\n" }, { "commit": "e4d886996c712b6083008a8838f142d77e3b22d9", "tree": "4f04abf778b419f21699ec728d8772a21e5f0e7a", "parents": [ "9bda5590be267fa08475eebb19feef55c318a723" ], "author": { "name": "Chris Bartholomew", "email": "c_bartholomew@yahoo.com", "time": "Tue Oct 29 14:57:07 2019 -0400" }, "committer": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Tue Oct 29 11:57:07 2019 -0700" }, "message": "[Issue 5415][docker build]Updating docker build for pulsar-standalone to use main dashboard sou… (#5420)\n\n* Updating docker build for puslar-standalone to use main dashboard source files; deleting duplicate files\r\n\r\n* Committed the wrong Dockerfile\r\n" }, { "commit": "9bda5590be267fa08475eebb19feef55c318a723", "tree": "8a692711f5af7e661b1c6a6618f5dd91a5d7baff", "parents": [ "4b54b33da13eecff7586531dd242bead57552f1c" ], "author": { "name": "冉小龙", "email": "ranxiaolong716@gmail.com", "time": "Mon Oct 28 21:06:10 2019 +0800" }, "committer": { "name": "Sijie Guo", "email": "sijie@apache.org", "time": "Mon Oct 28 21:06:10 2019 +0800" }, "message": "[functions][Issue:5350]Fix pulsar can\u0027t load the customized SerDe (#5357)\n\nFixes #5350\r\n\r\n### Motivation\r\n\r\nWhen using the `--output-serde-classname` option, `functionClassLoader` is not set correctly." }, { "commit": "4b54b33da13eecff7586531dd242bead57552f1c", "tree": "d5bcde1bf0f1a78c8609b0147a3215c929c66f25", "parents": [ "87e6e51bb48c629146868d4af75cc74200ddd115" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Fri Oct 25 09:43:45 2019 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Fri Oct 25 09:43:45 2019 -0700" }, "message": "Use individual netty-* artifacts instead of netty-all (#3613)\n\n" }, { "commit": "87e6e51bb48c629146868d4af75cc74200ddd115", "tree": "894c0bd0c7486c08e61ff4df2a7b959fd3e1b082", "parents": [ "8071f311a74a290a66be47f5eae099a9231279ae" ], "author": { "name": "lipenghui", "email": "penghui@apache.org", "time": "Fri Oct 25 23:23:03 2019 +0800" }, "committer": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Fri Oct 25 08:23:03 2019 -0700" }, "message": "[integration-tests]Enable messaging tests to integration tests. (#5456)\n\n* Enable messaging tests to integration tests.\r\n\r\n* Fix integration tests\r\n" }, { "commit": "8071f311a74a290a66be47f5eae099a9231279ae", "tree": "f334c460b8d4091b9891003b5aed5d1a900320e5", "parents": [ "ae69a546a4a8d074f0b3105737524b235befbfeb" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Thu Oct 24 14:39:00 2019 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Oct 24 14:39:00 2019 -0700" }, "message": "Expose metrics of Caffeine caches (#5320)\n\n* Expose metrics of Caffeine and Guava caches\r\n\r\n* Fixed test\r\n\r\n* removed guava cache instrumentation\r\n\r\n* Fixed test\r\n" }, { "commit": "ae69a546a4a8d074f0b3105737524b235befbfeb", "tree": "f7198d6a2979ac17b562fada1c3a7d99c564a213", "parents": [ "cf5b421ac34cb79118e18bea1a3ed641c78593d6" ], "author": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Thu Oct 24 11:27:30 2019 -0700" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Oct 24 11:27:30 2019 -0700" }, "message": "Multiple unit tests improvements (#5439)\n\n* Multiple unit tests improvements\r\n\r\n* Fixed Storm integration tests\r\n\r\n* Fixed StringSchema static initialization\r\n\r\n* Peg number of forks to number of cores\r\n\r\n* Updated to 4 forks\r\n\r\n* Fixed resourcel leak in managed ledger tests\r\n\r\n* Use different temp folders for PulsarFunctionState test\r\n\r\n* Increase retries count for PulsarFunctionE2ESecurityTest\r\n\r\n* Fixed Flume connector test\r\n\r\n* Fixed race conditions in primitive schema types static initialization\r\n\r\n* Improve port manager\r\n\r\n* Removed PulsarFunctionStateTest to move to integration tests\r\n\r\n* Fixed dangling class reference\r\n" }, { "commit": "cf5b421ac34cb79118e18bea1a3ed641c78593d6", "tree": "2110c19c37ab5e79299e2a9ad83a1a6486ff132a", "parents": [ "e5ab1196c5c4d972222e73214d107debe66c0983" ], "author": { "name": "Addison Higham", "email": "addisonj@gmail.com", "time": "Thu Oct 24 10:58:41 2019 -0600" }, "committer": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Thu Oct 24 09:58:41 2019 -0700" }, "message": "[proxy] Fix proxy to be able to re-send request body (#5361)\n\nFixes #5360\r\n\r\nThis adds a small cache of the request body to ensure that it can be\r\nre-sent.\r\n\r\nTODO: still needs tested" }, { "commit": "e5ab1196c5c4d972222e73214d107debe66c0983", "tree": "00908962eada834728470bc7de640cf2a8c0a092", "parents": [ "50b9c82626965086807df132eace4fe426ea0f71" ], "author": { "name": "Boyang Jerry Peng", "email": "jerry.boyang.peng@gmail.com", "time": "Tue Oct 22 02:21:51 2019 -0700" }, "committer": { "name": "Matteo Merli", "email": "mmerli@apache.org", "time": "Tue Oct 22 02:21:50 2019 -0700" }, "message": "Fix couple functions related integration tests (#5434)\n\n" }, { "commit": "50b9c82626965086807df132eace4fe426ea0f71", "tree": "7766ba14814c9c680a4499d41b86a15d24baab68", "parents": [ "0a5e31e9e8e3e08a33ea42415ef780125980b107" ], "author": { "name": "Boyang Jerry Peng", "email": "jerry.boyang.peng@gmail.com", "time": "Mon Oct 21 20:58:16 2019 -0700" }, "committer": { "name": "tuteng", "email": "guangning@apache.org", "time": "Tue Oct 22 11:58:16 2019 +0800" }, "message": "Revert \"Add default loader for latest pyyaml (#4974)\" (#5432)\n\nThis reverts commit d49e61e0907c30d71184da4eb769c9761456a80f." } ], "next": "0a5e31e9e8e3e08a33ea42415ef780125980b107" }