{"push_id":1002134468,"size":145,"distinct_size":145,"ref":"refs/heads/master","head":"80ae75053d4a3fc71f428b87a8f0a9349da6047b","before":"937963e339ddd57cc65e3da8af5398600e4d9ad2","commits":[{"sha":"e5f33b6d12d8f3d3d2d4bc216ce074d2605fc9ae","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-3367] Add PublicEvolving and Internal annotations to flink-java and flink-scala","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/e5f33b6d12d8f3d3d2d4bc216ce074d2605fc9ae"},{"sha":"53f8d773be5e1fd36e8675c2ca2520b6153febf3","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-3367] Add PublicEvolving and Internal annotations to flink-core","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/53f8d773be5e1fd36e8675c2ca2520b6153febf3"},{"sha":"c9db63b935725368a5750e8d4dc94e6b015a1688","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-3367] Add PublicEvolving and Internal annotations to flink-streaming-java and flink-streaming-scala\n\nThis closes #1606","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/c9db63b935725368a5750e8d4dc94e6b015a1688"},{"sha":"b2f6f8c53a36f7f01aff9a8aee638382da415451","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"Revert \"[FLINK-3369] [runtime] Make RemoteTransportException instance of CancelTaskException\"\n\nThis reverts commit cf3ae88b73e30a2d69ac1cc6009a8304ea3f53cc.\n\nThe reason is that we cannot be sure that a failing sender will always be the root\ncause why the receiver cannot read the data. A TM can also fail after a sender is\nfinished leading to a loss of the intermediate result partitions. Then the receiver\nwill no longer be able to read the data.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/b2f6f8c53a36f7f01aff9a8aee638382da415451"},{"sha":"babf84c76d94db26cadb167eb4abe0e73c4c2c9f","author":{"email":"e6fb06210fafc02fd7479ddbed2d042cc3a5155e@greghogan.com","name":"Greg Hogan"},"message":"[hotfix] [web-dashboard] Make build idempotent","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/babf84c76d94db26cadb167eb4abe0e73c4c2c9f"},{"sha":"73bc35f14c547c14ddf82660160e554404e54b8c","author":{"email":"e6fb06210fafc02fd7479ddbed2d042cc3a5155e@greghogan.com","name":"Greg Hogan"},"message":"[FLINK-3160] [web-dashboard] Aggregate operator statistics by TaskManager\n\nAdds a new per-job tab displaying subtask statistics aggregated by TaskManager.\n\nThis closes #1564.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/73bc35f14c547c14ddf82660160e554404e54b8c"},{"sha":"b17632ddbbb58f8b3e3d1a31d6658e59258918c7","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-3354] Determine correct size for RocksDB snapshots\n\nCloses #1638","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/b17632ddbbb58f8b3e3d1a31d6658e59258918c7"},{"sha":"5eae47f5d381cd55729660f62c714b52d28413ed","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-3187] [restart] Introduce RestartStrategy to ExecutionGraph\n\nA RestartStrategy defines how the ExecutionGraph reacts in case of a restart. Different strategies\nare conceivable. For example, no restart, fixed delay restart, exponential backoff restart, scaling\nin/out restart, etc.\n\nExpose RestartStrategy to user API\n\nThis removes the setNumberExecutionRetries and the setDelayBetweenRetries on the ExecutionEnvironment and\nthe ExecutionConfig. Instead the more general RestartStrategy can be set. In order to maintain the\nseparation between the runtime and api module, one sets a RestartStrategyConfiguration which is transformed\ninto a RestartStrategy on the JobManager.\n\nReplace old execution-retries configuration parameters by restart-strategy.\n\nAdd FixedDelayRestartStrategy test case\n\nReintroduce old configuration values and API calls for the deprecated restart mechanism\n\nThe old configuration values and API calls will be respected if no explicit\nRestartStrategy has been set. The values, if correct, are used to instantiate\na FixedDelayRestartStrategy.\n\nAdd deprecation comments to the JavaDocs\n\nAdd logging statement for job recovery\n\nFix JobManagerProcessFailureBatchRecoveryITCase by introducing a job recovery timeout\n\nAdd proper annotations to RestartStrategies\n\nLet ExecutionGraphRestartTest extend TestLogger\n\nThis closes #1470.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/5eae47f5d381cd55729660f62c714b52d28413ed"},{"sha":"bdd4024e20fdfb0accb6121a68780ce3a0c218c0","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"[FLINK-2111] Add \"stop\" signal to cleanly shutdown streaming jobs\n\n- added JobType to JobGraph and ExecutionGraph\n- added interface Stoppable, applied to SourceStreamTask\n- added STOP signal logic to JobManager, TaskManager, ExecutionGraph\n- extended Client to support stop\n- extended Cli frontend, JobManager frontend\n- updated documenation\n\nFix JobManagerTest.testStopSignal and testStopSignalFail\n\nThe StoppableInvokable could not be instantiated by Task because it was declared as a private\nclass. Adds additional checks to verify that the stop signal behaves correctly.\n\nAuto-detect if job is stoppable\n\nA job is stoppable iff all sources are stoppable\n\n- Replace JobType by stoppable flag\n- Add StoppableFunction and StoppableInvokable to support the optional stop operation\n- added REST get/delete test (no extra YARN test -- think not required as get/delete is both tested)\n- bug fix: job got canceld instead of stopped in web interface\n- Add StoppingException\n- Allow to stop jobs when they are not in state RUNNING\n\nSecond round of Till's comments","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/bdd4024e20fdfb0accb6121a68780ce3a0c218c0"},{"sha":"f60f8fbc69cd1c36a3a99b08b0e76100b9032fae","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-2111] Make stoppable stream task and stoppable stream source operator type safe\n\nUpdate index.js and reset vendor.css and vendor.js to master version\n\nUpdate web-dashboard\n\nRemove duplicate flink-runtime-web dependency from flink-tests\n\nRemove not used ProgramStopException\n\nChange stopping behaviour to only work in job status RUNNING\n\nThis closes #750.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/f60f8fbc69cd1c36a3a99b08b0e76100b9032fae"},{"sha":"90532549e7c1e3c461481ae1a7f4ffe33f3860ae","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[hotfix] Add better error reporting in case of wrongly specified retry delay","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/90532549e7c1e3c461481ae1a7f4ffe33f3860ae"},{"sha":"ca11c1ccc7e7e0c02a2450dfd71a950b6a484648","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[hotfix] Annotate StoppableFunction as PublicEvolving","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/ca11c1ccc7e7e0c02a2450dfd71a950b6a484648"},{"sha":"65d08058a46fd09793c6dc4e8a4435cc713f5807","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3158] Enforce maven version to be < 3.3 when building a release","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/65d08058a46fd09793c6dc4e8a4435cc713f5807"},{"sha":"c658763d42d072073cc846f1814aa3cc5c42e05c","author":{"email":"5a386a2d0b7c8ff8d44225c476d30e88ad48f04a@gmail.com","name":"Kostas Kloudas"},"message":"[FLINK-3304] Making the Avro Schema serializable.\n\nThis closes #1635","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/c658763d42d072073cc846f1814aa3cc5c42e05c"},{"sha":"76d3a6353a0a3f8960dc2b49d9eac6a4a279ea9e","author":{"email":"5a386a2d0b7c8ff8d44225c476d30e88ad48f04a@gmail.com","name":"Kostas Kloudas"},"message":"FLINK-2380: allow the specification of a default filesystem scheme in the flink configuration file.\n\nThis closes #1524","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/76d3a6353a0a3f8960dc2b49d9eac6a4a279ea9e"},{"sha":"8486c3c23be5158bc4b9029d6ac6e2bb5a167158","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[hotfix] Add Scala version suffix to flink-cep module","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/8486c3c23be5158bc4b9029d6ac6e2bb5a167158"},{"sha":"2714aaf3d47705401f422a09619f09d2a90bf185","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3296] Remove 'flushing' behavior of the OutputFormat support of the DataStream API\n\nThis closes #1563","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/2714aaf3d47705401f422a09619f09d2a90bf185"},{"sha":"932a49d7b4d10987c6ad63b8642408759944bf7e","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[hotfix] [docs] Complete sentences in cluster_execution.md","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/932a49d7b4d10987c6ad63b8642408759944bf7e"},{"sha":"489e65359e3b819db99544226087af12b3032e0f","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] [streaming] Remove unused code fragment from DataStream.union() function.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/489e65359e3b819db99544226087af12b3032e0f"},{"sha":"75dcfc02736a9b4d4a407a1348a761ff132ec23f","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] [rocksdb] Update predefined RocksDB option profiles.","distinct":true,"url":"https://api.github.com/repos/twalthr/flink/commits/75dcfc02736a9b4d4a407a1348a761ff132ec23f"}]}