{"push_id":933124717,"size":30,"distinct_size":30,"ref":"refs/heads/ooc-state","head":"3907dfecb05d59738404ba972968936b9a81a1bd","before":"cdbcaf70ef22029b45cd42319eac2c4c62b23ab8","commits":[{"sha":"dcf86c27b91170f99c4d575950c72db8d14617dc","author":{"email":"a1f9f4e08e774006ff3a0e5fef5095e327058baa@researchgate.net","name":"Sebastian Klemke"},"message":"[FLINK-3188] Pass deletes to KeyedDeserializationSchema\n\nThis closes #1484","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/dcf86c27b91170f99c4d575950c72db8d14617dc"},{"sha":"c674a6558e07f1d918961a21ddaad4a6148698a0","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3093] Introduce annotations for interface stability in flink-core\n\nThis closes #1427","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/c674a6558e07f1d918961a21ddaad4a6148698a0"},{"sha":"54b89b95c82f2d660f320e97f961b69e50e0f06e","author":{"email":"09f96470664173820d592801c5693434bcb0aaa7@apache.org","name":"Henry Saputra"},"message":"[refactor] Change if-else conditions to switch-case statements.\n\nThis closes #1485","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/54b89b95c82f2d660f320e97f961b69e50e0f06e"},{"sha":"5b27cea20528dc28ff608677e6979d7f337560c6","author":{"email":"1aced219f4cf89d13052070eff259d4560bc8faf@intel.com","name":"zhangminglei"},"message":"[codestyle] Improve code style of PoissonSampler\n\nThis closes #1476","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/5b27cea20528dc28ff608677e6979d7f337560c6"},{"sha":"3da24a05b3eba901fa75246754c9bfeaeec8ff62","author":{"email":"2651880fca54bf4129e6c30de5bc63285f9e53b6@ymail.com","name":"rtudoran"},"message":"[FLINK-3176] Improve documentation for window apply\n\nThis closes #1488","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/3da24a05b3eba901fa75246754c9bfeaeec8ff62"},{"sha":"d31b00d3e2dd530fef1b632ea40fe488a48319e9","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[javaDocs] Fix JavaDoc examples in tumbling and sliding time windows\n\nThis closes #1490","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/d31b00d3e2dd530fef1b632ea40fe488a48319e9"},{"sha":"08c81378bd1a6412b735cc7fb655da953a5828c7","author":{"email":"56412ae1ce3a61bfe9d2a6ed2ac9856dec4e12e8@nmusic.pt","name":"Filipe Correia"},"message":"[docs] Add \"Iterator Data Sink\" section to DataStream guide.\n\nThis closes #1487","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/08c81378bd1a6412b735cc7fb655da953a5828c7"},{"sha":"009146c7e658522766566c8361e9b88ac3b864ea","author":{"email":"0e22d7b3d61d325026cf57cf73580cd2ae383e1d@web.de","name":"daniel-pape"},"message":"[FLINK-1737] [ml] Add outer product to Vector class\n\nOuter/Kronecker product take two vectors v, w and compute a matrix\nsuch that each matrix entry (i,j) is the product of v(i) * w(j).\nDepending on the vector types the result is either a DenseMatrix\nor a SparseMatrix. If one of the operands is sparse, then the result\nis sparse as well.\n\nImplementation of outer product for sparse vectors.\n\nTest cases for outer product computation. For dense as well as sparse vectors, More tests are to come.\n\nReplaced implementation of  `outer' method in order to avoid call to `SparseVector.apply` (which involves binary search).\n\nReduced warning by three: Removed unnecessary `val` keyword from case class fields.\n\nIncorporated suggestion from Till Rohrmann's code review (\"avoid binary search by using zipWithIndex\").\n\nThis closes #1078.","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/009146c7e658522766566c8361e9b88ac3b864ea"},{"sha":"ebbc85da7b78c1acdac4d184bddd6dfecf1338b2","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3050] [runtime] Add UnrecoverableException to suppress job restarts\n\nThis closes #1461.","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/ebbc85da7b78c1acdac4d184bddd6dfecf1338b2"},{"sha":"a3c01858ddc596e4b6825ae51801cd2ac9060f76","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2976] [docs] Add docs about savepoints","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/a3c01858ddc596e4b6825ae51801cd2ac9060f76"},{"sha":"ad7b21b8de28133d43076c889f7afae5c27cba29","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2976] [streaming-java, streaming-scala] Set JobVertexID based on stream node hash\n\n[comments] Remove unused argument to method\n\n[comments] Add more comments to stream node hashing\n\nAdd name to hash in order to detect swapped nodes when they have names\n\nImprove error message on non-unique user-specified IDs\n\n[comments] Add comment to stream node hashing","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/ad7b21b8de28133d43076c889f7afae5c27cba29"},{"sha":"2533b4f7edb8f7eaf041845c8c19dac5896c50c9","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2976] [runtime] Add StateStore<T>","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/2533b4f7edb8f7eaf041845c8c19dac5896c50c9"},{"sha":"9260aaaa0d1caccd4da0514a2498ab3a99cb4547","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2976] [core, runtime, streaming-java] Add ApplicationID to ExecutionGraph","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/9260aaaa0d1caccd4da0514a2498ab3a99cb4547"},{"sha":"6bdf9d07cc93ba5f3a193ceafc0e13d35353316b","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2976] [runtime] Add setCount(long newCount) to CheckpointIDCounter","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/6bdf9d07cc93ba5f3a193ceafc0e13d35353316b"},{"sha":"d739ee2532e0fd49ef37508b1c2e4a355473aaa5","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2976] [runtime, tests] Add SavepointCoordinator\n\n[comments] Rename config keys\n\n[comments] Fix docs and don't overload savepoint backend configuration with checkpoint backend configuration\n\n[comments] Use ConcurrentMap in HeapStateStore\n\n[comments] Fix typo and add missing serialVersionUID\n\n[comments] Fix Scala style\n\n[comments] Fix Scala style\n\n[docs] Emphasize dangers and recommended approaches\n\nAdd test to show inf restart loop on submission with unknown savepoint path\n\n[comments] Suppress resart of savepoint recovery failure\n\nThis closes #1434.","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/d739ee2532e0fd49ef37508b1c2e4a355473aaa5"},{"sha":"3607575a234f65b5ea50d987e9bd9f01c7f4a605","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2976] [clients] Add savepoint commands to CliFrontend\n\n[comments] Use handleError(Throwable)","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/3607575a234f65b5ea50d987e9bd9f01c7f4a605"},{"sha":"77348858f4632e9b3987cf1ed6a9c8af4c5e1aeb","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2976] [streaming-contrib] Use ApplicationID in DbStateBackend instead of JobID\n\n[comments] Set larger timeout for future when triggering savepoint","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/77348858f4632e9b3987cf1ed6a9c8af4c5e1aeb"},{"sha":"b9a6a5cb5401fbda3a0eb4b910eb4f3f951af9cb","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3212] [tests] Add RetryOnFailure rule to JobManagerCheckpointRecoveryITCase","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/b9a6a5cb5401fbda3a0eb4b910eb4f3f951af9cb"},{"sha":"a065ed0910fa5636a26c47b3ece5cb48cdbf33f7","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@apache.org","name":"mjsax"},"message":"[Docs] Fixed code example in streaming docs\n\nThis closes #1498.","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/a065ed0910fa5636a26c47b3ece5cb48cdbf33f7"},{"sha":"a5b05566ebeb1504da6579b21f424fbb45a56148","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@apache.org","name":"mjsax"},"message":"[FLINK-3189] Fix argument parsing of CLI client INFO action\n\nThis closes #1493","distinct":true,"url":"https://api.github.com/repos/gyfora/flink/commits/a5b05566ebeb1504da6579b21f424fbb45a56148"}]}