{"push_id":1308099415,"size":229,"distinct_size":229,"ref":"refs/heads/trunk","head":"4f821830bc6b726cddf90999fff76006745b1a3f","before":"a34f78dcad1d7844a21d0afbf0f6eef183847d0d","commits":[{"sha":"7e9f5a7ee6dfe22107c8cc3c9f57daa288d6c392","author":{"name":"Matthias J. Sax","email":"50acca05af79804b01d430d231b3b71dcc4d995e@confluent.io"},"message":"HOTFIX: Check JoinWindow boundaries\n\nguozhangwang\n\nAuthor: Matthias J. Sax <matthias@confluent.io>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1575 from mjsax/hotfix2","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/7e9f5a7ee6dfe22107c8cc3c9f57daa288d6c392"},{"sha":"7d6b416f9e75f1d9f886b9b43637c488667222e1","author":{"name":"Henry Cai","email":"6191956cd9b80e22763ed3c46754d3de8494ca85@pinterest.com"},"message":"KAFKA-3740: Part I: expose StreamConfig properties in ProcessorContext\n\nThis is the part I of the work to add the StreamsConfig to ProcessorContext.\n\nWe need to access StreamsConfig in the ProcessorContext so other components (e.g. RocksDBWindowStore or LRUCache can retrieve config parameter from application)\n\nAuthor: Henry Cai <hcai@pinterest.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1553 from HenryCaiHaiying/config","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/7d6b416f9e75f1d9f886b9b43637c488667222e1"},{"sha":"3605ffa30602ebf9373b47f92f2a9f399a4a36db","author":{"name":"Yuto Kawamura","email":"b39723c7e6f56dc3cd4be5b06c58d1e3458db05c@gmail.com"},"message":"MINOR: Fix ambiguous log message in RecordCollector\n\nWhen producing fails in Kafka Streams, it gives an error like below:\n\n```\nError sending record: null\n```\n\nby this line: https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java#L59\n\nThis isn't not making sense because of:\n- Practically metadata is always null when exception != null : https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordBatch.java#L107-L109\n- It's quite misleading as we would interpret it like \"Kafka Streams attempted to send 'null' as a record\" which isn't in fact\n\nAs I find a PR #873  as the origin of the above line I changed it to instantiate callback on each send in order to log destination topic at least.\n\nAuthor: Yuto Kawamura <kawamuray.dadada@gmail.com>\n\nReviewers: Ismael Juma <ismael@juma.me.uk>, Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1555 from kawamuray/MINOR-record-collector-log-message","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/3605ffa30602ebf9373b47f92f2a9f399a4a36db"},{"sha":"44ad7b574e376f958cf1d3893156d666f904cdd3","author":{"name":"Shikhar Bhushan","email":"295367247747ce57c9516ff4d6f5e4f21f3accf0@confluent.io"},"message":"KAFKA-3846: KIP-65: include timestamp in Connect record types\n\nhttps://cwiki.apache.org/confluence/display/KAFKA/KIP-65%3A+Expose+timestamps+to+Connect\n\nAuthor: Shikhar Bhushan <shikhar@confluent.io>\n\nReviewers: Jason Gustafson <jason@confluent.io>, Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1537 from shikhar/kafka-3846","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/44ad7b574e376f958cf1d3893156d666f904cdd3"},{"sha":"7edaa3dd89d1a7300a12e101e23f66459a9cc33d","author":{"name":"Alex Loddengaard","email":"5c9e478f4d2660299134c9627c4f333f08fc4c05@gmail.com"},"message":"MINOR: bug fixes to ducktape services\n\nHere's a (mostly successful) run with these changes:\n\nhttp://testing.confluent.io/confluent-kafka-branch-builder-system-test-results/?prefix=2016-06-27--001.1467080884--alexlod--ducktape-fixes--ad85493/\n\nAt least one of the failed tests is failing in trunk, too:\n\nhttp://testing.confluent.io/confluent-kafka-branch-builder-system-test-results/?prefix=2016-06-28--001.1467090978--alexlod--ducktape-fixes--ad85493/\n\nThe contribution is my original work and I license the work to the project under the project's open source license.\n\nAuthor: Alex Loddengaard <alexloddengaard@gmail.com>\n\nReviewers: Geoff Anderson <geoff@confluent.io>, Ismael Juma <ismael@juma.me.uk>, Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1566 from alexlod/ducktape-fixes","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/7edaa3dd89d1a7300a12e101e23f66459a9cc33d"},{"sha":"5a97304170a697cb08f1c8d455d6661a37f92196","author":{"name":"Shikhar Bhushan","email":"295367247747ce57c9516ff4d6f5e4f21f3accf0@confluent.io"},"message":"MINOR: fix Bash shebang on vagrant/ scripts\n\nAuthor: Shikhar Bhushan <shikhar@confluent.io>\n\nReviewers: Geoff Anderson <geoff@confluent.io>, Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1567 from shikhar/vagrant-scripts-shebang","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/5a97304170a697cb08f1c8d455d6661a37f92196"},{"sha":"2098529b44cad78731e478aa8af2b49e9c94db7d","author":{"name":"Philippe Derome","email":"356f792a0d7f684a0af82d084c3cf99f4ea86ed5@gmail.com"},"message":"KAFKA-3902: Optimize KTable.filter in Streams DSL to avoid forwarding if both old and new values are null\n\nThe contribution is my original work and that I license the work to the project under the project's open source license.\n\nContributors: Guozhang Wang, Phil Derome\nguozhangwang\n\nAdded checkEmpty to validate processor does nothing  and added a inhibit check for filter to fix issue.\n\nAuthor: Philippe Derome <phderome@gmail.com>\nAuthor: Phil Derome <phderome@gmail.com>\nAuthor: Damian Guy <damian.guy@gmail.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1556 from phderome/DEROME-3902","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/2098529b44cad78731e478aa8af2b49e9c94db7d"},{"sha":"32e24b7c28e357c051bbe21b08c4e8c6d45a3907","author":{"name":"Kenji Yoshida","email":"feb0a2117846c0eb36aa0edbf630005a1b84bd53@gmail.com"},"message":"MINOR: remove \"auto.commit.interval.ms\" from \"Manual Offset Control\" example\n\nAuthor: xuwei-k <6b656e6a69@gmail.com>\n\nReviewers: Ismael Juma <ismael@juma.me.uk>\n\nCloses #1578 from xuwei-k/Manual-Offset-Control-example","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/32e24b7c28e357c051bbe21b08c4e8c6d45a3907"},{"sha":"f1323d4ffa451b8c7965d51f422f0933f35ff828","author":{"name":"Grant Henke","email":"92cb0c65dbf8ff1baaf010de530f6f36b8383062@gmail.com"},"message":"MINOR: Fix consumer constructor doc string\n\nAuthor: Grant Henke <granthenke@gmail.com>\n\nReviewers: Ismael Juma <ismael@juma.me.uk>\n\nCloses #1568 from granthenke/consumer-doc","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/f1323d4ffa451b8c7965d51f422f0933f35ff828"},{"sha":"0f8b6790351cb6b078ad3ec73e8d36f5bb3ad270","author":{"name":"Thanasis Katsadas","email":"d92a2f699faea86700b8f2d01de271352cf1d904@gmail.com"},"message":"MINOR: Typo fix in docs ops\n\nAuthor: Thanasis Katsadas <thanasis00@gmail.com>\n\nReviewers: Ismael Juma <ismael@juma.me.uk>\n\nCloses #1552 from thanasis00/trunk","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/0f8b6790351cb6b078ad3ec73e8d36f5bb3ad270"},{"sha":"31b4460cf9a520bd019ed98949ebfa9243e6e4a6","author":{"name":"Sriharsha Chintalapani","email":"9ca9e76739bbdf0ff40f91fca8d64b08ea934321@hortonworks.com"},"message":"MINOR: Warning instead of error if TGT cannot be renewed beyond the next expiry date\n\nAuthor: Sriharsha Chintalapani <harsha@hortonworks.com>\n\nReviewers: Gwen Shapira <cshapi@gmail.com>, Ismael Juma <ismael@juma.me.uk>\n\nCloses #1510 from harshach/KerberosLogin-Log","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/31b4460cf9a520bd019ed98949ebfa9243e6e4a6"},{"sha":"d7de59a579af5ba4ecb1aec8fed84054f8b86443","author":{"name":"Vahid Hashemian","email":"3cbd77b9f48a475f3d76cb73e4791ace5a0d82d4@us.ibm.com"},"message":"KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern) subscriptions\n\nThis patch fixes two issues:\n1. Subsequent regex subscriptions fail with the new consumer.\n2. Subsequent regex subscriptions would not immediately refresh metadata to change the subscription of the new consumer and trigger a rebalance.\n\nThe final note on the JIRA stating that a later created topic that matches a consumer's subscription pattern would not be assigned to the consumer upon creation seems to be as designed. A repeat\n`subscribe()` to the same pattern or some wait time until the next automatic metadata refresh would handle that case.\n\nAn integration test was also added to verify these issues are fixed with this PR.\n\nAuthor: Vahid Hashemian <vahidhashemian@us.ibm.com>\n\nReviewers: Jason Gustafson <jason@confluent.io>, Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1572 from vahidhashemian/KAFKA-3854","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/d7de59a579af5ba4ecb1aec8fed84054f8b86443"},{"sha":"87b3ce16c05eb105f1ee0da26b090e02b6c18678","author":{"name":"Alex Glikson","email":"2ebe26693ff5882c6b32d6fc7f2eaf8c50a8796d@il.ibm.com"},"message":"MINOR: Fix few documentation errors in streams quickstart\n\nPlus a minor enhancement\n\nAuthor: glikson <glikson@il.ibm.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1571 from glikson/patch-1","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/87b3ce16c05eb105f1ee0da26b090e02b6c18678"},{"sha":"12fa188b9aaeafa337c813f4a84a3117d6bf403f","author":{"name":"Matthias J. Sax","email":"50acca05af79804b01d430d231b3b71dcc4d995e@confluent.io"},"message":"HOTFIX: Auto-repartitioning for merge() and code simplifications\n\nfollow-up to auto-through feature:\n - add sourceNode to transform()\n - enable auto-repartitioning in merge()\n - null check not required anymore (always join-able due to auto-through)\n\nAuthor: Matthias J. Sax <matthias@confluent.io>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1580 from mjsax/hotfix","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/12fa188b9aaeafa337c813f4a84a3117d6bf403f"},{"sha":"416c3a7d97d473d0d9928c814d68d502c21077b7","author":{"name":"Damian Guy","email":"a352d70b5750eea9e7969230d96f9ec481f91a1c@gmail.com"},"message":"MINOR: Fix generics in KStream.groupBy(...)\n\nThe `KStream.groupBy(..)` calls don't change the value, only the key, so they don't need the type param `V1` as the new stream will always be of type `KStream<K1, V>`.\nThe `Serde` in the overloaded `groupBy` should have a type param of  `V` to match the returned `KStream`\n\nAuthor: Damian Guy <damian.guy@gmail.com>\n\nReviewers: Matthias J. Sax, Guozhang Wang\n\nCloses #1584 from dguy/kstream-generics","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/416c3a7d97d473d0d9928c814d68d502c21077b7"},{"sha":"dca263b4e00b00983a4b9f74517b25b01492a4c6","author":{"name":"Damian Guy","email":"a352d70b5750eea9e7969230d96f9ec481f91a1c@gmail.com"},"message":"MINOR: fix generics in Windows.segments and Windows.until\n\n`Windows.segments(...)` and `Windows.until(...)` currently aren't returning the `Window` with its type param `W`. This causes the generic type to be lost and therefore methods using this can't infer the correct return types.\n\nAuthor: Damian Guy <damian.guy@gmail.com>\n\nReviewers: Matthias J. Sax, Guozhang Wang\n\nCloses #1587 from dguy/windows-generics","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/dca263b4e00b00983a4b9f74517b25b01492a4c6"},{"sha":"15e008783cf73dcaed851fe6cc587767031886e5","author":{"name":"Moritz Siuts","email":"3bbf72a35e4ca2947b084cf3207f28e5c9d7f60a@emetriq.com"},"message":"KAFKA-3802; log mtimes reset on broker restart / shutdown\n\nThere seems to be a bug in the JDK that on some versions the mtime of\nthe file is modified on FileChannel.truncate() even if the javadoc states\n`If the given size is greater than or equal to the file's current size then\n the file is not modified.`.\n\nThis causes problems with log retention, as all the files then look like\nthey contain recent data to Kafka. Therefore this is only done if the channel size is different to the target size.\n\nAuthor: Moritz Siuts <m.siuts@emetriq.com>\n\nReviewers: Jun Rao <junrao@gmail.com>, Ismael Juma <ismael@juma.me.uk>\n\nCloses #1497 from msiuts/KAFKA-3802-log_mtimes_reset_on_broker_shutdown","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/15e008783cf73dcaed851fe6cc587767031886e5"},{"sha":"b64302f9cea0e3e95d740cbe7bbd4c64e147301c","author":{"name":"Bill Bejeck","email":"cd735052505ca456aac5be887ebb94a0125946fe@gmail.com"},"message":"KAFKA-3794: added stream / table names as prefix to print / writeAsText\n\n…int to the console.\n\nAuthor: bbejeck <bbejeck@gmail.com>\n\nReviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1577 from bbejeck/KAFKA-3794-add-prefix-to-print-functions","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/b64302f9cea0e3e95d740cbe7bbd4c64e147301c"},{"sha":"7218648ae7ac1ce93f3ff25702b99c3af236fd0f","author":{"name":"Jeyhun Karimov","email":"ddc7fb06c7377a7c2dc4512c0e11d8962713a563@gmail.com"},"message":"KAFKA-3836: KStreamReduce and KTableReduce should not pass nulls to Deserializers\n\nMinor changes to check null changes.\n\nAuthor: Jeyhun Karimov <je.karimov@gmail.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1591 from jeyhunkarimov/KAFKA-3836","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/7218648ae7ac1ce93f3ff25702b99c3af236fd0f"},{"sha":"efc4c88811c93d11eeffe61310b7f8652ca73ceb","author":{"name":"Bill Bejeck","email":"cd735052505ca456aac5be887ebb94a0125946fe@gmail.com"},"message":"KAFKA-3926: Fix transient test failure in RegexSourceIntegrationTest\n\n…Tasks call versus simply asserting createStreamTasks method called.\n\nAuthor: bbejeck <bbejeck@gmail.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1590 from bbejeck/KAFKA-3926-transient-failures-regex-source-integration-test","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/efc4c88811c93d11eeffe61310b7f8652ca73ceb"}]}
{"actor":{"display_login":"fpj"}}