{"push_id":1422471748,"size":39,"distinct_size":39,"ref":"refs/heads/trunk","head":"3e3b7a010be9959ac6f205a0ea66a2595bb62ae6","before":"11766ad31861e0350178f59127e471fde2b20970","commits":[{"sha":"6dbe202b6dc3ba638d3a55ff89b594bd334bb8b0","author":{"name":"Tu Yang","email":"efc4e90ea9e3cb8055ce211ca82c60d4766cd830@meituan.com"},"message":"KAFKA-4360：Controller may deadLock when autoLeaderRebalance encounter zk expired\n\nAuthor: tuyang <tuyang@meituan.com>\nAuthor: xiguantiaozhan <kafkausr@126.com>\n\nReviewers: Ismael Juma, Jiangjie Qin, Guozhang Wang\n\nCloses #2094 from xiguantiaozhan/rebalance_deadlock","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/6dbe202b6dc3ba638d3a55ff89b594bd334bb8b0"},{"sha":"8ab8f37b43e3274ad0d8fb3883e3f432992058ba","author":{"name":"Xavier Léauté","email":"07b97c3ef02b9179b56ac4eac32e7b955097e197@confluent.io"},"message":"MINOR: fix typos and incorrect docs\n\nAuthor: Xavier Léauté <xavier@confluent.io>\n\nReviewers: Matthias J. Sax, Guozhang Wang\n\nCloses #2112 from xvrl/minor-doc-fixes","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/8ab8f37b43e3274ad0d8fb3883e3f432992058ba"},{"sha":"7c36fc377650dac8a9d6e5f2d0049a78cd93d2e5","author":{"name":"Damian Guy","email":"a352d70b5750eea9e7969230d96f9ec481f91a1c@gmail.com"},"message":"KAFKA-4311: Multi layer cache eviction causes forwarding to incorrect ProcessorNode\n\nGiven a topology like the one below. If a record arriving in `tableOne` causes a cache eviction, it will trigger the `leftJoin` that will do a `get` from `reducer-store`. If the key is not currently cached in `reducer-store`, but is in the backing store, it will be put into the cache, and it may also trigger an eviction. If it does trigger an eviction and the eldest entry is dirty it will flush the dirty keys. It is at this point that a ClassCastException is thrown. This occurs because the ProcessorContext is still set to the context of the `leftJoin` and the next child in the topology is `mapValues`.\nWe need to set the correct `ProcessorNode`, on the context, in the `ForwardingCacheFlushListener` prior to calling `context.forward`. We also need to  remember to reset the `ProcessorNode` to the previous node once `context.forward` has completed.\n\n```\n       final KTable<String, String> one = builder.table(Serdes.String(), Serdes.String(), tableOne, tableOne);\n        final KTable<Long, String> two = builder.table(Serdes.Long(), Serdes.String(), tableTwo, tableTwo);\n        final KTable<String, Long> reduce = two.groupBy(new KeyValueMapper<Long, String, KeyValue<String, Long>>() {\n            Override\n            public KeyValue<String, Long> apply(final Long key, final String value) {\n                return new KeyValue<>(value, key);\n            }\n        }, Serdes.String(), Serdes.Long())\n                .reduce(new Reducer<Long>() {..}, new Reducer<Long>() {..}, \"reducer-store\");\n\n    one.leftJoin(reduce, new ValueJoiner<String, Long, String>() {..})\n        .mapValues(new ValueMapper<String, String>() {..});\n\n```\n\nAuthor: Damian Guy <damian.guy@gmail.com>\n\nReviewers: Eno Thereska, Guozhang Wang\n\nCloses #2051 from dguy/kafka-4311","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/7c36fc377650dac8a9d6e5f2d0049a78cd93d2e5"},{"sha":"f1e1b6e744cde036d75678575bd5e32c608ecdb1","author":{"name":"Damian Guy","email":"a352d70b5750eea9e7969230d96f9ec481f91a1c@gmail.com"},"message":"MINOR: remove unused fields from KTableImpl\n\nRemove `keySerde`, `valSerde`, `OUTERTHIS_NAME`, `OUTEROTHER_NAME`, `LEFTTHIS_NAME`, `LEFTOTHER_NAME` from `KTableImpl` as they are all unused fields\n\nAuthor: Damian Guy <damian.guy@gmail.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #2119 from dguy/minor-ktable-unused","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/f1e1b6e744cde036d75678575bd5e32c608ecdb1"},{"sha":"a66ca1624c692d30b7ae1e25c29915331cbf41e3","author":{"name":"Damian Guy","email":"a352d70b5750eea9e7969230d96f9ec481f91a1c@gmail.com"},"message":"MINOR: fix incorrect logging in StreamThread\n\nFix incorrect logging when unable to create an active task. The output was: Failed to create an active task %s:\nIt should have the taskId.\n\nAuthor: Damian Guy <damian.guy@gmail.com>\n\nReviewers: Ismael Juma, Eno Thereska\n\nCloses #2109 from dguy/minor-logging","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/a66ca1624c692d30b7ae1e25c29915331cbf41e3"},{"sha":"da13b537871ee59d30fb82703de4b6b1fcb11dff","author":{"name":"rnpridgeon","email":"a36e4e75112566d0718b8c34dcbf7c84ea43c79f@gmail.com"},"message":"KAFKA-4364: Remove secrets from DEBUG logging\n\nleverage fix from KAFKA-2690 to remove secrets from task logging\n\nAuthor: rnpridgeon <ryan.n.pridgeon@gmail.com>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #2115 from rnpridgeon/KAFKA-4364","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/da13b537871ee59d30fb82703de4b6b1fcb11dff"},{"sha":"6972d9476fc036d5fdcc59fb82fb20f063091df8","author":{"name":"Matthias J. Sax","email":"50acca05af79804b01d430d231b3b71dcc4d995e@confluent.io"},"message":"MINOR: add upgrade guide for Kafka Streams API\n\nAuthor: Matthias J. Sax <matthias@confluent.io>\n\nReviewers: Michael G. Noll, Eno Thereska\n\nCloses #2114 from mjsax/updateDocUpgradeSection","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/6972d9476fc036d5fdcc59fb82fb20f063091df8"},{"sha":"cc62b4f844ca16eee974e75b736af87b7532de0d","author":{"name":"Guozhang Wang","email":"08d6b47f1ed933bf8f63fe549a461671f3a38d3b@gmail.com"},"message":"revert streams/src/main/java/org/apache/kafka/streams/processor/ConsumerRecordTimestampExtractor.java","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/cc62b4f844ca16eee974e75b736af87b7532de0d"},{"sha":"d8fa4006cb824aa2a8ab890b6754c920ac17182c","author":{"name":"Matthias J. Sax","email":"50acca05af79804b01d430d231b3b71dcc4d995e@confluent.io"},"message":"MINOR: improve exception message for incompatible Serdes to actual key/value data types\n\nAuthor: Matthias J. Sax <matthias@confluent.io>\n\nReviewers: Michael G. Noll, Guozhang Wang\n\nCloses #2118 from mjsax/hotfixImproveSerdeTypeMissmatchError","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/d8fa4006cb824aa2a8ab890b6754c920ac17182c"},{"sha":"0fc1898bf6b91ac5f79dbf3da7ebc90da410876d","author":{"name":"Dan Norwood","email":"0c8ed251887e3d51b589468a0f5cce90ee433fba@confluent.io"},"message":"HOTFIX: failing to close this iterator causes leaks in rocksdb\n\nguozhangwang dguy\n\nAuthor: dan norwood <norwood@confluent.io>\n\nReviewers: Damian Guy, Michael G. Noll, Guozhang Wang\n\nCloses #2122 from norwood/close-call","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/0fc1898bf6b91ac5f79dbf3da7ebc90da410876d"},{"sha":"97839344601cc67256e871bd461e877eed974104","author":{"name":"Konstantine Karantasis","email":"56b201399e7939aa9258d7df3a7e403bddeb6727@confluent.io"},"message":"MINOR: Extend mirror maker test to include interceptors\n\nAuthor: Konstantine Karantasis <konstantine@confluent.io>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #2081 from kkonstantine/MINOR-Extend-mirror-maker-test-to-include-interceptors","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/97839344601cc67256e871bd461e877eed974104"},{"sha":"64a860c5853e21ff91109d0acb74b42f2dc20c7c","author":{"name":"Damian Guy","email":"a352d70b5750eea9e7969230d96f9ec481f91a1c@gmail.com"},"message":"KAFKA-4379: Remove caching of dirty and removed keys from StoreChangeLogger\n\nThe `StoreChangeLogger` currently keeps a cache of dirty and removed keys and will batch the changelog records such that we don't send a record for each update. However, with KIP-63 this is unnecessary as the batching and de-duping is done by the caching layer. Further, the `StoreChangeLogger` relies on `context.timestamp()` which is likely to be incorrect when caching is enabled\n\nAuthor: Damian Guy <damian.guy@gmail.com>\n\nReviewers: Matthias J. Sax, Eno Thereska, Guozhang Wang\n\nCloses #2103 from dguy/store-change-logger","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/64a860c5853e21ff91109d0acb74b42f2dc20c7c"},{"sha":"7282de39f7b7cef1ca85f21771f2401a4a67eaec","author":{"name":"Mickael Maison","email":"7085863039422df15fdbf5fc53ace6ee398da44c@gmail.com"},"message":"KAFKA-4081; KafkaConsumer should not allow negative offsets to be committed\n\nAuthor: Mickael Maison <mickael.maison@gmail.com>\n\nReviewers: Jiangjie Qin <becket.qin@gmail.com>, Jason Gustafson <jason@confluent.io>\n\nCloses #1827 from mimaison/KAFKA-4081","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/7282de39f7b7cef1ca85f21771f2401a4a67eaec"},{"sha":"4f1d8c6859c5767c314de84bd654cb7e1153db4b","author":{"name":"Konstantine Karantasis","email":"56b201399e7939aa9258d7df3a7e403bddeb6727@confluent.io"},"message":"MINOR: Fix export command for additional env vars in connect system tests\n\nAuthor: Konstantine Karantasis <konstantine@confluent.io>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #2126 from kkonstantine/MINOR-Fix-formatting-of-env-vars-in-connect-system-test-template","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/4f1d8c6859c5767c314de84bd654cb7e1153db4b"},{"sha":"b7d36b7261ddefea68667a65cc5e2ee0734ed4a1","author":{"name":"Jason Gustafson","email":"158e602a35675d2a0b685478824aa5995557a235@confluent.io"},"message":"KAFKA-3829: Ensure valid configuration prior to creating connector\n\nAuthor: Jason Gustafson <jason@confluent.io>\n\nReviewers: Shikhar Bhushan <shikhar@schmizz.net>, Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1911 from hachikuji/KAFKA-3829","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/b7d36b7261ddefea68667a65cc5e2ee0734ed4a1"},{"sha":"1f1d4500623275ca05fe661b608a5119bde934ed","author":{"name":"Joel Koshy","email":"c9e7ad2165c9ce9dd63eb64fd1a7d8ecddcc9b12@gmail.com"},"message":"KAFKA-4409; Fix deadlock between topic event handling and shutdown in ZookeeperConsumerConnector\n\nThe consumer can deadlock on shutdown if a topic event fires during shutdown. The shutdown acquires the rebalance lock and then the topic-event-watcher lock. The topic event watcher acquires these in the reverse order. Shutdown should not need to acquire the topic-event-watcher’s lock - all it does is unsubscribes from topic events.\n\nAuthor: Joel Koshy <jjkoshy@gmail.com>\n\nReviewers: Jiangjie Qin <becket.qin@gmail.com>\n\nCloses #2129 from jjkoshy/KAFKA-4409","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/1f1d4500623275ca05fe661b608a5119bde934ed"},{"sha":"3b4c347949c02b1e2b1dd473deda0f8d2304d027","author":{"name":"Jason Gustafson","email":"158e602a35675d2a0b685478824aa5995557a235@confluent.io"},"message":"KAFKA-2066; Use client-side FetchRequest/FetchResponse on server\n\nAuthor: Jason Gustafson <jason@confluent.io>\n\nReviewers: Jun Rao <junrao@gmail.com>\n\nCloses #2069 from hachikuji/KAFKA-2066","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/3b4c347949c02b1e2b1dd473deda0f8d2304d027"},{"sha":"a32962af1427483eb103868497d3bfb6d5537fc6","author":{"name":"Shikhar Bhushan","email":"295367247747ce57c9516ff4d6f5e4f21f3accf0@confluent.io"},"message":"HOTFIX: Remove failing ConnectDistributedTest.test_bad_connector_class\n\nSince #1911 was merged it is hard to externally test a connector transitioning to FAILED state due to an initialization failure, which is what this test was attempting to verify.\n\nThe unit test added in #1778 already exercises exception-handling around Connector instantiation.\n\nAuthor: Shikhar Bhushan <shikhar@confluent.io>\n\nReviewers: Jason Gustafson <jason@confluent.io>\n\nCloses #2131 from shikhar/test_bad_connector_class","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/a32962af1427483eb103868497d3bfb6d5537fc6"},{"sha":"31203efcb20b7efcbad5984b377ad87c58673dbc","author":{"name":"Ewen Cheslack-Postava","email":"b4a5ea001e047040e8c9075b67a268293138da2c@ewencp.org"},"message":"MINOR: Clarify how to fix conversion issues when plain JSON data is used with schemas.enable=true\n\nAuthor: Ewen Cheslack-Postava <me@ewencp.org>\n\nReviewers: Ismael Juma <ismael@juma.me.uk>\n\nCloses #2041 from ewencp/clarify-json-converter-failure","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/31203efcb20b7efcbad5984b377ad87c58673dbc"},{"sha":"b902ef985a8d4ce304950fcb2c02499054fe6d24","author":{"name":"Ismael Juma","email":"e6abb59dc9dfc569a27afac0f1a05d72488c0302@juma.me.uk"},"message":"MINOR: Remove unused `ByteBoundedBlockingQueue` class and `zkSessionTimeout` parameter\n\nAuthor: Ismael Juma <ismael@juma.me.uk>\n\nReviewers: Jason Gustafson <jason@confluent.io>\n\nCloses #2136 from ijuma/remove-unused-code","distinct":true,"url":"https://api.github.com/repos/miguno/kafka/commits/b902ef985a8d4ce304950fcb2c02499054fe6d24"}]}
{"actor":{"display_login":"miguno"}}