{"push_id":1406999394,"size":6,"distinct_size":6,"ref":"refs/heads/master","head":"a5ec8494c56ef8c58ba49dc95df89796e91544d3","before":"611412c6b4072077adba21250e2244094be93764","commits":[{"sha":"fa1864c7a6eadea55eb2d7e8fd2b72e043841671","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[hotfix] [Kafka Consumer] Clean up some code confusion and style in the Fetchers for Kafka 0.9/0.10","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-flink/commits/fa1864c7a6eadea55eb2d7e8fd2b72e043841671"},{"sha":"a66e7ad14e41fa07737f447d68920ad5cc4ed6d3","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[FLINK-5048] [kafka consumer] Change thread model of FlinkKafkaConsumer to better handel shutdown/interrupt situations\n\nPrior to this commit, the FlinkKafkaConsumer (0.9 / 0.10) spawns a separate thread that operates Kafka's consumer.\nThat thread ws shielded from interrupts, because the Kafka Consumer has not been handling thread interrupts well.\nSince that thread was also the thread that emitted records, it would block in the network stack (backpressure) or in chained operators.\nThe later case lead to situations where cancellations got very slow unless that thread would be interrupted (which it could not be).\n\nThis commit changes the thread model:\n  - A spawned consumer thread polls a batch or records from the KafkaConsumer and pushes the\n    batch of records into a blocking queue (size one)\n  - The main thread of the task will pull the record batches from the blocking queue and\n    emit the records.","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-flink/commits/a66e7ad14e41fa07737f447d68920ad5cc4ed6d3"},{"sha":"cf78542232e9bed62fbb1a0de568bf26adbdb098","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"Revert \"[hotfix] [cassandra] [tests] Show error log messages\"\n\nThis reverts commit 1adefee2eff9c9b4267f5b5e10022255cfcaf47a.","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-flink/commits/cf78542232e9bed62fbb1a0de568bf26adbdb098"},{"sha":"95d640b832a91b05d6031dbb09086206369666d3","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"Revert \"[hotfix] [cassandra] Fix CassandraSinkBase serialization issue\"\n\nThis reverts commit 5fa389014a3ce40534703c8a5731c8a9a955058a.","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-flink/commits/95d640b832a91b05d6031dbb09086206369666d3"},{"sha":"02c10d312371aaad12ed8961cdf96288fe78a983","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"Revert \"[FLINK-4177] Harden CassandraConnectorITCase\"\n\nThis reverts commit 62523acbe175cf159fe1b4ab6cf5c0412fc4d232.","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-flink/commits/02c10d312371aaad12ed8961cdf96288fe78a983"},{"sha":"a5ec8494c56ef8c58ba49dc95df89796e91544d3","author":{"name":"sergey_sokur","email":"30be61467d9379545f64c6c0e55188855474fba8@gmail.com"},"message":"[hotfix] [tests] Corrected log4j files.\n\nThis closes #2814","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-flink/commits/a5ec8494c56ef8c58ba49dc95df89796e91544d3"}]}
{"actor":{"display_login":"ueshin"}}