Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2434#discussion_r76624854
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/DefaultTimeServiceProvider.java
---
@@ -28,15 +31,22 @@
*/
public class DefaultTimeServiceProvider extends TimeServiceProvider {
+ /** The containing task that owns this time service provider. */
+ private final StreamTask<?, ?> task;
--- End diff --
If the `StreamTask` is only used for the async exception handling then I
think this can be abstracted behind an `AsynchronousExceptionHandler` interface
that the task implements. This would have something like
`notifyOfAsyncException()` and `checkAsyncExceptions()`. These are the same
methods that `StreamTask` has now but we would not expose all of `StreamTask`
to the time service provider but have clear-cut interfaces.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
