{"push_id":689644096,"size":46,"distinct_size":0,"ref":"refs/heads/master","head":"2eb5cfeb2dad061aa8e84040bd648b5198d2d142","before":"86692e55fe64b1e7776acaba726db55dabf9defe","commits":[{"sha":"b5e55918c0e6f51df00d2d39548d12f1b7710aa5","author":{"email":"1269c6af9ef0c1717d22b50e45144beaa00ec5fd@gronau.neofonie.priv","name":"yildirim"},"message":"[hbase] Add a stream data sink for HBase\n\nThis closes #706","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/b5e55918c0e6f51df00d2d39548d12f1b7710aa5"},{"sha":"8e49e7b5b7b3f889b45c5bba3a4164540b2a507e","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[streaming] Minor cleanups on data stream.","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/8e49e7b5b7b3f889b45c5bba3a4164540b2a507e"},{"sha":"23a364616f0cec1a7c58a9edb308d83652ea68ea","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[streaming] [scala] ITCases for streaming scala examples","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/23a364616f0cec1a7c58a9edb308d83652ea68ea"},{"sha":"39010dce426936f66a3f9440e77d5c4edadd7bd9","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[streaming] Removed StockPrices example\n\nThe purpose of this was to serve as an example for a blogpost.\nMoved it to another branch and removed it from the master.\n\nCloses #777","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/39010dce426936f66a3f9440e77d5c4edadd7bd9"},{"sha":"6685b0bac54b95705426fd78bb819171271004e6","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-2098] Ensure checkpoints and element emission are in order\n\nBefore, it could happen that a streaming source would keep emitting\nelements while a checkpoint is being performed. This can lead to\ninconsistencies in the checkpoints with other operators.\n\nThis also adds a test that checks whether only one checkpoint is\nexecuted at a time and the serial behaviour of checkpointing and\nemission.\n\nThis changes the SourceFunction interface to have run()/cancel() methods\nwhere the run() method takes a lock object on which it needs to\nsynchronize updates to state and emission of elements.","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/6685b0bac54b95705426fd78bb819171271004e6"},{"sha":"f4195ac02764b92622316e83fa4dd31b864f2375","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2098] Improvements on checkpoint-aligned sources","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/f4195ac02764b92622316e83fa4dd31b864f2375"},{"sha":"da8aa10891e178f006d254ffc05e5b4cdba0870a","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"[FLINK-1229][docs] Updated web client documentation\n - WebClient assembler class flag is '-c' (not 'assembler')\n - doc-building script is named 'build_docs.sh' (not '_build_docs.sh')","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/da8aa10891e178f006d254ffc05e5b4cdba0870a"},{"sha":"92d3251261808f72bb5ef390ac1cf9b396f1d185","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-2123] Fix log4j warnings on CliFrontend startup\n\nThis closes #783","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/92d3251261808f72bb5ef390ac1cf9b396f1d185"},{"sha":"0d00836ae21e2ec062bbce017d123f68e4d3a150","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[javadoc] fix link not found errors on jdk8","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/0d00836ae21e2ec062bbce017d123f68e4d3a150"},{"sha":"17cb647b56bbd39777c4b38d481bd532757c932f","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-1892] [tez] Bump Tez dependency to 0.6.1 from 0.6.0 to include tez bugfixes","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/17cb647b56bbd39777c4b38d481bd532757c932f"},{"sha":"4b9e34047095da2e6a9425f67462409033a3cf14","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[tests] Increase timeouts for process failure tests in order to compensate for volatile CI environments (Travis)","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/4b9e34047095da2e6a9425f67462409033a3cf14"},{"sha":"235b02cb56d24bb5db3c254fa34661ccc0e1a083","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-2160] Change Streaming Source Interface to run(Context)/cancel()\n\nThe context can be used to emit elements and retrieve the checkpointing\nlock object.\n\nIn the future, the context can be extended to provide support for\nelement emission with timestamps and dealing with the watermark system.","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/235b02cb56d24bb5db3c254fa34661ccc0e1a083"},{"sha":"9b88184518c6f23f1a0f18d68623e4909b3c4476","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-2165] [TableAPI] Renamed table conversion functions in TableEnvironment\n\nThis closes #793","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/9b88184518c6f23f1a0f18d68623e4909b3c4476"},{"sha":"3e6b6beab360b5961cdb2b6d0887f5a31634aa23","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[FLINK-2002] [streaming] Test for iterations being gracefully shut down\n\nThe fix was done by gyfora in fdac963.","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/3e6b6beab360b5961cdb2b6d0887f5a31634aa23"},{"sha":"86e84258535a41533248a408cbf10e770f032659","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-1126][docs] Best practice: named TupleX types\n\nThis closes #786","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/86e84258535a41533248a408cbf10e770f032659"},{"sha":"8a52076102d8c6e63d0c3a81cde6cc86ffc8033b","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-1565][FLINK-2078] Document ExecutionConfig and object reuse behavior\n\nThis closes #781","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/8a52076102d8c6e63d0c3a81cde6cc86ffc8033b"},{"sha":"2298cfedbf880b3a6065a307224c5f3e9e326a0b","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2133] [jobmanager] Fix possible deadlock when vertices transition to final state.","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/2298cfedbf880b3a6065a307224c5f3e9e326a0b"},{"sha":"f72e5c8cd781b2d32aa89fd62f3b0b8c78ded0f8","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[FLINK-2139] [streaming] Streaming outputformat tests","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/f72e5c8cd781b2d32aa89fd62f3b0b8c78ded0f8"},{"sha":"e3402c0caccd6cc3bb85529909e23d85946efc17","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[streaming] Socket Client Sink propagates exceptions\n\nCloses #789","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/e3402c0caccd6cc3bb85529909e23d85946efc17"},{"sha":"89586036c0f328f20bd8f57a42d38268b4a0b42f","author":{"email":"9beaf097787bf06881ac92a7a204ca2dfeb8fbc6@gmail.com","name":"Gábor Hermann"},"message":"[FLINK-2136] [streaming] Added test for scala DataStream","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/89586036c0f328f20bd8f57a42d38268b4a0b42f"}]}