{"push_id":1136855847,"size":1000,"distinct_size":1476,"ref":"refs/heads/master","head":"fba33b3fe2ed6f492b3511a1dbb0c8027bb1b97c","before":"31c0c2925c63c2999aa831602f52601d33cd6b47","commits":[{"sha":"6019f085f0d3dadc20a11f900784ce2796a89ce0","author":{"name":"tedyu","email":"f3efda66e9dbf526c8baa4fd8c1378586ced3c51@gmail.com"},"message":"[FLINK-2826] [runtime] Fix race condition and locking in BroadcastVariableMaterialization#decrementReferenceInternal\n\nThis closes #1339","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/6019f085f0d3dadc20a11f900784ce2796a89ce0"},{"sha":"2063fa12d520818569e5cbb88d4123716f2da249","author":{"name":"Maximilian Michels","email":"0babbab6c2ab1e494e95176e73e7efe04dd4b11a@apache.org"},"message":"[license] remove flink-benchmark due to licensing issues\n\nIn addition to dd66e61ecc5da5b15a610f04b98c8386d141f910,\nremoves the left-over source files.","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/2063fa12d520818569e5cbb88d4123716f2da249"},{"sha":"824074aac620a940d33cb484f97e16c640d5d6b7","author":{"name":"zentol","email":"fb5e6fb623bb680e91c5624b0e3c6d5a76178a29@web.de"},"message":"[FLINK-2901] Move PythonAPI to flink-libraries\n\nThis closes #1257","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/824074aac620a940d33cb484f97e16c640d5d6b7"},{"sha":"955ce5304d549e255c5e439b5d65d685dd0c1df7","author":{"name":"Jun Aoki","email":"ecce374cf18111eb0d97a34f78a40b3400fe8944@apache.org"},"message":"[Documanation] Fix constructor name of WordWithCount example.\n\nThis closes #1325","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/955ce5304d549e255c5e439b5d65d685dd0c1df7"},{"sha":"946e8f648e283c3d91cbec56038215ee3aa3a408","author":{"name":"Ufuk Celebi","email":"78b56ba69f8ee462da352d0ec4ccfd5661b9c331@apache.org"},"message":"[docs] Update HA docs with YARN and state backend configuration","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/946e8f648e283c3d91cbec56038215ee3aa3a408"},{"sha":"30647a2e6b74563e441947ad2f5726d9627251c2","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-2432] Custom serializer support\n\nThis closes #962","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/30647a2e6b74563e441947ad2f5726d9627251c2"},{"sha":"b7cf642bca109dced7dc1a02e831405887d7a9a6","author":{"name":"Sachin Goel","email":"246b05330c5a921f285cb8127ae0e6f3256df695@gmail.com"},"message":"[FLINK-2797][cli] Add support for running jobs in detached mode from CLI\n\nThis closes #1214.","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/b7cf642bca109dced7dc1a02e831405887d7a9a6"},{"sha":"00e44eda17052c4b3de4f9690c250a45df6f407f","author":{"name":"Sachin Goel","email":"246b05330c5a921f285cb8127ae0e6f3256df695@gmail.com"},"message":"[FLINK-2850] Limit the types of jobs which can run in detached mode\n\nThis disallows the following types of interactive programs in detached\nmode:\n\n1. More than one call to execute\n\n2. Accessing job execution results like\naccumulators, net runtime, etc. This effectively disables eager\nexecution functions such as count, print, collect, etc. too","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/00e44eda17052c4b3de4f9690c250a45df6f407f"},{"sha":"9a911c88ec4b11300d72f41a7c51569e1d228a87","author":{"name":"Maximilian Michels","email":"0babbab6c2ab1e494e95176e73e7efe04dd4b11a@apache.org"},"message":"[FLINK-2994] minor correction for newlines","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/9a911c88ec4b11300d72f41a7c51569e1d228a87"},{"sha":"feb6994ffca04e4b7ad6174ca08048ea452e19f6","author":{"name":"smarthi","email":"460fb680219190d7266e67382bd0cb7298d502a9@apache.org"},"message":"[FLINK-3017] [Docu] Fix broken 'Slots' link on Streaming Guide.\n\nThis closes #1357","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/feb6994ffca04e4b7ad6174ca08048ea452e19f6"},{"sha":"aba377945a66f37198e4a16bb9256c180ffcae79","author":{"name":"Niels Basjes","email":"49ca49a8341c4b8217285575174ce60a9fa81538@basjes.nl"},"message":"[FLINK-2977] Using reflection to load HBase Kerberos tokens\n\nThis closes #1342","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/aba377945a66f37198e4a16bb9256c180ffcae79"},{"sha":"14c24e797ed9e8fcaab98fecbb7856e363175ea4","author":{"name":"smarthi","email":"460fb680219190d7266e67382bd0cb7298d502a9@apache.org"},"message":"FLINK-3022: Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/14c24e797ed9e8fcaab98fecbb7856e363175ea4"},{"sha":"bdb306a1152aa9938bde2cc536db540eb2ca40d0","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-3024] Fix TimestampExtractor.getCurrentWatermark() Behaviour\n\nPreviously the internal currentWatermark would be updated even if the\nvalue returned from getCurrentWatermark was lower than the current\nwatermark.\n\nThis can lead to problems with chaining because the watermark is\ndirectly forwarded without going through the watermark logic that\nensures correct behaviour (monotonically increasing).\n\nThis adds a test that verifies that the timestamp extractor does not\nemit decreasing watermarks.","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/bdb306a1152aa9938bde2cc536db540eb2ca40d0"},{"sha":"a654760299f6698b2a2673ca5b6ffba38b39ea4e","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[FLINK-3025] [kafka consumer] Bump transitive ZkClient dependency to 0.7 for bugfixes\n\nThis closes #1365","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/a654760299f6698b2a2673ca5b6ffba38b39ea4e"},{"sha":"e692a10801629d31a6cd06b8f173363ea060859d","author":{"name":"smarthi","email":"460fb680219190d7266e67382bd0cb7298d502a9@apache.org"},"message":"[hotfix] [utils] Change the parameter 'numSample' in DataSetUtils.sampleWithSize() to 'numSamples', remove redundant Java 6 code\n\nThis closes #1362","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/e692a10801629d31a6cd06b8f173363ea060859d"},{"sha":"1f52899a9bdbee67d038bba5e06baaec553afad6","author":{"name":"jaoki","email":"ecce374cf18111eb0d97a34f78a40b3400fe8944@apache.org"},"message":"[hotfix] [runtime] Minor javadoc fix in JobManager\n\nThis closes #1358\n\nJobExecutionVertices should be ExecutionJobVertices?\nI found it while I have been drawing a Flink local execution diagram.\nIt is still a half way but let me know if you have any feedback.\nhttps://docs.google.com/drawings/d/1lZg8LkhAlI5lMc2EGCPlYArBmv7cCj-By-phuG6rGE8/edit","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/1f52899a9bdbee67d038bba5e06baaec553afad6"},{"sha":"442fcb196f9bf9fada2278b78c8447e65f0c85e0","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-2914] [runtime] Add missing break Statement in ZKJobGraphStore\n\nThis closes #1359","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/442fcb196f9bf9fada2278b78c8447e65f0c85e0"},{"sha":"ffb8aecf2bf1ab64d2488ae37130f310f40b530e","author":{"name":"andralungu","email":"0b2438f3695d946a718ad9c8fdd42600160e57ac@gmail.com"},"message":"[FLINK-2879] [docs] Fixed broken links on the architecture page\n\nThis closes #1348","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/ffb8aecf2bf1ab64d2488ae37130f310f40b530e"},{"sha":"a45212d2b18cc12e3c314ed43e8d19943693deed","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[FLINK-2967] Increase timeout for LOCAL_HOST address detection strategy, give the local host address a higher priority\n\nThis closes #1391","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/a45212d2b18cc12e3c314ed43e8d19943693deed"},{"sha":"99d52cc69d660e559a0e37978edfa33ec3923948","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[hotfix][docs] Replace Count.of() with appropriate Count(Trigger|Evictor).of()","distinct":true,"url":"https://api.github.com/repos/jamescao/flink/commits/99d52cc69d660e559a0e37978edfa33ec3923948"}]}
{"actor":{"display_login":"jamescao"}}