{"push_id":781382244,"size":21,"distinct_size":1,"ref":"refs/heads/mem_mixed","head":"3aba551901b21176ef45b15d5904fd46c8fb4356","before":"0debf7b6ee6ab2445fd05e1d41de056f46609b40","commits":[{"sha":"b9de4ed37ffa68ef50dc6d6b3819afcc00d1d029","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers.\n\nRefactors FlinkMiniCluster to support multiple JobManager\n\nAdds proper remote address resolution for actors\n\nClean up of LeaderElection and LeaderRetrievalService. Removes synchronization to avoid deadlock.\n\nAdds ZooKeeper start option to TestBaseUtils.startCluster\n\nRemoves registration session IDs, using the leader session IDs instead. Sets the leader session ID\n directly in the grantLeadership method. Let the LeaderElectionService select the leader session I\nD. Return leader session ID to LeaderRetrievalListeners.\n\nRemoves direct ActorRef interaction\n\nIntroduces LeaderRetrievalService for the Client and the CliFrontend.\n\nMake ApplicationClient to use the LeaderRetrievalService for JobManager resolution\n\nAdds LeaderElection/Retrieval tests\n\nAdded test for exception forwarding from the CuratorFramework to a Contender\n\nAdds test job submission with changing leaders\n\nAdds new test cases for job cleanup after leader election change\n\nAdds new LeaderChangeStateCleanup test case\n\nAdds LeaderElectionRetrievalTestingCluster\n\nIntroduces ListeningBehaviour for job submissions\n\nRelocation of org.apache.curator in flink-shaded-hadoop jar\n\nAdds Apache ZooKeeper and Apache Curator to LICENSE and NOTICE files\n\nIncreases zookeeper connection timeout to 20000 ms for the KafkaITCase to fix failing tests on Travis\n\nIncreased timeouts of ZooKeeperLeaderElectionTest for Travis\n\nMakes the WebInfoServer and the WebRuntimeMonitor to use the LeaderRetrievalService to retrieve the current leading JobManager\n\nAdds proper synchronization to ZooKeeperLeaderElectionService. Fixes StateCheckpointedITCase and PartitionedStateCheckpointingITCase\n\nAdds configuration description for new ZooKeeper configuration values\n\nFixed port selection of JobManager at startup\n\nImproves logging output\n\nExtends masters file to also specify the webui ports\n\nAdds proper network interface resolution by retrieving the current leader address\n\nMakes the ZooKeeperLeaderElectionService write the leader information in ephemeral nodes so that the information is deleted once the leader has terminated. Fixes a bug in the TaskManager due to call by name semantics of scheduler.scheduleOnce.\n\nAdds jobManagerURL to TriggerTaskManagerRegistration message\n\nEnables findConnectingAddress to use the ZooKeeperLeaderRetrievalService. This allows to test the connection to a possibly changing master node.\n\nChanges startup scripts to respect the recovery mode instead of the ZK_QUORUM\n\nAdjust travis log file to only log zookeeper errors\n\nUpdates high availability setup guide\n\nAdds TestLogger to leader election tests\n\nThis closes #1016.","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/b9de4ed37ffa68ef50dc6d6b3819afcc00d1d029"},{"sha":"d5a90279fec810965da1a06bf7c90e7123c2719b","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[jobmanager] fix warning about non-exhaustive case matching\n\n- fixed warning by adding a catch all case\n- corrected indention of code block\n\nhint: use -w to ignore the whitespace in the diff,\n      e.g. git log -u -w","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/d5a90279fec810965da1a06bf7c90e7123c2719b"},{"sha":"ac9a911723d0d81ee9c4d8231ee81bbbafff2575","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2599] [test-stability] Fix possible NPE in SlotCountExceedingParallelismTest","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/ac9a911723d0d81ee9c4d8231ee81bbbafff2575"},{"sha":"6b0c0e4c00f40bd3159ff21fc74463ab983bfe6e","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[core][runtime] move SerializedValueTest from runtime to core\n\n- move createCopySerializable to core's CommonTestUtils\n- rename CommonTestUtils createCopy to createCopyWritable\n- adapt the tests to use core's CommonTestUtils where applicable\n\nThis closes #1081.","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/6b0c0e4c00f40bd3159ff21fc74463ab983bfe6e"},{"sha":"8aa8e4f94f14363c0f17ef824ea847aaab54d3b4","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[scripts] Fixes correct Flink bin path usage in scripts","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/8aa8e4f94f14363c0f17ef824ea847aaab54d3b4"},{"sha":"7364ce180425838801f8ca6adb71bf8c3ec851da","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[scripts] Adds example settings for zookeeper ha to default flink-conf.yaml","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/7364ce180425838801f8ca6adb71bf8c3ec851da"},{"sha":"f4a48c23a30c170a5a2c08c27e1f01f7827eefd2","author":{"email":"5cbbd5f57bb27bf0f9da21420242788d85005e91@intel.com","name":"chengxiang li"},"message":"[FLINK-2596] Remove non-transitive comparator in random sampler test.\n\nThis closes #1080","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/f4a48c23a30c170a5a2c08c27e1f01f7827eefd2"},{"sha":"8c852c2abf3a1e597dd1d139197d3420861a516c","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-2584] Check for unshaded classes in fat jar and shade curator\n\nThis closes #1076","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/8c852c2abf3a1e597dd1d139197d3420861a516c"},{"sha":"ab14f90142fd69426bb695cbdb641f0a5a0c46f7","author":{"email":"175bc738678996cb1561b36804c970b6ef30ec54@gmx.net","name":"Martin Junghanns"},"message":"[FLINK-2590] fixing DataSetUtils.zipWithUniqueId() and DataSetUtils.zipWithIndex()\n\n* modified algorithm as explained in the issue\n* updated method documentation\n\n[FLINK-2590] reducing required bit shift size\n\n* maximum bit size is changed to getNumberOfParallelSubTasks() - 1\n\nThis closes #1075.","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/ab14f90142fd69426bb695cbdb641f0a5a0c46f7"},{"sha":"6a58aadec15657a7da60c58ef6d5dbbf7e5ca14b","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-2590] Fixes Scala's DataSetUtilsITCase","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/6a58aadec15657a7da60c58ef6d5dbbf7e5ca14b"},{"sha":"31aededecfc4ec2085c00f23e2a78f660995efaa","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-2604] [runtime] Adds synchronization to stop method of ZooKeeperLeaderElectionService","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/31aededecfc4ec2085c00f23e2a78f660995efaa"},{"sha":"dd9979f8ffc7de178968298d8c21df7315633e9b","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2601] [runtime] Install shutdown hook at the end of I/O manager initialization\n\nThis prevents possible null pointers when the JVM shuts down before the I/O manager was fully started.","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/dd9979f8ffc7de178968298d8c21df7315633e9b"},{"sha":"2e6e4de5d1d2b5123f4311493763fd84f52779ab","author":{"email":"5cbbd5f57bb27bf0f9da21420242788d85005e91@intel.com","name":"chengxiang li"},"message":"[FLINK-2545] add bucket member verification while build bloom filter.\n\nThis closes #1067","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/2e6e4de5d1d2b5123f4311493763fd84f52779ab"},{"sha":"166b3705c9079efafe9217d98e7edaf54e6a84cf","author":{"email":"9bcb11ac70c2fc7872d9b58e21318011c5e228e2@gmail.com","name":"Sachin Goel"},"message":"[FLINK-2448] [tests] Create new Test Environments on every call to getExecutionEnvironment and allow sharing of job execution results","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/166b3705c9079efafe9217d98e7edaf54e6a84cf"},{"sha":"5d98e77cd740dc991978dbb1d026954f733786a8","author":{"email":"9bcb11ac70c2fc7872d9b58e21318011c5e228e2@gmail.com","name":"Sachin Goel"},"message":"[hotfix] [gelly] Remove unintended calls to getExecutionEnvironment in VertexCentricIteration and GatherSumApplyIteration\n\nThis closes #1031","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/5d98e77cd740dc991978dbb1d026954f733786a8"},{"sha":"d09f0027bddefa7d3f3f73dbf6f26926338cf712","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[hotfix][docs] Update Kafka section in streaming guide to match the renamed class names","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/d09f0027bddefa7d3f3f73dbf6f26926338cf712"},{"sha":"53752163f39e3a91bee78e66d69ab05eda5a08bb","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-2607][quickstart] ignore signature files when creating fat jar\n\nThis closes #1085.","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/53752163f39e3a91bee78e66d69ab05eda5a08bb"},{"sha":"14ba66bafffc3f74a3d89ba2717de0ae9b407041","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-2614][scala-shell] scala shell's default execution mode is broken\n\n- call new start() method of FlinkMiniCluster","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/14ba66bafffc3f74a3d89ba2717de0ae9b407041"},{"sha":"9f96b32bf8a0c77accdd91b7cfada2f6e751c167","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"[FLINK-2475] Rename Flink Client log file\n\nThis closes #1074","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/9f96b32bf8a0c77accdd91b7cfada2f6e751c167"},{"sha":"3d528442f6993c64600224483ee3048c40763c80","author":{"email":"f4c871e5d0e065cb2adf612e3fed11df80e9a2a2@googlemail.com","name":"Nikolaas Steenbergen"},"message":"[FLINK-2161] [scala shell] Modify start script to take additional argument (-a <path/to/class> or --addclasspath <path/to/class>) for external libraries\n\nThis closes #805","distinct":false,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/3d528442f6993c64600224483ee3048c40763c80"}]}