{"push_id":817270815,"size":9,"distinct_size":9,"ref":"refs/heads/master","head":"48791c34776fe10373ef3abbc35d9b0fcfbda1e4","before":"4c5d43b6f51229cf1b593aec1554105f4efbc01e","commits":[{"sha":"4938ff09f692d7b8b1c3af16125d2216eb5c623c","author":{"email":"50f957e7ebf7b4286b7f73838f5eec431c788506@apache.org","name":"twalthr"},"message":"[FLINK-2642] [table] Scala Table API crashes when executing word count example\n\nThis closes #1209.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/4938ff09f692d7b8b1c3af16125d2216eb5c623c"},{"sha":"906bd6dcb360665af0331faddb34e7260bfe7f1a","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[streaming] Removed unused StreamReduce\n\nRefactored corresponding tests, some minor cleanups.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/906bd6dcb360665af0331faddb34e7260bfe7f1a"},{"sha":"225704bc9912536042027fca1a9880beba3bc2bb","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[FLINK-2283] [streaming] grouped reduce and fold operators checkpoint state","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/225704bc9912536042027fca1a9880beba3bc2bb"},{"sha":"a76d9638e83947d491e6ae1edb82f020b6ba8f54","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[FLINK-2283] [streaming] Test for checkpointing in internal operators","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/a76d9638e83947d491e6ae1edb82f020b6ba8f54"},{"sha":"c414ea98ec6896fd9c011d421cb3e5c9587c8446","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[FLINK-2283] [streaming] Proper serialization of state in StreamGroupedFold and Reduce","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/c414ea98ec6896fd9c011d421cb3e5c9587c8446"},{"sha":"e494c2795252a7f3db3659b1919cc7c75fc3dbb9","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[FLINK-2812] [streaming] KeySelectorUtil interacts well with type extraction\n\nThe interaction is tested in the AggregationFunctionTest and the scala DataStreamTest amongst others.\n\nCloses #1155","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/e494c2795252a7f3db3659b1919cc7c75fc3dbb9"},{"sha":"b08669abf282c52b54c395b85e992edb8ca621d4","author":{"email":"09f96470664173820d592801c5693434bcb0aaa7@apache.org","name":"hsaputra"},"message":"[FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference\n\nRemove Pact word from class and file names in Apache Flink.\nPact was the name used in Stratosphere time to refer to concept of distributed datasets (similar to Flink Dataset). It was used when Pact and Nephele still separate concept.\n\nAs part of 0.10.0 release cleanup effort, let's remove the Pact names to avoid confusion.\n\nThe PR also contains small cleanups (sorry):\n1. Small refactor DataSinkTask and DataSourceTask to follow Java7 generic convention creation new collection. Remove LOG.isDebugEnabled check.\n2. Simple cleanup to update MapValue and TypeInformation with Java7 generic convention creation new collection.\n3. Combine several exceptions that have same catch operation.\n\nApologize for the extra changes with PR. But I separated them into different commits for easier review.\n\nAuthor: hsaputra <hsaputra@apache.org>\n\nCloses #1218 from hsaputra/remove_pact_name and squashes the following commits:\n\nb3c55b4 [hsaputra] Rename RegularTask to BatchTask per review.\ne278fac [hsaputra] Address review comments from chiwanpark (good catch).\n9f92f33 [hsaputra] Remove Pact from the file names of teh flink-runtime and flink-clients modules.\ndbb2175 [hsaputra] Simple cleanup to update MapValue with Java7 generic for new collection. Remove unused imports in CollectionsDataTypeTest.\ndf2f553 [hsaputra] Use Java7 style of type resolution for new collection.\n6403d44 [hsaputra] Remove the word Pact from the Javadoc for ChainedDriver.\n0c562f4 [hsaputra] Small refactor on DataSinkTask and DataSourceTask classes to keep up with modern Java practice.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/b08669abf282c52b54c395b85e992edb8ca621d4"},{"sha":"ff0a1a0b57ea239ef05d240ca9d9d5bd20d458ec","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"Revert \"[FLINK-2210] Table API support for aggregation on columns with null values\"\n\nThis reverts commit b59c81bc41f0fc4ade5359dfdf42549a76d412fa.\n\nThe commit had to be reverted because the RowSerializer is not in sync\nwith other comparators and serializers. See FLINK-2236.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/ff0a1a0b57ea239ef05d240ca9d9d5bd20d458ec"},{"sha":"48791c34776fe10373ef3abbc35d9b0fcfbda1e4","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"Revert \"[FLINK-2203] handling null values for RowSerializer\"\n\nThis reverts commit f8e12b20d925c3f6f24769327d1da5d98affa679.\n\nThe commit had to be reverted because the RowSerializer is not in sync\nwith other comperators and serializers. See FLINK-2236.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/48791c34776fe10373ef3abbc35d9b0fcfbda1e4"}]}