beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Davor Bonaci (JIRA)" <>
Subject [jira] [Created] (BEAM-1634) Flink: register IOChannelFactories on workers
Date Tue, 07 Mar 2017 07:04:32 GMT
Davor Bonaci created BEAM-1634:

             Summary: Flink: register IOChannelFactories on workers
                 Key: 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

View raw message