{"push_id":664632655,"size":52,"distinct_size":52,"ref":"refs/heads/master","head":"a35c7201e010ee34629a7fbd9ffcd9b149fe5f93","before":"bd96ba8d1bbdc494ac88b98a6469255572f4a9fc","commits":[{"sha":"b3cb5e7e67f615f363424e84b623605bf128a3c9","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[streaming] Added naming for streaming operators\n\nThis improves tracking of jobs.\n\nCloses #654","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/b3cb5e7e67f615f363424e84b623605bf128a3c9"},{"sha":"8ea840e2fa609ed756422d87f10e8f6b1f90a2df","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"Removed legally questionable tweet data","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/8ea840e2fa609ed756422d87f10e8f6b1f90a2df"},{"sha":"faac20315b365e5d5dd800893bc5f04395aba2cf","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[runtime] Fix Netty watermark configuration\n\nThe watermarks of the NettyServer, which is responsible for data transfers, were\nnot configured correctly. Instead they were configured for the NettyClient, which\ndoes need this fine-grained control as it does not transfer a lot of data.\n\nPreviously, the default watermarks matched our desired watermarks of 64k (for our\ndefault page size) by chance.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/faac20315b365e5d5dd800893bc5f04395aba2cf"},{"sha":"0078c44e59a368f5564ef6a151aea2f351a2e2c8","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-1978] Fix POJO deserialization for reuse objects with NULL fields\n\nThis closes #655","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/0078c44e59a368f5564ef6a151aea2f351a2e2c8"},{"sha":"68924031594e4793becb884436b0964540f5151c","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[streaming] [api-breaking] Changed returntype of WindowedDataStream's mapWindow\n\nFor a more consistent behaviour.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/68924031594e4793becb884436b0964540f5151c"},{"sha":"2f08d9d561de5789a2ef784411f6f4a9ed4afb9f","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-1937] [ml] Fixes sparse vector/matrix creation fromCOO with a single element\n\nThis closes #636.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/2f08d9d561de5789a2ef784411f6f4a9ed4afb9f"},{"sha":"ddb2b34704a410491d428dec2ade0cb20a58ed80","author":{"email":"f55f5fad55aaea3a24db3b0da6267c06dda1c57a@icloud.com","name":"Chiwan Park"},"message":"[FLINK-1933] [ml] Adds distance metrics and documentation to machine learning library\n\n[ml] [docs] Add a overview documentation for Distance Metrics\n\n[FLINK-1933] [ml] Moves metrics.distances package to org.apache.flink.ml\n\nThis closes #629.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/ddb2b34704a410491d428dec2ade0cb20a58ed80"},{"sha":"ce2163e6c987a9fbd9235f6e5b24c0aa8e475b04","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[gelly] removes generic type constraints\n\nThis closes #657","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/ce2163e6c987a9fbd9235f6e5b24c0aa8e475b04"},{"sha":"778cda7a57540a65b9f5e0c48e32bcadbc2022b7","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[ml] [docs] Adds distance formulas to documentation. Automatically include latex_commands.html with mathjax markdown files.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/778cda7a57540a65b9f5e0c48e32bcadbc2022b7"},{"sha":"f0b45c45078742dfbc43d9513a38e26e3f9a62f2","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[scala] Introduces trait type to TypeAnalyzer which avoids compiler warnings due to misclassification as a pojo type","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/f0b45c45078742dfbc43d9513a38e26e3f9a62f2"},{"sha":"2939fba3fbe594bbee6babdb7c223a93c45eef64","author":{"email":"f673f1e5a4e3968f7234d6d5284a8476e9f90573@sics.se","name":"Theodore Vasiloudis"},"message":"[FLINK-1807] [ml] Adds optimization framework and SGD solver.\n\nAdded Stochastic Gradient Descent initial version and some tests.\n\nAdded L1, L2 regularization.\n\nAdded tests for regularization, fixed parameter setting.\n\nAdded documentation.\n\nAdded option to provide UDF for the prediction function, moved SGD regularization to update step.\n\nAdded prediction function class to allow non-linear optimization in the future.\n\nSmall refactoring to allow calculation of regularized loss separatly from\nregularized gradient.\n\nThis closes #613.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/2939fba3fbe594bbee6babdb7c223a93c45eef64"},{"sha":"3b8f60e9b6f65485db280124e5368f111b558e27","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-1997][table] Add <> and != for un-equal in expressions","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/3b8f60e9b6f65485db280124e5368f111b558e27"},{"sha":"84dcb7c20f5d67dbb5a931ab56e68594e491034b","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-1998][table] Fix equals expression\n\nThe code that was generated for this used \"==\", now it uses .equals()","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/84dcb7c20f5d67dbb5a931ab56e68594e491034b"},{"sha":"bc8f1978c9f553064047b275645944a10fc6531a","author":{"email":"30fe1a8f5dd93099e33b9e2531a4af9bb5e18fc8@gmail.com","name":"bhatsachin"},"message":"[FLINK-1792] Add processCPULoad in metricsRegistry, add button to\nshow/hide graphs, add summary for metrics\n\nThis closes #553\n\n(Also close the mesos pull request)\nThis closes #251","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/bc8f1978c9f553064047b275645944a10fc6531a"},{"sha":"170366c9003424f3847d2658df6f29d2f63c3e2c","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[streaming] Made constructor of GroupedDataStream public","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/170366c9003424f3847d2658df6f29d2f63c3e2c"},{"sha":"7e5a97062c8d5d322be81a9d8af35f942a929f57","author":{"email":"c74e059bc827b84292cec407df5549863ef2dda9@gmail.com","name":"Johannes"},"message":"[FLINK-1974] Fix getNetRuntime() of JobExecutionResult and add documentation\n\n- Fix JobInfo to report milliseconds\n- Added documentation to indicate that the return type is in milliseconds\n- Added an getNetRuntime method which accepts a desired time unit for easy conversion\n\nThis closes #652","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/7e5a97062c8d5d322be81a9d8af35f942a929f57"},{"sha":"d259e6962186135f5d8d4e7a9fbb9b053756477a","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[docs] Fix broken links in documentation","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/d259e6962186135f5d8d4e7a9fbb9b053756477a"},{"sha":"acca10ea0a94cac56fe53258fa145c777ad4ea67","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[streaming] New Source and state checkpointing interfaces that allow operations to interact with the state checkpointing in a more precise manner.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/acca10ea0a94cac56fe53258fa145c777ad4ea67"},{"sha":"1c8d866a83065e3d1bc9707dab81117f24c9f678","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-1968] [runtime] Clean up and improve the distributed cache.\n\n - Gives a proper exception when a non-cached file is accessed\n - Forwards I/O exceptions that happen during file transfer, rather than only returning null when transfer failed\n - Consistently keeps reference counts and copies only when needed\n - Properly removes all files when shutdown\n - Uses a shutdown hook to remove files when process is killed","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/1c8d866a83065e3d1bc9707dab81117f24c9f678"},{"sha":"1d368a4b77f3ea53809e622564c87b657547c405","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[runtime] Fix TaskExecutionState against non-serializable exceptions.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/1d368a4b77f3ea53809e622564c87b657547c405"}]}