[jira] [Commented] (BEAM-5759) ConcurrentModificationException on JmsIO checkpoint finalization

2018-10-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652348#comment-16652348 ] Jean-Baptiste Onofré commented on BEAM-5759: Thanks for catching. I'm reviewing the PR

[jira] [Updated] (BEAM-5438) Add Gemfire IO

2018-10-19 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5438: --- Summary: Add Gemfire IO (was: why not add a Gemfire IO) > Add Gemfire

[jira] [Commented] (BEAM-5438) Add Gemfire IO

2018-10-19 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656902#comment-16656902 ] Ismaël Mejía commented on BEAM-5438: @zhangbin are you interested on working on this one? >

[jira] [Updated] (BEAM-5438) why not add a Gemfire IO

2018-10-19 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5438: --- Priority: Minor (was: Major) > why not add a Gemfire

[jira] [Commented] (BEAM-5439) StringUtf8Coder is slower than expected

2018-10-19 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656897#comment-16656897 ] Ismaël Mejía commented on BEAM-5439: This looks interesting, I don't have historic context on this one

[jira] [Resolved] (BEAM-5759) ConcurrentModificationException on JmsIO checkpoint finalization

2018-10-17 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-5759. Resolution: Fixed > ConcurrentModificationException on JmsIO checkpo

[jira] [Assigned] (BEAM-5933) PCollectionViews$SimplePCollectionView.hashCode allocates memory

2018-11-01 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-5933: -- Assignee: Vojtech Janota (was: Kenneth Knowles) > PCollectionVi

[jira] [Resolved] (BEAM-5933) PCollectionViews$SimplePCollectionView.hashCode allocates memory

2018-11-01 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5933. Resolution: Fixed Fix Version/s: 2.9.0 > PCollectionViews$SimplePCollectionView.hashC

[jira] [Commented] (BEAM-5910) FileSystems should retrieve lastModified time

2018-10-31 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16670230#comment-16670230 ] Ismaël Mejía commented on BEAM-5910: Big +1 on this, makes total sense. > FileSystems should retri

[jira] [Resolved] (BEAM-5919) Build breaks when including Multi-release Jars

2018-10-31 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5919. Resolution: Fixed Fix Version/s: 2.9.0 > Build breaks when including Multi-release J

[jira] [Commented] (BEAM-5891) Update byte-buddy to 1.9.3

2018-10-31 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16670862#comment-16670862 ] Ismaël Mejía commented on BEAM-5891: BEAM-5919 is merged now so this should be good to go, at least

[jira] [Assigned] (BEAM-5891) Update byte-buddy to 1.9.3

2018-10-30 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-5891: -- Assignee: Keisuke Kondo (was: Kenneth Knowles) > Update byte-buddy to 1.

[jira] [Updated] (BEAM-5919) Build breaks when including Multi-release Jars

2018-10-30 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5919: --- Attachment: logjava9jarissue.txt > Build breaks when including Multi-release J

[jira] [Created] (BEAM-5919) Build breaks when including Multi-release Jars

2018-10-30 Thread JIRA
Ismaël Mejía created BEAM-5919: -- Summary: Build breaks when including Multi-release Jars Key: BEAM-5919 URL: https://issues.apache.org/jira/browse/BEAM-5919 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-5891) Update byte-buddy to 1.9.3

2018-10-30 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668905#comment-16668905 ] Ismaël Mejía commented on BEAM-5891: Reassigned to [~klonika99] in case you want to work

[jira] [Commented] (BEAM-5949) Remove __ne__ when Beam Python drops Python 2 support

2018-11-05 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675232#comment-16675232 ] Ismaël Mejía commented on BEAM-5949: Probably we should create some JIRA to accumulate issues

[jira] [Commented] (BEAM-5650) Timeout exceptions while reading a lot of files from a bounded source like S3 when using TextIO

2018-11-02 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16673180#comment-16673180 ] Ismaël Mejía commented on BEAM-5650: [~jhalarua] Any hints of where the issue is ? BEAM-5934 looks

[jira] [Resolved] (BEAM-5891) Update byte-buddy to 1.9.3

2018-11-05 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5891. Resolution: Fixed Fix Version/s: 2.9.0 Marking this as resolved for the dependency only

[jira] [Resolved] (BEAM-5987) Spark SideInputReader performance

2018-11-06 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5987. Resolution: Fixed > Spark SideInputReader performa

[jira] [Commented] (BEAM-6007) Create ClassLoadingStrategy with Java 11 compatible way

2018-11-08 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679569#comment-16679569 ] Ismaël Mejía commented on BEAM-6007: It is clear that we should not expose byte buddy at all, can you

[jira] [Created] (BEAM-6023) Remove Create.Values translation from Spark runner

2018-11-08 Thread JIRA
Ismaël Mejía created BEAM-6023: -- Summary: Remove Create.Values translation from Spark runner Key: BEAM-6023 URL: https://issues.apache.org/jira/browse/BEAM-6023 Project: Beam Issue Type

[jira] [Commented] (BEAM-5650) Timeout exceptions while reading a lot of files from a bounded source like S3 when using TextIO

2018-11-08 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679830#comment-16679830 ] Ismaël Mejía commented on BEAM-5650: Thanks a lot for the PR and the analysis Ankit, Will comment

[jira] [Updated] (BEAM-5650) Timeout exceptions while reading a lot of files from a bounded source like S3 with Flink runner

2018-11-08 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5650: --- Summary: Timeout exceptions while reading a lot of files from a bounded source like S3 with Flink

[jira] [Created] (BEAM-6037) Make Spark runner pipeline translation based on URNs

2018-11-12 Thread JIRA
Ismaël Mejía created BEAM-6037: -- Summary: Make Spark runner pipeline translation based on URNs Key: BEAM-6037 URL: https://issues.apache.org/jira/browse/BEAM-6037 Project: Beam Issue Type

[jira] [Commented] (BEAM-5964) Add ClickHouseIO.Write

2018-11-12 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683742#comment-16683742 ] Ismaël Mejía commented on BEAM-5964: Excellent for the binary protocol! The real deal

[jira] [Commented] (BEAM-6031) Add retry logic to S3FileSystem

2018-11-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688160#comment-16688160 ] Ismaël Mejía commented on BEAM-6031: [~pawelbartoszek] do you plan to work on this one? We have

[jira] [Assigned] (BEAM-6031) Add retry logic to S3FileSystem

2018-11-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-6031: -- Assignee: (was: Ismaël Mejía) > Add retry logic to S3FileSys

[jira] [Resolved] (BEAM-5974) Migrate ByteKeyRangeTracker to use tryClaim(ByteKey.EMPTY) as end of range claim instead of markDone

2018-11-07 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5974. Resolution: Fixed Fix Version/s: 2.9.0 > Migrate ByteKeyRangeTracker to use tryCl

[jira] [Commented] (BEAM-5891) Update byte-buddy to 1.9.3

2018-11-07 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677843#comment-16677843 ] Ismaël Mejía commented on BEAM-5891: Sure thing [~klonika99]. Just ping me when is ready. We need

[jira] [Resolved] (BEAM-5857) Unnecessary submission of a new job in Combine.globally

2018-11-06 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5857. Resolution: Fixed Fix Version/s: 2.9.0 > Unnecessary submission of a new

[jira] [Commented] (BEAM-5964) Add ClickHouseIO.Write

2018-11-06 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676584#comment-16676584 ] Ismaël Mejía commented on BEAM-5964: Great, don't forget to take a look at https://beam.apache.org

[jira] [Commented] (BEAM-2639) Unbounded Source for MongoDB

2018-11-06 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-2639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676528#comment-16676528 ] Jean-Baptiste Onofré commented on BEAM-2639: I will resume my work on this one. [~nevi_me] do

[jira] [Assigned] (BEAM-5857) Unnecessary submission of a new job in Combine.globally

2018-11-06 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-5857: -- Assignee: Marek Simunek (was: Amit Sela) > Unnecessary submission of a new

[jira] [Assigned] (BEAM-5775) Make the spark runner not serialize data unless spark is spilling to disk

2018-11-14 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-5775: -- Assignee: Mike Kaplinskiy (was: Amit Sela) > Make the spark runner not serialize data unl

[jira] [Updated] (BEAM-5650) Timeout exceptions while reading a lot of files from a bounded source like S3 when using TextIO

2018-11-08 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5650: --- Component/s: (was: io-java-aws) runner-flink runner-core

[jira] [Resolved] (BEAM-6078) CassandraIO.read() should use builder's keyspace by default

2018-11-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-6078. Resolution: Fixed Fix Version/s: 2.9.0 > CassandraIO.read() should use builder's keysp

[jira] [Commented] (BEAM-6185) Upgrade to Spark 2.4.0

2019-01-02 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732398#comment-16732398 ] Jean-Baptiste Onofré commented on BEAM-6185: Yes, not a problem with the PR. Some users

[jira] [Updated] (BEAM-6185) Upgrade to Spark 2.4.0

2019-01-02 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6185: --- Fix Version/s: (was: 2.10.0) > Upgrade to Spark 2.

[jira] [Commented] (BEAM-6436) Gradle local SNAPSHOT publication is not detected correctly by maven

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744062#comment-16744062 ] Ismaël Mejía commented on BEAM-6436: Thanks for the pointer to publishing, I will add this to the wiki

[jira] [Commented] (BEAM-1861) ORC support

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744017#comment-16744017 ] Ismaël Mejía commented on BEAM-1861: I have no idea of anyone working actively on this. If someone

[jira] [Updated] (BEAM-4544) Add support for intellij to work with vendored artifacts generated as part of the Apache Beam build process

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-4544: --- Issue Type: Sub-task (was: Improvement) Parent: BEAM-5819 > Add support for intellij to w

[jira] [Assigned] (BEAM-1861) ORC support

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1861: -- Assignee: (was: Tibor Kiss) > ORC support > --- > > Ke

[jira] [Reopened] (BEAM-5933) PCollectionViews$SimplePCollectionView.hashCode allocates memory

2019-01-17 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reopened BEAM-5933: Reopening because this is going to be reverted by BEAM-6407 > PCollectionVi

[jira] [Commented] (BEAM-6266) Newest AWS SDK causes errors on startup without usage

2019-01-18 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746453#comment-16746453 ] Ismaël Mejía commented on BEAM-6266: Are you interested in contributing a fix for this one [~mikekap

[jira] [Updated] (BEAM-6436) Gradle local SNAPSHOT publication is not detected correctly by maven

2019-01-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6436: --- Description: If you publish some Beam artifact locally e.g. like this:     ./gradlew

[jira] [Commented] (BEAM-5828) Investigate publishing shaded source jars

2019-01-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743192#comment-16743192 ] Ismaël Mejía commented on BEAM-5828: If we can not legally publish the source of the vendored

[jira] [Created] (BEAM-6438) Update (or create new) release guide for vendored dependencies

2019-01-15 Thread JIRA
Ismaël Mejía created BEAM-6438: -- Summary: Update (or create new) release guide for vendored dependencies Key: BEAM-6438 URL: https://issues.apache.org/jira/browse/BEAM-6438 Project: Beam Issue

[jira] [Assigned] (BEAM-6436) Gradle local SNAPSHOT publication is not detected correctly by maven

2019-01-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-6436: -- Assignee: Scott Wegner (was: Luke Cwik) > Gradle local SNAPSHOT publication is not detec

[jira] [Commented] (BEAM-6436) Gradle local SNAPSHOT publication is not detected correctly by maven

2019-01-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743172#comment-16743172 ] Ismaël Mejía commented on BEAM-6436: [~swegner] assigned to you since Luke is out at the moment

[jira] [Created] (BEAM-6436) Gradle local SNAPSHOT publication is not detected correctly by maven

2019-01-15 Thread JIRA
Ismaël Mejía created BEAM-6436: -- Summary: Gradle local SNAPSHOT publication is not detected correctly by maven Key: BEAM-6436 URL: https://issues.apache.org/jira/browse/BEAM-6436 Project: Beam

[jira] [Updated] (BEAM-6438) Update (or create new) release guide for vendored dependencies

2019-01-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6438: --- Description: We also need to add steps to validate the release of the vendored dependencies during

[jira] [Created] (BEAM-6437) Update contribution guide with information about vendored dependencies

2019-01-15 Thread JIRA
Ismaël Mejía created BEAM-6437: -- Summary: Update contribution guide with information about vendored dependencies Key: BEAM-6437 URL: https://issues.apache.org/jira/browse/BEAM-6437 Project: Beam

[jira] [Commented] (BEAM-5723) CassandraIO is broken because of use of bad relocation of guava

2019-01-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743177#comment-16743177 ] Ismaël Mejía commented on BEAM-5723: I moved it to 2.11.0 because the current fix depends

[jira] [Updated] (BEAM-6436) Gradle local SNAPSHOT publication is not detected correctly by maven

2019-01-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6436: --- Description: If you publish some Beam artifact locally e.g. like this:     ./gradlew

[jira] [Created] (BEAM-6423) Refactor current file compressors as extensions

2019-01-14 Thread JIRA
Ismaël Mejía created BEAM-6423: -- Summary: Refactor current file compressors as extensions Key: BEAM-6423 URL: https://issues.apache.org/jira/browse/BEAM-6423 Project: Beam Issue Type

[jira] [Assigned] (BEAM-6424) RabbitMqIO: NullPointerException raised on getWatermark() first call

2019-01-14 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-6424: -- Assignee: (was: Eugene Kirpichov) > RabbitMqIO: NullPointerException rai

[jira] [Created] (BEAM-6422) Create an extensible mechanism for file (de)compresion

2019-01-14 Thread JIRA
Ismaël Mejía created BEAM-6422: -- Summary: Create an extensible mechanism for file (de)compresion Key: BEAM-6422 URL: https://issues.apache.org/jira/browse/BEAM-6422 Project: Beam Issue Type

[jira] [Commented] (BEAM-6424) RabbitMqIO: NullPointerException raised on getWatermark() first call

2019-01-14 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742288#comment-16742288 ] Ismaël Mejía commented on BEAM-6424: [~alafanechere] are you interested into creating a PR to fix

[jira] [Commented] (BEAM-6424) RabbitMqIO: NullPointerException raised on getWatermark() first call

2019-01-14 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742296#comment-16742296 ] Jean-Baptiste Onofré commented on BEAM-6424: Thanks. I will fix that as discussed on github

[jira] [Commented] (BEAM-6475) SQL Connection leak when using streaming pipeline

2019-01-21 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747798#comment-16747798 ] Jean-Baptiste Onofré commented on BEAM-6475: Thanks for the report. Let me investigate. >

[jira] [Resolved] (BEAM-6481) Relocations don't include sources

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-6481. Resolution: Duplicate Fix Version/s: Not applicable > Relocations don't include sour

[jira] [Updated] (BEAM-5828) Publish shaded source jars

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5828: --- Summary: Publish shaded source jars (was: Investigate publishing shaded source jars) > Publ

[jira] [Commented] (BEAM-5045) JdbcIO connection issue with MS SQL

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750204#comment-16750204 ] Jean-Baptiste Onofré commented on BEAM-5045: I'm resuming my investigation on this one

[jira] [Assigned] (BEAM-6479) Deprecate AvroIO.RecordFormatter

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-6479: -- Assignee: Ismaël Mejía > Deprecate AvroIO.RecordFormat

[jira] [Updated] (BEAM-6424) RabbitMqIO: NullPointerException raised on getWatermark() first call

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-6424: --- Component/s: (was: io-ideas) io-java-rabbitmq > RabbitM

[jira] [Updated] (BEAM-6480) Provide Avro.sink for IndexedRecord (FileIO compatible)

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6480: --- Description: More generally for sink there is no need to create a mapper API since the previous

[jira] [Updated] (BEAM-6480) Provide Avro.sink for IndexedRecord (FileIO compatible)

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6480: --- Summary: Provide Avro.sink for IndexedRecord (FileIO compatible) (was: Provide an avro sink

[jira] [Assigned] (BEAM-6480) Provide an avro sink for IndexedRecord without a formatter

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-6480: -- Assignee: Ismaël Mejía > Provide an avro sink for IndexedRecord without a format

[jira] [Updated] (BEAM-6479) Deprecate AvroIO.RecordFormatter

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6479: --- Summary: Deprecate AvroIO.RecordFormatter (was: AvroIO.RecordFormatter should use IndexedRecord

[jira] [Updated] (BEAM-6424) RabbitMqIO: NullPointerException raised on getWatermark() first call

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-6424: --- Fix Version/s: (was: 2.11.0) > RabbitMqIO: NullPointerException rai

[jira] [Updated] (BEAM-6424) RabbitMqIO: NullPointerException raised on getWatermark() first call

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-6424: --- Fix Version/s: 2.11.0 > RabbitMqIO: NullPointerException raised on getWaterm

[jira] [Updated] (BEAM-6479) Deprecate AvroIO.RecordFormatter

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6479: --- Description:  AvroIO.RecordFormatter is an user friendly way to transform user elements into Avro

[jira] [Updated] (BEAM-6479) Deprecate AvroIO.RecordFormatter

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6479: --- Description:  AvroIO.RecordFormatter is an user friendly way to transform user elements into Avro

[jira] [Updated] (BEAM-6480) Add AvroIO.sink for IndexedRecord (FileIO compatible)

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6480: --- Summary: Add AvroIO.sink for IndexedRecord (FileIO compatible) (was: Provide Avro.sink

[jira] [Resolved] (BEAM-6491) FileIOTest.testMatchWatchForNewFiles flakey in java presubmit

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-6491. Resolution: Fixed Assignee: Jeff Klukas Fix Version/s: 2.11.0

[jira] [Commented] (BEAM-5045) JdbcIO connection issue with MS SQL

2019-01-23 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750437#comment-16750437 ] Jean-Baptiste Onofré commented on BEAM-5045: So, I guess we can close this Jira ? > Jdb

[jira] [Updated] (BEAM-6348) Add ValueProvider support for Statement in JdbcIO.write()

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6348: --- Fix Version/s: (was: 2.11.0) 2.10.0 > Add ValueProvider support for Statem

[jira] [Updated] (BEAM-6332) Avoid unnecessary serialization steps when executing combine transform

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6332: --- Fix Version/s: (was: 2.11.0) 2.10.0 > Avoid unnecessary serialization st

[jira] [Updated] (BEAM-6425) Replace SSLContext.getInstance("SSL")

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6425: --- Fix Version/s: (was: 2.11.0) 2.10.0 > Replace SSLContext.getInstance(&

[jira] [Updated] (BEAM-6021) Serialize more core classes when using kryo's BeamSparkRunnerRegistrator

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6021: --- Fix Version/s: (was: 2.11.0) 2.10.0 > Serialize more core classes when us

[jira] [Updated] (BEAM-5798) Add support to write to multiple topics with KafkaIO

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5798: --- Fix Version/s: (was: 2.11.0) 2.10.0 > Add support to write to multiple top

[jira] [Updated] (BEAM-6097) Add NemoRunner

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6097: --- Fix Version/s: Not applicable > Add NemoRunner > -- > > Ke

[jira] [Updated] (BEAM-6097) Add NemoRunner

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6097: --- Fix Version/s: (was: 2.11.0) > Add NemoRunner > -- > > Ke

[jira] [Updated] (BEAM-6097) Add NemoRunner

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6097: --- Component/s: website > Add NemoRunner > -- > > Ke

[jira] [Updated] (BEAM-4143) GcsResourceIdTest has had a masked failure

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-4143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-4143: --- Fix Version/s: (was: 2.11.0) 2.10.0 > GcsResourceIdTest has had a mas

[jira] [Updated] (BEAM-6155) Migrate the Go SDK to the modern GCS library

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6155: --- Fix Version/s: (was: 2.11.0) 2.10.0 > Migrate the Go SDK to the modern

[jira] [Updated] (BEAM-6357) Datastore Python client: retry on ABORTED rpc responses

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6357: --- Fix Version/s: (was: 2.11.0) 2.10.0 > Datastore Python client: re

[jira] [Updated] (BEAM-6346) Portable Flink Job hangs if the sdk harness fails to start

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6346: --- Fix Version/s: (was: 2.11.0) 2.10.0 > Portable Flink Job hangs if the

[jira] [Updated] (BEAM-4110) LocalResourceIdTest has had a masked failure

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-4110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-4110: --- Fix Version/s: (was: 2.11.0) 2.10.0 > LocalResourceIdTest has had a mas

[jira] [Updated] (BEAM-6326) Fix test failures in streaming mode of PortableValidatesRunner

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6326: --- Fix Version/s: (was: 2.11.0) > Fix test failures in streaming mode of PortableValidatesRun

[jira] [Updated] (BEAM-6319) BigQueryToTableIT.testNewTypesQueryWithoutReshuffleWithCustom flaky

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6319: --- Fix Version/s: (was: 2.11.0) 2.10.0

[jira] [Updated] (BEAM-6248) Add Flink 1.7.x build target to Flink Runner

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6248: --- Fix Version/s: (was: 2.11.0) > Add Flink 1.7.x build target to Flink Run

[jira] [Updated] (BEAM-6164) GCS OpenRead and OpenWrite do not make use of the passed in context

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6164: --- Fix Version/s: (was: 2.11.0) 2.10.0 > GCS OpenRead and OpenWrite do not m

[jira] [Updated] (BEAM-6311) org.apache.beam.sdk.io.gcp.bigquery.BigQueryToTableIT.testStandardQueryWithoutCustom flakey

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6311: --- Fix Version/s: (was: 2.11.0) 2.10.0

[jira] [Updated] (BEAM-5723) CassandraIO is broken because of use of bad relocation of guava

2019-01-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5723: --- Affects Version/s: 2.10.0 > CassandraIO is broken because of use of bad relocation of gu

[jira] [Updated] (BEAM-5723) CassandraIO is broken because of use of bad relocation of guava

2019-01-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5723: --- Fix Version/s: (was: 2.10.0) (was: 2.7.1) 2.11.0

[jira] [Updated] (BEAM-6312) org.apache.beam.sdk.io.gcp.bigquery.BigQueryToTableIT.testNewTypesQueryWithoutReshuffle flakey

2019-01-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6312: --- Fix Version/s: (was: 2.11.0) 2.10.0

[jira] [Resolved] (BEAM-6425) Replace SSLContext.getInstance("SSL")

2019-01-15 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-6425. Resolution: Fixed Fix Version/s: 2.11.0 > Replace SSLContext.getInstance(&

[jira] [Resolved] (BEAM-5910) FileSystems should retrieve lastModified time

2019-01-18 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-5910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5910. Resolution: Fixed Fix Version/s: 2.11.0 > FileSystems should retrieve lastModified t

[jira] [Created] (BEAM-6462) Create an unbounded version of SyntheticIO based on SDF

2019-01-18 Thread JIRA
Ismaël Mejía created BEAM-6462: -- Summary: Create an unbounded version of SyntheticIO based on SDF Key: BEAM-6462 URL: https://issues.apache.org/jira/browse/BEAM-6462 Project: Beam Issue Type

  1   2   3   4   5   6   7   8   9   10   >