[ https://issues.apache.org/jira/browse/BEAM-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15898854#comment-15898854 ]
ASF GitHub Bot commented on BEAM-1634: -------------------------------------- GitHub user davorbonaci opened a pull request: https://github.com/apache/beam/pull/2176 [BEAM-1634] Flink: register known IOChannelFactories R: @aljoscha You can merge this pull request into a Git repository by running: $ git pull https://github.com/davorbonaci/beam flink-gcs-fix Alternatively you can review and apply these changes as the patch at: https://github.com/apache/beam/pull/2176.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 #2176 ---- commit 971335e4d85982b697e30a6ba331eabc7b38f3a0 Author: Davor Bonaci <da...@google.com> Date: 2017-03-07T00:51:04Z Flink: register known IOChannelFactories ---- > Flink: register IOChannelFactories on workers > --------------------------------------------- > > Key: BEAM-1634 > URL: https://issues.apache.org/jira/browse/BEAM-1634 > Project: Beam > Issue Type: Bug > Components: runner-flink > Reporter: Davor Bonaci > Assignee: Aljoscha Krettek > Fix For: 0.6.0 > > > Runners should register IOChannelFactories on each worker before executing a > task on the workers. > This ensures that things like TextIO, AvroIO, etc. work with custom file > systems, like GCS, HDFS and others. -- This message was sent by Atlassian JIRA (v6.3.15#6346)