beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Eugene Kirpichov (JIRA)" <>
Subject [jira] [Commented] (BEAM-2140) Fix SplittableDoFn ValidatesRunner tests in FlinkRunner
Date Mon, 18 Sep 2017 18:40:00 GMT


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:
>             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

View raw message