[jira] [Commented] (BEAM-2831) Pipeline crashes due to Beam encoder breaking Flink memory management

[ https://issues.apache.org/jira/browse/BEAM-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391419#comment-16391419 ] Guillaume Balaine commented on BEAM-2831: - I fixed that in every Coder, including t

[jira] [Commented] (BEAM-2831) Pipeline crashes due to Beam encoder breaking Flink memory management

[ https://issues.apache.org/jira/browse/BEAM-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389772#comment-16389772 ] Guillaume Balaine commented on BEAM-2831: - The implication here, is that from 2.1 o

[jira] [Commented] (BEAM-3649) HadoopSeekableByteChannel breaks when backing InputStream doesn't supporte ByteBuffers

[ https://issues.apache.org/jira/browse/BEAM-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380436#comment-16380436 ] Guillaume Balaine commented on BEAM-3649: - I was using HDFS mostly for its compatib

[jira] [Closed] (BEAM-3649) HadoopSeekableByteChannel breaks when backing InputStream doesn't supporte ByteBuffers

[ https://issues.apache.org/jira/browse/BEAM-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guillaume Balaine closed BEAM-3649. --- Resolution: Fixed Fix Version/s: 2.4.0 Fixed by BEAM-2790 > HadoopSeekableByteChannel b

[jira] [Commented] (BEAM-3649) HadoopSeekableByteChannel breaks when backing InputStream doesn't supporte ByteBuffers

[ https://issues.apache.org/jira/browse/BEAM-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16377051#comment-16377051 ] Guillaume Balaine commented on BEAM-3649: - Hello Ismaël, thanks, I saw the fix afte

[jira] [Created] (BEAM-3649) HadoopSeekableByteChannel breaks when backing InputStream doesn't supporte ByteBuffers

Guillaume Balaine created BEAM-3649: --- Summary: HadoopSeekableByteChannel breaks when backing InputStream doesn't supporte ByteBuffers Key: BEAM-3649 URL: https://issues.apache.org/jira/browse/BEAM-3649

[jira] [Commented] (BEAM-793) JdbcIO can create a deadlock when parallelism is greater than 1

[ https://issues.apache.org/jira/browse/BEAM-793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174736#comment-16174736 ] Guillaume Balaine commented on BEAM-793: Alright, I made it worked by having a backo

[jira] [Commented] (BEAM-793) JdbcIO can create a deadlock when parallelism is greater than 1

[ https://issues.apache.org/jira/browse/BEAM-793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174391#comment-16174391 ] Guillaume Balaine commented on BEAM-793: Hello Jean-Baptiste, thanks for being so re

[jira] [Commented] (BEAM-793) JdbcIO can create a deadlock when parallelism is greater than 1

[ https://issues.apache.org/jira/browse/BEAM-793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173911#comment-16173911 ] Guillaume Balaine commented on BEAM-793: This is a major problem, it easily occurs i

[jira] [Commented] (BEAM-2500) Add support for S3 as a Apache Beam FileSystem

[ https://issues.apache.org/jira/browse/BEAM-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123445#comment-16123445 ] Guillaume Balaine commented on BEAM-2500: - Sorry about that, discovered a bug later

[jira] [Comment Edited] (BEAM-2500) Add support for S3 as a Apache Beam FileSystem

[ https://issues.apache.org/jira/browse/BEAM-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123184#comment-16123184 ] Guillaume Balaine edited comment on BEAM-2500 at 8/11/17 11:02 AM: --

[jira] [Updated] (BEAM-2500) Add support for S3 as a Apache Beam FileSystem

[ https://issues.apache.org/jira/browse/BEAM-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guillaume Balaine updated BEAM-2500: Attachment: hadoop_fs_patch.patch This patch works for me. > Add support for S3 as a Apache

[jira] [Commented] (BEAM-2500) Add support for S3 as a Apache Beam FileSystem

[ https://issues.apache.org/jira/browse/BEAM-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123047#comment-16123047 ] Guillaume Balaine commented on BEAM-2500: - Thanks, that's fine really, the only tro

[jira] [Commented] (BEAM-2500) Add support for S3 as a Apache Beam FileSystem

[ https://issues.apache.org/jira/browse/BEAM-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120095#comment-16120095 ] Guillaume Balaine commented on BEAM-2500: - I got s3a to work on a simple aggregatio