[jira] [Created] (BEAM-5508) Upgrade gradle-versions-plugin to 0.20.0

2018-09-25 Thread Ted Yu (JIRA)
Ted Yu created BEAM-5508: Summary: Upgrade gradle-versions-plugin to 0.20.0 Key: BEAM-5508 URL: https://issues.apache.org/jira/browse/BEAM-5508 Project: Beam Issue Type: Task Components:

[jira] [Commented] (BEAM-4334) The Stream created in LocalFileSystem#matchOne should be closed

2018-05-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494404#comment-16494404 ] Ted Yu commented on BEAM-4334: -- Currently tied up in dayjob. FYI > The Stream created in

[jira] [Updated] (BEAM-2805) Potential arithmetic overflow in Generator#nextAuctionLengthMs()

2018-05-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-2805: - Description: {code} long numEventsForAuctions = (config.configuration.numInFlightAuctions *

[jira] [Updated] (BEAM-3934) BoundedReader should be closed in JavaReadViaImpulse#ReadFromBoundedSourceFn

2018-05-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-3934: - Labels: usability (was: ) > BoundedReader should be closed in JavaReadViaImpulse#ReadFromBoundedSourceFn >

[jira] [Created] (BEAM-4334) The Stream created in LocalFileSystem#matchOne should be closed

2018-05-17 Thread Ted Yu (JIRA)
Ted Yu created BEAM-4334: Summary: The Stream created in LocalFileSystem#matchOne should be closed Key: BEAM-4334 URL: https://issues.apache.org/jira/browse/BEAM-4334 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-4185) Support building with Java 10

2018-04-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16457119#comment-16457119 ] Ted Yu commented on BEAM-4185: -- Then javadoc errors: {code} [javadoc]

[jira] [Commented] (BEAM-4185) Support building with Java 10

2018-04-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16457101#comment-16457101 ] Ted Yu commented on BEAM-4185: -- If I skip the above module, next would be this for Apache Beam :: Runners ::

[jira] [Created] (BEAM-4185) Support building with Java 10

2018-04-27 Thread Ted Yu (JIRA)
Ted Yu created BEAM-4185: Summary: Support building with Java 10 Key: BEAM-4185 URL: https://issues.apache.org/jira/browse/BEAM-4185 Project: Beam Issue Type: Improvement Components:

[jira] [Created] (BEAM-3935) FileChannel instance should be closed in ArtifactServiceStager#StagingCallable#get

2018-03-26 Thread Ted Yu (JIRA)
Ted Yu created BEAM-3935: Summary: FileChannel instance should be closed in ArtifactServiceStager#StagingCallable#get Key: BEAM-3935 URL: https://issues.apache.org/jira/browse/BEAM-3935 Project: Beam

[jira] [Created] (BEAM-3934) BoundedReader should be closed in JavaReadViaImpulse#ReadFromBoundedSourceFn

2018-03-26 Thread Ted Yu (JIRA)
Ted Yu created BEAM-3934: Summary: BoundedReader should be closed in JavaReadViaImpulse#ReadFromBoundedSourceFn Key: BEAM-3934 URL: https://issues.apache.org/jira/browse/BEAM-3934 Project: Beam

[jira] [Created] (BEAM-3915) Unclosed reader in JavaReadViaImpulse#ReadFromBoundedSourceFn

2018-03-22 Thread Ted Yu (JIRA)
Ted Yu created BEAM-3915: Summary: Unclosed reader in JavaReadViaImpulse#ReadFromBoundedSourceFn Key: BEAM-3915 URL: https://issues.apache.org/jira/browse/BEAM-3915 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-3845) Avoid calling Class#newInstance

2018-03-13 Thread Ted Yu (JIRA)
Ted Yu created BEAM-3845: Summary: Avoid calling Class#newInstance Key: BEAM-3845 URL: https://issues.apache.org/jira/browse/BEAM-3845 Project: Beam Issue Type: Task Components:

[jira] [Created] (BEAM-3679) Upgrade calcite to release 1.16

2018-02-09 Thread Ted Yu (JIRA)
Ted Yu created BEAM-3679: Summary: Upgrade calcite to release 1.16 Key: BEAM-3679 URL: https://issues.apache.org/jira/browse/BEAM-3679 Project: Beam Issue Type: Improvement Components:

[jira] [Created] (BEAM-3677) Declare proper exception type in catch block of KafkaExactlyOnceSink#initShardWriter

2018-02-09 Thread Ted Yu (JIRA)
Ted Yu created BEAM-3677: Summary: Declare proper exception type in catch block of KafkaExactlyOnceSink#initShardWriter Key: BEAM-3677 URL: https://issues.apache.org/jira/browse/BEAM-3677 Project: Beam

[jira] [Created] (BEAM-3140) Unchecked return value from bis.read() in MutationGroupEncoder#decodeMutation

2017-11-03 Thread Ted Yu (JIRA)
Ted Yu created BEAM-3140: Summary: Unchecked return value from bis.read() in MutationGroupEncoder#decodeMutation Key: BEAM-3140 URL: https://issues.apache.org/jira/browse/BEAM-3140 Project: Beam

[jira] [Created] (BEAM-2987) Close of InputStream should be placed in finally block

2017-09-25 Thread Ted Yu (JIRA)
Ted Yu created BEAM-2987: Summary: Close of InputStream should be placed in finally block Key: BEAM-2987 URL: https://issues.apache.org/jira/browse/BEAM-2987 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-1962) Connection should be closed in case start() throws exception

2017-09-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1962: - Description: In JmsIO#start() : {code} try { Connection connection; if (spec.getUsername()

[jira] [Updated] (BEAM-2805) Potential arithmetic overflow in Generator#nextAuctionLengthMs()

2017-09-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-2805: - Description: {code} long numEventsForAuctions = (config.configuration.numInFlightAuctions *

[jira] [Updated] (BEAM-2775) HadoopInputFormatIOTest fails with NoSuchMethodError

2017-09-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-2775: - Description: As of commit 8503adbbc3a590cd0dc2939f6a45d335682a9442, I got: {code} [ERROR]

[jira] [Updated] (BEAM-1962) Connection should be closed in case start() throws exception

2017-09-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1962: - Description: In JmsIO#start() : {code} try { Connection connection; if (spec.getUsername()

[jira] [Commented] (BEAM-2764) SolrIOTest fails in master branch

2017-09-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157533#comment-16157533 ] Ted Yu commented on BEAM-2764: -- lgtm > SolrIOTest fails in master branch > -

[jira] [Updated] (BEAM-2805) Potential arithmetic overflow in Generator#nextAuctionLengthMs()

2017-09-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-2805: - Description: {code} long numEventsForAuctions = (config.configuration.numInFlightAuctions *

[jira] [Updated] (BEAM-2335) Document various maven commands for running tests

2017-09-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-2335: - Description: In this discussion thread, various maven commands for running / not running selected tests were

[jira] [Created] (BEAM-2805) Potential arithmetic overflow in Generator#nextAuctionLengthMs()

2017-08-24 Thread Ted Yu (JIRA)
Ted Yu created BEAM-2805: Summary: Potential arithmetic overflow in Generator#nextAuctionLengthMs() Key: BEAM-2805 URL: https://issues.apache.org/jira/browse/BEAM-2805 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-2775) HadoopInputFormatIOTest fails with NoSuchMethodError

2017-08-17 Thread Ted Yu (JIRA)
Ted Yu created BEAM-2775: Summary: HadoopInputFormatIOTest fails with NoSuchMethodError Key: BEAM-2775 URL: https://issues.apache.org/jira/browse/BEAM-2775 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-2764) SolrIOTest fails in master branch

2017-08-14 Thread Ted Yu (JIRA)
Ted Yu created BEAM-2764: Summary: SolrIOTest fails in master branch Key: BEAM-2764 URL: https://issues.apache.org/jira/browse/BEAM-2764 Project: Beam Issue Type: Test Components:

[jira] [Updated] (BEAM-2335) Document various maven commands for running tests

2017-08-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-2335: - Description: In this discussion thread, various maven commands for running / not running selected tests were

[jira] [Updated] (BEAM-1962) Connection should be closed in case start() throws exception

2017-08-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1962: - Description: In JmsIO#start() : {code} try { Connection connection; if (spec.getUsername()

[jira] [Updated] (BEAM-1962) Connection should be closed in case start() throws exception

2017-08-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1962: - Description: In JmsIO#start() : {code} try { Connection connection; if (spec.getUsername()

[jira] [Updated] (BEAM-2335) Document various maven commands for running tests

2017-08-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-2335: - Description: In this discussion thread, various maven commands for running / not running selected tests were

[jira] [Resolved] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-07-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved BEAM-1773. -- Resolution: Later Fix Version/s: Not applicable > Consider allowing Source#validate() to throw exception

[jira] [Updated] (BEAM-1962) Connection should be closed in case start() throws exception

2017-07-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1962: - Description: In JmsIO#start() : {code} try { Connection connection; if (spec.getUsername()

[jira] [Updated] (BEAM-2335) Document various maven commands for running tests

2017-07-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-2335: - Description: In this discussion thread, various maven commands for running / not running selected tests were

[jira] [Updated] (BEAM-1962) Connection should be closed in case start() throws exception

2017-07-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1962: - Description: In JmsIO#start() : {code} try { Connection connection; if (spec.getUsername()

[jira] [Updated] (BEAM-2335) Document various maven commands for running tests

2017-07-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-2335: - Labels: document (was: ) > Document various maven commands for running tests >

[jira] [Created] (BEAM-2608) Unclosed BoundedReader in TextIO#ReadTextFn#process()

2017-07-12 Thread Ted Yu (JIRA)
Ted Yu created BEAM-2608: Summary: Unclosed BoundedReader in TextIO#ReadTextFn#process() Key: BEAM-2608 URL: https://issues.apache.org/jira/browse/BEAM-2608 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-1962) Connection should be closed in case start() throws exception

2017-06-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1962: - Description: In JmsIO#start() : {code} try { Connection connection; if (spec.getUsername()

[jira] [Updated] (BEAM-2335) Document various maven commands for running tests

2017-06-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-2335: - Description: In this discussion thread, various maven commands for running / not running selected tests were

[jira] [Updated] (BEAM-1962) Connection should be closed in case start() throws exception

2017-05-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1962: - Description: In JmsIO#start() : {code} try { Connection connection; if (spec.getUsername()

[jira] [Created] (BEAM-2335) Document various maven commands for running tests

2017-05-19 Thread Ted Yu (JIRA)
Ted Yu created BEAM-2335: Summary: Document various maven commands for running tests Key: BEAM-2335 URL: https://issues.apache.org/jira/browse/BEAM-2335 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-1962) Connection should be closed in case start() throws exception

2017-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1962: - Description: In JmsIO#start() : {code} try { Connection connection; if (spec.getUsername()

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-05-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991524#comment-15991524 ] Ted Yu commented on BEAM-1773: -- Currently working on making tests compile. For related sub-tests, I am adding

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-05-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990938#comment-15990938 ] Ted Yu commented on BEAM-1773: -- [~kenn]: Can you take a look at the latest patch ? > Consider allowing

[jira] [Resolved] (BEAM-2123) Passing potential null pointer to encode() in StructuredCoder#structuralValue

2017-04-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved BEAM-2123. -- Resolution: Not A Problem Fix Version/s: Not applicable > Passing potential null pointer to encode() in

[jira] [Commented] (BEAM-2123) Passing potential null pointer to encode() in StructuredCoder#structuralValue

2017-04-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990529#comment-15990529 ] Ted Yu commented on BEAM-2123: -- Thanks for the confirmation (I didn't see structuralValue() either) > Passing

[jira] [Commented] (BEAM-2123) Passing potential null pointer to encode() in StructuredCoder#structuralValue

2017-04-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990526#comment-15990526 ] Ted Yu commented on BEAM-2123: -- I looked at

[jira] [Commented] (BEAM-2123) Passing potential null pointer to encode() in StructuredCoder#structuralValue

2017-04-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990387#comment-15990387 ] Ted Yu commented on BEAM-2123: -- I am interested in seeing a counter example where null value produces

[jira] [Updated] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1773: - Attachment: (was: 1773.v4.patch) > Consider allowing Source#validate() to throw exception >

[jira] [Updated] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1773: - Attachment: 1773.v4.patch > Consider allowing Source#validate() to throw exception >

[jira] [Updated] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1773: - Attachment: 1773.v4.patch See if patch v4 is on right track. > Consider allowing Source#validate() to throw

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990102#comment-15990102 ] Ted Yu commented on BEAM-1773: -- Should ValidationException class be created in org.apache.beam.sdk package ?

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990101#comment-15990101 ] Ted Yu commented on BEAM-1773: -- w.r.t. ValidationException, I assume you mean creating ValidationException

[jira] [Comment Edited] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990101#comment-15990101 ] Ted Yu edited comment on BEAM-1773 at 4/30/17 2:23 AM: --- w.r.t. ValidationException, I

[jira] [Created] (BEAM-2123) Passing potential null pointer to encode() in StructuredCoder#structuralValue

2017-04-29 Thread Ted Yu (JIRA)
Ted Yu created BEAM-2123: Summary: Passing potential null pointer to encode() in StructuredCoder#structuralValue Key: BEAM-2123 URL: https://issues.apache.org/jira/browse/BEAM-2123 Project: Beam

[jira] [Comment Edited] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15957130#comment-15957130 ] Ted Yu edited comment on BEAM-1773 at 4/29/17 11:22 PM: [~kenn]

[jira] [Commented] (BEAM-1831) Checking of containment in createdTables may have race condition in StreamingWriteFn

2017-04-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15989162#comment-15989162 ] Ted Yu commented on BEAM-1831: -- Thanks for checking. Maybe comment should be added before the second check

[jira] [Closed] (BEAM-1745) Unintended unboxing of potential null pointer in AutoValue_ElasticsearchIO_Write

2017-04-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu closed BEAM-1745. Resolution: Not A Problem Fix Version/s: Not applicable > Unintended unboxing of potential null pointer in >

[jira] [Comment Edited] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15957130#comment-15957130 ] Ted Yu edited comment on BEAM-1773 at 4/20/17 8:22 PM: --- [~kenn] [~j...@nanthrax.net]:

[jira] [Created] (BEAM-1962) Connection should be closed in case start() throws exception

2017-04-13 Thread Ted Yu (JIRA)
Ted Yu created BEAM-1962: Summary: Connection should be closed in case start() throws exception Key: BEAM-1962 URL: https://issues.apache.org/jira/browse/BEAM-1962 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1773: - Attachment: beam-1773.v2.patch > Consider allowing Source#validate() to throw exception >

[jira] [Created] (BEAM-1950) Access to static field shouldn't be protected by lock on non-static MicrobatchSource.this

2017-04-12 Thread Ted Yu (JIRA)
Ted Yu created BEAM-1950: Summary: Access to static field shouldn't be protected by lock on non-static MicrobatchSource.this Key: BEAM-1950 URL: https://issues.apache.org/jira/browse/BEAM-1950 Project: Beam

[jira] [Comment Edited] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15957130#comment-15957130 ] Ted Yu edited comment on BEAM-1773 at 4/7/17 4:44 PM: -- [~kenn] [~j...@nanthrax.net]:

[jira] [Commented] (BEAM-1734) Potentially unbox null pointer in AutoValue_BigQueryIO_Write

2017-04-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15957626#comment-15957626 ] Ted Yu commented on BEAM-1734: -- This seems to be caused by defect in codegen for AutoValue annotation. Can

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15957130#comment-15957130 ] Ted Yu commented on BEAM-1773: -- [~kenn] [~j...@nanthrax.net]: Please provide your feedback. > Consider

[jira] [Comment Edited] (BEAM-1832) Potentially unclosed OutputStream in ApexYarnLauncher

2017-04-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947383#comment-15947383 ] Ted Yu edited comment on BEAM-1832 at 4/4/17 9:02 PM: -- In the same class: {code}

[jira] [Updated] (BEAM-1831) Checking of containment in createdTables may have race condition in StreamingWriteFn

2017-04-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1831: - Description: {code} public TableReference getOrCreateTable(BigQueryOptions options, String tableSpec)

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953890#comment-15953890 ] Ted Yu commented on BEAM-1773: -- [~kenn] [~j...@nanthrax.net]: Can you comment on the above proposal ? >

[jira] [Resolved] (BEAM-1760) Potential null dereference in HDFSFileSink#doFinalize

2017-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved BEAM-1760. -- Resolution: Later Assignee: Davor Bonaci (was: Ted Yu) Fix Version/s: Not applicable >

[jira] [Updated] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1773: - Attachment: (was: beam-1773.v1.patch) > Consider allowing Source#validate() to throw exception >

[jira] [Updated] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1773: - Attachment: beam-1773.v1.patch > Consider allowing Source#validate() to throw exception >

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953809#comment-15953809 ] Ted Yu commented on BEAM-1773: -- I want to get some opinion on the method signature for PTransform#expand(). Is

[jira] [Updated] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1773: - Attachment: beam-1773.v1.patch > Consider allowing Source#validate() to throw exception >

[jira] [Assigned] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu reassigned BEAM-1773: Assignee: Ted Yu (was: Jean-Baptiste Onofré) > Consider allowing Source#validate() to throw exception >

[jira] [Commented] (BEAM-1760) Potential null dereference in HDFSFileSink#doFinalize

2017-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953657#comment-15953657 ] Ted Yu commented on BEAM-1760: -- [~davor]: Mind taking a look ? > Potential null dereference in

[jira] [Comment Edited] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952662#comment-15952662 ] Ted Yu edited comment on BEAM-1773 at 4/3/17 3:13 PM: -- [~j...@nanthrax.net]: If you

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-04-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952662#comment-15952662 ] Ted Yu commented on BEAM-1773: -- JB: If you are busy, I can work on this. > Consider allowing

[jira] [Commented] (BEAM-1832) Potentially unclosed OutputStream in ApexYarnLauncher

2017-03-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947383#comment-15947383 ] Ted Yu commented on BEAM-1832: -- In the same class: {code} public static List getYarnDeployDependencies()

[jira] [Created] (BEAM-1832) Potentially unclosed OutputStream in ApexYarnLauncher

2017-03-29 Thread Ted Yu (JIRA)
Ted Yu created BEAM-1832: Summary: Potentially unclosed OutputStream in ApexYarnLauncher Key: BEAM-1832 URL: https://issues.apache.org/jira/browse/BEAM-1832 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-1831) Checking of containment in createdTables may have race condition in StreamingWriteFn

2017-03-29 Thread Ted Yu (JIRA)
Ted Yu created BEAM-1831: Summary: Checking of containment in createdTables may have race condition in StreamingWriteFn Key: BEAM-1831 URL: https://issues.apache.org/jira/browse/BEAM-1831 Project: Beam

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-03-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946311#comment-15946311 ] Ted Yu commented on BEAM-1773: -- [~kenn]: Do you have other comment ? > Consider allowing Source#validate() to

[jira] [Commented] (BEAM-1760) Potential null dereference in HDFSFileSink#doFinalize

2017-03-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946210#comment-15946210 ] Ted Yu commented on BEAM-1760: -- [~davor]: Can you take a look at the PR ? > Potential null dereference in

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-03-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935586#comment-15935586 ] Ted Yu commented on BEAM-1773: -- Unchecked (runtime) exception: Should indicate a coding error. To fix it

[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-03-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934732#comment-15934732 ] Ted Yu commented on BEAM-1773: -- Feel free to take it. Thanks. > Consider allowing Source#validate() to throw

[jira] [Created] (BEAM-1773) Consider allowing Source#validate() to throw exception

2017-03-21 Thread Ted Yu (JIRA)
Ted Yu created BEAM-1773: Summary: Consider allowing Source#validate() to throw exception Key: BEAM-1773 URL: https://issues.apache.org/jira/browse/BEAM-1773 Project: Beam Issue Type: Improvement

[jira] [Comment Edited] (BEAM-1761) Unintended unboxing of potential null pointer in AutoValue_HDFSFileSource

2017-03-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933746#comment-15933746 ] Ted Yu edited comment on BEAM-1761 at 3/20/17 11:01 PM: I checked most recent

[jira] [Resolved] (BEAM-1761) Unintended unboxing of potential null pointer in AutoValue_HDFSFileSource

2017-03-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved BEAM-1761. -- Resolution: Not A Problem Fix Version/s: Not applicable > Unintended unboxing of potential null pointer

[jira] [Commented] (BEAM-1761) Unintended unboxing of potential null pointer in AutoValue_HDFSFileSource

2017-03-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933746#comment-15933746 ] Ted Yu commented on BEAM-1761: -- I checked most recent master branch. AutoValue_HDFSFileSink.java is gone and

[jira] [Commented] (BEAM-1761) Unintended unboxing of potential null pointer in AutoValue_HDFSFileSource

2017-03-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933732#comment-15933732 ] Ted Yu commented on BEAM-1761: -- Can you review the PR over BEAM-1568 first ? I can work on this once that is

[jira] [Commented] (BEAM-1761) Unintended unboxing of potential null pointer in AutoValue_HDFSFileSource

2017-03-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933153#comment-15933153 ] Ted Yu commented on BEAM-1761: -- Similar problem exists in AutoValue_HDFSFileSink.java > Unintended unboxing

[jira] [Updated] (BEAM-1761) Unintended unboxing of potential null pointer in AutoValue_HDFSFileSource

2017-03-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1761: - Description: {code} if (validateSource == null) { missing += " validateSource"; } ...

[jira] [Created] (BEAM-1761) Unintended unboxing of potential null pointer in AutoValue_HDFSFileSource

2017-03-20 Thread Ted Yu (JIRA)
Ted Yu created BEAM-1761: Summary: Unintended unboxing of potential null pointer in AutoValue_HDFSFileSource Key: BEAM-1761 URL: https://issues.apache.org/jira/browse/BEAM-1761 Project: Beam Issue

[jira] [Created] (BEAM-1760) Potential null dereference in HDFSFileSink#doFinalize

2017-03-20 Thread Ted Yu (JIRA)
Ted Yu created BEAM-1760: Summary: Potential null dereference in HDFSFileSink#doFinalize Key: BEAM-1760 URL: https://issues.apache.org/jira/browse/BEAM-1760 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-1568) Ineffective null check in IsmFormat#structuralValue

2017-03-19 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1568: - Description: {code} public Object structuralValue(IsmRecord record) throws Exception {

[jira] [Resolved] (BEAM-1574) MongoDbIOTest fails due to inability to download mongodb tar ball

2017-03-19 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved BEAM-1574. -- Resolution: Cannot Reproduce Fix Version/s: Not applicable > MongoDbIOTest fails due to inability to

[jira] [Commented] (BEAM-1745) Unintended unboxing of potential null pointer in AutoValue_ElasticsearchIO_Write

2017-03-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930747#comment-15930747 ] Ted Yu commented on BEAM-1745: -- There is similar problem in AutoValue_ElasticsearchIO_Read > Unintended

[jira] [Created] (BEAM-1745) Unintended unboxing of potential null pointer in AutoValue_ElasticsearchIO_Write

2017-03-17 Thread Ted Yu (JIRA)
Ted Yu created BEAM-1745: Summary: Unintended unboxing of potential null pointer in AutoValue_ElasticsearchIO_Write Key: BEAM-1745 URL: https://issues.apache.org/jira/browse/BEAM-1745 Project: Beam

[jira] [Created] (BEAM-1734) Potentially unbox null pointer in AutoValue_BigQueryIO_Write

2017-03-16 Thread Ted Yu (JIRA)
Ted Yu created BEAM-1734: Summary: Potentially unbox null pointer in AutoValue_BigQueryIO_Write Key: BEAM-1734 URL: https://issues.apache.org/jira/browse/BEAM-1734 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-1568) Ineffective null check in IsmFormat#structuralValue

2017-03-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1568: - Description: {code} public Object structuralValue(IsmRecord record) throws Exception {

[jira] [Commented] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes()

2017-03-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890543#comment-15890543 ] Ted Yu commented on BEAM-1567: -- [~iemejia]: Can you take a look at the PR ? Thanks > hashStream should be

[jira] [Commented] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes()

2017-02-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15888484#comment-15888484 ] Ted Yu commented on BEAM-1567: -- [~dhalp...@google.com]: Can you take a look at the latest PR ? > hashStream

  1   2   >