[
https://issues.apache.org/jira/browse/BEAM-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976722#comment-15976722
]
ASF GitHub Bot commented on BEAM-1886:
--------------------------------------
GitHub user aljoscha opened a pull request:
https://github.com/apache/beam/pull/2611
[BEAM-1886] Remove TextIO override in Flink runner
This is a duplicate of #2537. The tests work locally but not on Jenkins,
I'm trying to figure out why that might be.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/beam
finish-pr-2537-remove-flink-source
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/2611.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2611
----
commit 8f8ce303eb443bb8996ea76d5b979cb4b1000787
Author: JingsongLi <[email protected]>
Date: 2017-04-14T03:22:43Z
[BEAM-1886] Remove TextIO override in Flink runner
----
> Remove TextIO override in Flink runner
> --------------------------------------
>
> Key: BEAM-1886
> URL: https://issues.apache.org/jira/browse/BEAM-1886
> Project: Beam
> Issue Type: Bug
> Components: runner-flink
> Reporter: Kenneth Knowles
> Assignee: Jingsong Lee
> Fix For: First stable release
>
>
> Today, the Flink runner replaces TextIO with a customized version. I believe
> this is related to adequate support for files HDFS.
> However, the capabilities are less, in particular the recent support for
> window-and-pane sharded writes of unbounded collections.
> Concretely, we have had to remove WindowedWordCountIT from the precommit
> Jenkins run.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
