[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906539#comment-14906539
]
ASF GitHub Bot commented on FLINK-2111:
---------------------------------------
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-142970422
There are some crucial issues still with this pull request:
Most importantly, it changes parts that it needs not change, altering
system behavior. That manifests itself in the 130+ changed files, for something
that should probably touch around 20 files.
As per the contribution guidelines, it is very important that pull requests
do not do that. We have seen too many cases where bugs were introduced because
code parts were changed for no other reason than someone thinking that the code
should look different in their opinion.
Reporting and changing such unrelated parts should always be a separate
issue.
In the first few files, I see examples of
- Changing the type of exceptions caught. We often explicitly catch
Throwables, because we want to handle Errors as well, such as LinkageErrors
which are common when the dynamic class loading fails.
- Changing of the way tests deal with exceptions. There are good reasons
to explicitly catch and check expected exceptions (check messages, safe against
maven mis-configurations where exceptions propagating out of tests were not
correctly recognized, I saw that more than once so far).
> Add "stop" signal to cleanly shutdown streaming jobs
> ----------------------------------------------------
>
> Key: FLINK-2111
> URL: https://issues.apache.org/jira/browse/FLINK-2111
> Project: Flink
> Issue Type: Improvement
> Components: Distributed Runtime, JobManager, Local Runtime,
> Streaming, TaskManager, Webfrontend
> Reporter: Matthias J. Sax
> Assignee: Matthias J. Sax
> Priority: Minor
>
> Currently, streaming jobs can only be stopped using "cancel" command, what is
> a "hard" stop with no clean shutdown.
> The new introduced "stop" signal, will only affect streaming source tasks
> such that the sources can stop emitting data and shutdown cleanly, resulting
> in a clean shutdown of the whole streaming job.
> This feature is a pre-requirment for
> https://issues.apache.org/jira/browse/FLINK-1929
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
