{"push_id":831834229,"size":53,"distinct_size":1,"ref":"refs/heads/pmml","head":"aaf5f5864f9f74ff197b9dc5cc6f014281d21ff7","before":"e40524ed04dc60568d813daa0ea513b213b3e516","commits":[{"sha":"fa2bb8f119f747a24bb013a4387ded5c51348ee7","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-2790] [yarn] [ha] Add high availability support for Yarn\n\nThis squashes the following commits:\n- Refactor JobManager's start actors method to be reusable\n- Yarn refactoring to introduce yarn testing functionality\n- Add support for testing yarn cluster. Extracted JobManager's and TaskManager's testing messages into stackable traits.\n- Implement YarnHighAvailabilityITCase using Akka messages for synchronization.\n- Logging statements\n- Fix registration at JobManager when the leader address is null\n- Fix curator dependency conflict\n- Shades Flink's curator dependency in flink-runtime so that it cannot be overriden by external dependencies in the class path. This solves the problem with Hadoop 2.6.0 which adds Curator 2.6.0 to the class path. The curator version of this Hadoop version is not compatible to Flink's Curator version 2.8.0. Furthermore, Flink's Guava version is forced to be included in flink-shaded-curator jar to avoid to many different Guava version in the resulting dist jar.\n- Unify two shade executions of flink-runtime into one\n- Exclude log4j and slf4j-log4j12 dependency from flink-shaded-curator\n- Set default number of application attempts to 1 in standalone case\n\nThis closes #1213","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/fa2bb8f119f747a24bb013a4387ded5c51348ee7"},{"sha":"0ee0c1f5573ad059dc6a8e4489094b7f78267306","author":{"email":"50f957e7ebf7b4286b7f73838f5eec431c788506@apache.org","name":"twalthr"},"message":"[FLINK-1789][core][runtime] Allow adding of URLs to the usercode class loader\n\nThis closes #593.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/0ee0c1f5573ad059dc6a8e4489094b7f78267306"},{"sha":"b2b2781fd04a14807849fdc41e4b5ecb8ab75f13","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[hotfix] Change result of WindowedStream ops to SingleOutputStreamOperator","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/b2b2781fd04a14807849fdc41e4b5ecb8ab75f13"},{"sha":"0c1141abcd0f58dcf2ec9abcccd47c5e5410b074","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-2780] Remove Old Windowing Logic and API\n\nThis rewrites the few examples and tests that are remaining using the\nnew Windowing API.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/0c1141abcd0f58dcf2ec9abcccd47c5e5410b074"},{"sha":"9a21ab1175c2f04446a44684bfd8b5e74404f4fe","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-2550] Rename extractTimestmp() to assignTimestamps()\n\nThis also changed TimestampExtractor.emitWatermark() to\nTimestampExtractor.extractWatermark().","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/9a21ab1175c2f04446a44684bfd8b5e74404f4fe"},{"sha":"c9088a491a459e44be41b074054a11883abef5c8","author":{"email":"1dc673e4ad3419cf51d1e2606f688dd937061d98@gmail.com","name":"Kostas Tzoumas"},"message":"[FLINK-2779] Update documentation to reflect new Stream/Window API","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/c9088a491a459e44be41b074054a11883abef5c8"},{"sha":"998be1bbbc823e1299dcb6bfe56774ec2f7286ab","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@apache.org","name":"mjsax"},"message":"[FLINK-2831] [Storm Compatibility] Failing Test: WrapperSetupHelperTest","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/998be1bbbc823e1299dcb6bfe56774ec2f7286ab"},{"sha":"04558574cf27e567f1ba0afdcaa888aa001f7ffa","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[hotfix] Fix wrong reference to WindowedDataStream in Doc","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/04558574cf27e567f1ba0afdcaa888aa001f7ffa"},{"sha":"6b2222762fc38d84b31170216d6b6ae0c272af9b","author":{"email":"137786487c59fd1095e9d24db45c238b72c2dd2b@campus.tu-berlin.de","name":"r-pogalz"},"message":"[FLINK-2576] Add outer join base operator.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/6b2222762fc38d84b31170216d6b6ae0c272af9b"},{"sha":"b00c1d7e7b83a3f2e42223fe97dd369755f884c3","author":{"email":"b1c1d8736f20db3fb6c1c66bb1455ed43909f0d8@jkovacs.de","name":"Johann Kovacs"},"message":"[FLINK-2576] [javaAPI] [scalaAPI] [optimizer] Add outerJoin to DataSet API (Java, Scala) and optimizer.\n\nThis closes #1138","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/b00c1d7e7b83a3f2e42223fe97dd369755f884c3"},{"sha":"1272cd5d0c477fea90753dcc1b39736db56ac757","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-2576] [javaAPI] [scalaAPI] Restored binary compatibility for DataSet (inner) join.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/1272cd5d0c477fea90753dcc1b39736db56ac757"},{"sha":"48f614cb77cbd9723db076df80e36b38e20f913f","author":{"email":"4877b5966827a9c06b3f725e99b7442e1fa1186a@gmail.com","name":"Gabor Gevay"},"message":"[FLINK-2818] [docs] Correct javadocs of *ReduceDriver classes and some methods in the API.\n\nThis closes #1224.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/48f614cb77cbd9723db076df80e36b38e20f913f"},{"sha":"7750a1f29e231f16cbbea4d91dbe530b1f92f192","author":{"email":"a26e691c1e2579e0b3e84545031f591986d1e6fb@gmail.com","name":"nikste"},"message":"[FLINK-2613] [scala shell] Print usage information for Scala Shell\n\n  - Change startup code of scala shell\n  - User has to specify local or remote mode explicitly now.\n\nThis closes #1106.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/7750a1f29e231f16cbbea4d91dbe530b1f92f192"},{"sha":"71d5a39b424d66c102130e01acad9d12e96f6a87","author":{"email":"d9a1a677f68c4bb1eba80df59d7b26849432d88c@gmail.com","name":"dawid"},"message":"[FLINK-2156] [tests] Fix bug that some tests of Scala module cannot create log file\n\nThis closes #1234.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/71d5a39b424d66c102130e01acad9d12e96f6a87"},{"sha":"91ffbc1e3b626b93398271a6ea10c57b18459339","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[FLINK-2833] [gelly] create a flink-libraries module and move gelly there\n\nThis closes #1241","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/91ffbc1e3b626b93398271a6ea10c57b18459339"},{"sha":"3b77faa36f11c704ebf69616c263dae3307e6ae7","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-2784] Remove deprecated configuration keys and updated documentation\n\nThis closes #1244","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/3b77faa36f11c704ebf69616c263dae3307e6ae7"},{"sha":"58ab14b55e7f1d5835bd4bb660ae9bb676f8dbb2","author":{"email":"9bcb11ac70c2fc7872d9b58e21318011c5e228e2@gmail.com","name":"Sachin Goel"},"message":"[FLINK-2730][webfrontend] Add cpu and memory usage graphs\n\nThis closes #1236.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/58ab14b55e7f1d5835bd4bb660ae9bb676f8dbb2"},{"sha":"d38aeaceb3de56fd62266f65836ea5e97c161212","author":{"email":"09f96470664173820d592801c5693434bcb0aaa7@apache.org","name":"Henry Saputra"},"message":"Small update to Javadoc in IterativeDataset.closeWith to add missing param.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/d38aeaceb3de56fd62266f65836ea5e97c161212"},{"sha":"86080bb971c8d48a6a4225b41b30f80b0986a6aa","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[hotfix] Add countWindow and countWindowAll shortcut","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/86080bb971c8d48a6a4225b41b30f80b0986a6aa"},{"sha":"2475c82d425b4a6a564f0d38f352a0f3b8753d72","author":{"email":"7f60945318f366e6fd5b2c2d5a33d425e866214a@gmail.com","name":"Viktor Taranenko"},"message":"[docs] fix typo in Scala functions type descriptors\n\nCloses #1253","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/2475c82d425b4a6a564f0d38f352a0f3b8753d72"}]}