[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16170437#comment-16170437
]
Aljoscha Krettek commented on BEAM-2140:
----------------------------------------
As I commented on the PR, I have a solution that is simpler but also doesn't
work because there is currently no way of getting around the fact that Flink
will shutdown the timer service before calling close() on an operator. Meaning
that there is no way of blocking on "in-flight" timers. I'll try and get such a
feature in Flink, only then can we fix this issue.
> Fix SplittableDoFn ValidatesRunner tests in FlinkRunner
> -------------------------------------------------------
>
> Key: BEAM-2140
> URL: https://issues.apache.org/jira/browse/BEAM-2140
> Project: Beam
> Issue Type: Bug
> Components: runner-flink
> Reporter: Aljoscha Krettek
> Assignee: Aljoscha Krettek
>
> As discovered as part of BEAM-1763, there is a failing SDF test. We disabled
> the tests to unblock the open PR for BEAM-1763.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
