{"push_id":941123399,"size":39,"distinct_size":1,"ref":"refs/heads/fs_param","head":"ff46b8aae8a55b60390d9936ddd0fa5972854b9c","before":"e8d9bdf133c64032741f8ff509e16b40875ad6be","commits":[{"sha":"d0e1d635d9e6a4ef157275099e2e787b3b18c0ed","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/d0e1d635d9e6a4ef157275099e2e787b3b18c0ed"},{"sha":"b7520a53f83d23cc6dfd9ff958880837cb0c99ae","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3195] Rework quickstart example & some cleanups on the new examples","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/b7520a53f83d23cc6dfd9ff958880837cb0c99ae"},{"sha":"e9bf13d8626099a1d6ddb6ebe98c50be848fe79e","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-1712] Remove \"flink-staging\" module\n\nThis closes #1492\nThis closes #1482","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/e9bf13d8626099a1d6ddb6ebe98c50be848fe79e"},{"sha":"e4d8944004e55dd3a965f1d32584e7c64862d1ac","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2962] Cluster startup script refers to unused variable","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/e4d8944004e55dd3a965f1d32584e7c64862d1ac"},{"sha":"d1c93d286b95f069f6ba0a4e60e3a34655a395e3","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@apache.org","name":"mjsax"},"message":"[FLINK-2586] Unstable Storm Compatibility Tests\n - added BLOCKING flag to FlinkLocalCluster\n - added NullTerminatingSpout and SpoutOutputCollectorObserver plus tests\n - reworked test accordingly\n   - set BLOCKING flag for ITCases\n   - make infinite spouts finite using NullTerminatingSpout\n   - removed sleep time to get stable\n - fixed bug in BoltSplitITCase and SpoutSplitITCase\n   - exception in VerifyAndEnrichBolt is swallowed and test would not fail (replaced by errorFlag)\n - reduced sleep-time in BoltSplitITCase and SpoutSplitITCase to reduce testing time\n - fixed WrapperSetupHelperTest\n   - reworked to origianl version with more than two inputs\n     (was limite to two inputs because more the two inputs per bolt was not supported in between, which is now fixed)\nminor code cleanup (removed unused imports, indenting, etc.)\nfixed small error in documenation\n\nThis closes #1502.","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/d1c93d286b95f069f6ba0a4e60e3a34655a395e3"},{"sha":"be055b7a9f8ecb09e5e4e0bbddb98639173a09a7","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@apache.org","name":"mjsax"},"message":"[Storm-Compatibility] Forward Storm Kryo registrations to Flink\n\nThis closes #1495.","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/be055b7a9f8ecb09e5e4e0bbddb98639173a09a7"},{"sha":"615cf42b3d9404dca3884c5abc71650a6cf91d7b","author":{"email":"f55f5fad55aaea3a24db3b0da6267c06dda1c57a@apache.org","name":"Chiwan Park"},"message":"[FLINK-2984] [ml] Extend libSVM file format support\n\nThis closes #1504.","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/615cf42b3d9404dca3884c5abc71650a6cf91d7b"},{"sha":"a65cd8db1c8e966fe43f68f3a427d9b1d09fe165","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@apache.org","name":"mjsax"},"message":"[hotfix] moved files to correct folder to match package statements\n\nThis closes #1510","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/a65cd8db1c8e966fe43f68f3a427d9b1d09fe165"},{"sha":"388c280fcd8157f5ebc06a9062a0d06a3d2e92cb","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] Remove unnecessary dependencies in flink-runtime.\n\n  - Removes Apache Commons HTTP Client\n  - Removes Apache Commons IO\n  - Removes Jettison JSONparser and consolidates tests to use Jackson instead (which is included anyways)","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/388c280fcd8157f5ebc06a9062a0d06a3d2e92cb"},{"sha":"0ae46b596949808f56c40bd7a68f478bc10206ab","author":{"email":"f0240f04f02825bdfdd799537566d6dfe08422fe@opencorrelate.org","name":"Prez Cannady"},"message":"[FLINK-3236] [runtime] Flink user code classloader as parent classloader from Flink core classes\n\nOriginally, the user code classloader delegates to the system classloader as parent.\nThat works in Flink standalone settings, but not when the Flink core classes themselves\n are not loaded with the system classloader (certain embedded setups).\n\nThis patch uses as parent the classloader that was used to load the Flink core classes, specificly\n\"org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.FlinkUserCodeClassLoader.class.getClassLoader()\".\n\nThis closes #1506\nThis closes #1507\nThis closes #1508","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/0ae46b596949808f56c40bd7a68f478bc10206ab"},{"sha":"9915b339b77ad0a8b6bf61cf2df87877204201f5","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] Remove docs for the now removed web client.","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/9915b339b77ad0a8b6bf61cf2df87877204201f5"},{"sha":"16cf8b1355fda5cc47634820a88249d61a768c60","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] Remove outdated README for the quickstart projects.\n\nThe README was describing non-existing bash scripts removed several versions ago.","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/16cf8b1355fda5cc47634820a88249d61a768c60"},{"sha":"8b8dfc1671f21a2e381376e78184c7b46adf26b0","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3235] Remove Flink on Tez code","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/8b8dfc1671f21a2e381376e78184c7b46adf26b0"},{"sha":"0937be0a94eae0b47f0a5f0206e62a98bcbc8432","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3232] [runtime] Add option to eagerly deploy channels\n\nAdds a flag to the ExecutionGraph's IntermediateResult class indicating whether\nthe result consumers should be deployed eagerly. If true, the consumers are\ndeployed as soon as the partition is registered at the ResultPartitionManager of\nthe task manager. In practice, the deployment boils down to updating unknown\ninput channels of the consumers (because the actual tasks are actually deployed\nall at once).\n\nThis behaviour is configured in the JobGraph generator and only activated for\nstreaming programs (StreamingJobGraphGenerator). It only makes sense for\npipelined results.\n\nThe motivation is to get down the latency of the first records passing a\npipeline. The initial update of the input channels causes a higher latency.\n\nYou can see this effect in the StreamingScalabilityAndLatency class (manual\ntest).\n\nAt the moment, this results in duplicate Akka messages when the first record\nis produced (the message travels from the task to the job manager and from the\njob manager to task manager, which then will be ignored at the InputGate).\n\nThis closes #1503","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/0937be0a94eae0b47f0a5f0206e62a98bcbc8432"},{"sha":"e9a535877906bd75df3e633e3c5dad556b9c925d","author":{"email":"e6fb06210fafc02fd7479ddbed2d042cc3a5155e@greghogan.com","name":"Greg Hogan"},"message":"[FLINK-3219] [java scala] Implement DataSet.count and DataSet.collect using a single operator","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/e9a535877906bd75df3e633e3c5dad556b9c925d"},{"sha":"9365441396efdcf852e9076bdb6ca0fcc841434c","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] Minor cleanup of warnings, comments, and code style in the Java API Utils","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/9365441396efdcf852e9076bdb6ca0fcc841434c"},{"sha":"2c556f74e491a47e7c10e7b8cc03e5c65cf34d23","author":{"email":"a47d0c84e35042eed4634dc240ddb5dd2cf54b11@gmail.com","name":"Ajay Bhat"},"message":"[FLINK-3197] [core] Close InputStream in BinaryInputFormat#createStatistics reliably\n\nThis closes #1494","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/2c556f74e491a47e7c10e7b8cc03e5c65cf34d23"},{"sha":"cfcb5d7ba5c22295c0ae628f8d9a2447e2286985","author":{"email":"f0240f04f02825bdfdd799537566d6dfe08422fe@opencorrelate.org","name":"Prez Cannady"},"message":"[hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators\n\nThis closes #1511","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/cfcb5d7ba5c22295c0ae628f8d9a2447e2286985"},{"sha":"cf7045c2dc07615c3ec3885134b9bfddd72deb97","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3074] [yarn] Fix port range retry termination condition","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/cf7045c2dc07615c3ec3885134b9bfddd72deb97"},{"sha":"21882af01029b6ce0cca9c84491a6f82dda095cb","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3073] [dist] Fix JobManager command line argument\n\nRemoved streaming mode lead to wrong arguments being passed.","distinct":false,"url":"https://api.github.com/repos/kl0u/flink/commits/21882af01029b6ce0cca9c84491a6f82dda095cb"}]}