[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16170471#comment-16170471
]
Eugene Kirpichov commented on BEAM-2140:
----------------------------------------
Thanks Aljoscha! It would be awesome to get this working in Flink, since we now
have very useful IO capabilities built on top of SDF (specifically
FileIO.match().continuously(), the lower-level Watch transform and the
higher-level TextIO.watchForNewFiles() etc) and it would be great if these
worked in more runners. They will also provide examples to test on that are far
more realistic than the SDF unit tests. Let me know if there's any way I can
help.
> 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)
