[jira] [Assigned] (BEAM-10183) Update links for RabbitMqIO and KuduIO IO doc to Javadoc

2020-06-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-10183: --- Assignee: Alexey Romanenko > Update links for RabbitMqIO and KuduIO IO doc to

[jira] [Created] (BEAM-10183) Update links for RabbitMqIO and KuduIO IO doc to Javadoc

2020-06-03 Thread Alexey Romanenko (Jira)
Alexey Romanenko created BEAM-10183: --- Summary: Update links for RabbitMqIO and KuduIO IO doc to Javadoc Key: BEAM-10183 URL: https://issues.apache.org/jira/browse/BEAM-10183 Project: Beam

[jira] [Comment Edited] (BEAM-9742) Add ability to pass FluentBackoff to JdbcIo.Write

2020-06-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123706#comment-17123706 ] Alexey Romanenko edited comment on BEAM-9742 at 6/2/20, 12:22 PM: -- UPD:

[jira] [Work started] (BEAM-6515) Unable to read messages from RabbitMQ as a continuous stream

2020-06-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-6515 started by Alexey Romanenko. -- > Unable to read messages from RabbitMQ as a continuous stream >

[jira] [Updated] (BEAM-9742) Add ability to pass FluentBackoff to JdbcIo.Write

2020-06-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9742: --- Labels: (was: stale-assigned) > Add ability to pass FluentBackoff to JdbcIo.Write >

[jira] [Commented] (BEAM-9742) Add ability to pass FluentBackoff to JdbcIo.Write

2020-06-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123706#comment-17123706 ] Alexey Romanenko commented on BEAM-9742: UPD: PRs review is in process. > Add ability to pass

[jira] [Assigned] (BEAM-5786) KafkaIO should support topic patterns

2020-05-29 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-5786: -- Assignee: (was: Alexey Romanenko) > KafkaIO should support topic patterns >

[jira] [Resolved] (BEAM-10098) Javadoc export deactivated for RabbitMqIO and KuduIO

2020-05-28 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-10098. - Fix Version/s: Not applicable Resolution: Fixed > Javadoc export deactivated for

[jira] [Updated] (BEAM-10098) Javadoc export deactivated for RabbitMqIO and KuduIO

2020-05-28 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10098: Fix Version/s: (was: Not applicable) 2.23.0 > Javadoc export

[jira] [Resolved] (BEAM-9916) Update IOs documentation links

2020-05-27 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9916. Fix Version/s: Not applicable Resolution: Fixed > Update IOs documentation links >

[jira] [Resolved] (BEAM-7770) Add ReadAll transform for SolrIO

2020-05-27 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-7770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-7770. Fix Version/s: 2.23.0 Resolution: Fixed > Add ReadAll transform for SolrIO >

[jira] [Commented] (BEAM-9977) Build Kafka Read on top of Java SplittableDoFn

2020-05-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116859#comment-17116859 ] Alexey Romanenko commented on BEAM-9977: [~boyuanz] I see that there is a PR #11715, that was

[jira] [Assigned] (BEAM-9916) Update IOs documentation links

2020-05-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-9916: -- Assignee: Ashwin Ramaswami (was: Alexey Romanenko) > Update IOs documentation links >

[jira] [Comment Edited] (BEAM-9916) Update IOs documentation links

2020-05-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116786#comment-17116786 ] Alexey Romanenko edited comment on BEAM-9916 at 5/26/20, 2:40 PM: --

[jira] [Assigned] (BEAM-9916) Update IOs documentation links

2020-05-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-9916: -- Assignee: Alexey Romanenko > Update IOs documentation links >

[jira] [Assigned] (BEAM-9916) Update IOs documentation links

2020-05-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-9916: -- Assignee: (was: Alexey Romanenko) > Update IOs documentation links >

[jira] [Commented] (BEAM-9916) Update IOs documentation links

2020-05-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116786#comment-17116786 ] Alexey Romanenko commented on BEAM-9916: [~epicfaace] Good point, thanks! I'll check them out and

[jira] [Commented] (BEAM-9760) KafkaIO supports consumer group?

2020-05-12 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105641#comment-17105641 ] Alexey Romanenko commented on BEAM-9760: Hi [~wongkawah], thanks for details. I see your point but

[jira] [Resolved] (BEAM-9439) KinesisReader does not report correct backlog statistics

2020-05-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9439. Fix Version/s: 2.22.0 Resolution: Fixed > KinesisReader does not report correct

[jira] [Updated] (BEAM-9916) Update IOs documentation links

2020-05-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9916: --- Description: Currently, on the webpage [https://beam.apache.org/documentation/io/built-in/] 

[jira] [Updated] (BEAM-9916) Update IOs documentation links

2020-05-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9916: --- Status: Open (was: Triage Needed) > Update IOs documentation links >

[jira] [Assigned] (BEAM-9916) Update IOs documentation links

2020-05-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-9916: -- Assignee: Alexey Romanenko > Update IOs documentation links >

[jira] [Updated] (BEAM-9916) Update IOs documentation links

2020-05-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9916: --- Description: Currently, on the webpage [https://beam.apache.org/documentation/io/built-in/] 

[jira] [Created] (BEAM-9916) Update IOs documentation links

2020-05-07 Thread Alexey Romanenko (Jira)
Alexey Romanenko created BEAM-9916: -- Summary: Update IOs documentation links Key: BEAM-9916 URL: https://issues.apache.org/jira/browse/BEAM-9916 Project: Beam Issue Type: Improvement

[jira] [Resolved] (BEAM-8542) Add async write to AWS SNS IO & remove retry logic

2020-05-05 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-8542. Fix Version/s: 2.22.0 Resolution: Fixed > Add async write to AWS SNS IO & remove

[jira] [Resolved] (BEAM-9720) Add custom AWS Http Client Configuration capability for AWS client 1.0/2.0

2020-04-30 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9720. Fix Version/s: 2.22.0 Resolution: Fixed > Add custom AWS Http Client Configuration

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

2020-04-24 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091688#comment-17091688 ] Alexey Romanenko commented on BEAM-8121: [~chamikara] Yes, it could be a good idea. Do you mean to

[jira] [Commented] (BEAM-9760) KafkaIO supports consumer group?

2020-04-24 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091682#comment-17091682 ] Alexey Romanenko commented on BEAM-9760: Could you elaborate more about your proposal?  For now,

[jira] [Resolved] (BEAM-9686) SparkCommonPipelineOptions should not depend of a child class to resolve the tmp checkpoint dir

2020-04-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9686. Fix Version/s: 2.21.0 Resolution: Fixed > SparkCommonPipelineOptions should not

[jira] [Closed] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

2020-04-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko closed BEAM-8121. -- Fix Version/s: Not applicable Resolution: Not A Problem I close it since the problem was

[jira] [Assigned] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

2020-04-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-8121: -- Assignee: Alexey Romanenko > Messages are not distributed per machines when consuming

[jira] [Closed] (BEAM-7942) Kafka backward compatibility

2020-04-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko closed BEAM-7942. -- Fix Version/s: (was: 2.8.0) Not applicable Assignee: Alexey

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

2020-04-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074511#comment-17074511 ] Alexey Romanenko commented on BEAM-8121: [~TauJan] Do you have any updates on this issue? Do you

[jira] [Comment Edited] (BEAM-9525) KafkaIO attempting to make connection when uploading via Dataflow Runner

2020-04-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072936#comment-17072936 ] Alexey Romanenko edited comment on BEAM-9525 at 4/3/20, 11:25 AM: -- Do you

[jira] [Resolved] (BEAM-7299) Upgrade kafka client for KafkaIO to support new compression zstd

2020-04-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-7299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-7299. Fix Version/s: Not applicable Resolution: Won't Fix I close this one since it was

[jira] [Resolved] (BEAM-9476) KinesisIO DescribeStream transient errors are not retried

2020-04-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9476. Fix Version/s: 2.21.0 Resolution: Fixed > KinesisIO DescribeStream transient errors

[jira] [Assigned] (BEAM-9476) KinesisIO DescribeStream transient errors are not retried

2020-04-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-9476: -- Assignee: Alexey Romanenko > KinesisIO DescribeStream transient errors are not retried

[jira] [Updated] (BEAM-9476) KinesisIO DescribeStream transient errors are not retried

2020-04-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9476: --- Status: Open (was: Triage Needed) > KinesisIO DescribeStream transient errors are not

[jira] [Commented] (BEAM-7519) Improve work with SSL/TLS certificates in SDK IO, for Google Dataflow

2020-04-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-7519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073706#comment-17073706 ] Alexey Romanenko commented on BEAM-7519: I just found this issue by chance, so the answer is quite

[jira] [Comment Edited] (BEAM-9627) KafkaIO needs better support for SSL

2020-04-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073702#comment-17073702 ] Alexey Romanenko edited comment on BEAM-9627 at 4/2/20, 12:55 PM: -- I

[jira] [Updated] (BEAM-9525) KafkaIO attempting to make connection when uploading via Dataflow Runner

2020-04-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9525: --- Status: Open (was: Triage Needed) > KafkaIO attempting to make connection when uploading via

[jira] [Resolved] (BEAM-9627) KafkaIO needs better support for SSL

2020-04-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9627. Fix Version/s: Not applicable Resolution: Not A Problem I close this issue since

[jira] [Commented] (BEAM-9627) KafkaIO needs better support for SSL

2020-04-01 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072966#comment-17072966 ] Alexey Romanenko commented on BEAM-9627: Actually, this hook already exists. You can try to use

[jira] [Updated] (BEAM-9525) KafkaIO attempting to make connection when uploading via Dataflow Runner

2020-04-01 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9525: --- Status: Triage Needed (was: Open) > KafkaIO attempting to make connection when uploading via

[jira] [Updated] (BEAM-9627) KafkaIO needs better support for SSL

2020-04-01 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9627: --- Status: Open (was: Triage Needed) > KafkaIO needs better support for SSL >

[jira] [Updated] (BEAM-9525) KafkaIO attempting to make connection when uploading via Dataflow Runner

2020-04-01 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9525: --- Status: Open (was: Triage Needed) > KafkaIO attempting to make connection when uploading via

[jira] [Commented] (BEAM-9525) KafkaIO attempting to make connection when uploading via Dataflow Runner

2020-04-01 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072936#comment-17072936 ] Alexey Romanenko commented on BEAM-9525: Do you know what kind of request it sends to broker in

[jira] [Assigned] (BEAM-9439) KinesisReader does not report correct backlog statistics

2020-03-31 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-9439: -- Assignee: Sebastian Graca > KinesisReader does not report correct backlog statistics

[jira] [Commented] (BEAM-9439) KinesisReader does not report correct backlog statistics

2020-03-31 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071688#comment-17071688 ] Alexey Romanenko commented on BEAM-9439: [~titmus] Thanks, sounds good to me as a trade-off

[jira] [Comment Edited] (BEAM-9439) KinesisReader does not report correct backlog statistics

2020-03-30 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071128#comment-17071128 ] Alexey Romanenko edited comment on BEAM-9439 at 3/30/20, 4:41 PM: --

[jira] [Commented] (BEAM-9439) KinesisReader does not report correct backlog statistics

2020-03-30 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071128#comment-17071128 ] Alexey Romanenko commented on BEAM-9439: [~pawel.kaczmarczyk] I think now I see why

[jira] [Commented] (BEAM-9439) KinesisReader does not report correct backlog statistics

2020-03-30 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071120#comment-17071120 ] Alexey Romanenko commented on BEAM-9439: [~titmus] Thank for testing this. I'm not a Dataflow

[jira] [Updated] (BEAM-9439) KinesisReader does not report correct backlog statistics

2020-03-30 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9439: --- Status: Open (was: Triage Needed) > KinesisReader does not report correct backlog statistics

[jira] [Comment Edited] (BEAM-9439) KinesisReader does not report correct backlog statistics

2020-03-27 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068938#comment-17068938 ] Alexey Romanenko edited comment on BEAM-9439 at 3/27/20, 5:56 PM: -- Thank

[jira] [Commented] (BEAM-9439) KinesisReader does not report correct backlog statistics

2020-03-27 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068938#comment-17068938 ] Alexey Romanenko commented on BEAM-9439: Thank you for reporting this.  I'd ask

[jira] [Commented] (BEAM-9133) CassandraIOTest.classMethod test is still flaky

2020-03-25 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17066687#comment-17066687 ] Alexey Romanenko commented on BEAM-9133: Is there any update on this? It's still flaky:

[jira] [Resolved] (BEAM-9420) Configurable timeout for Kafka setupInitialOffset()

2020-03-25 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9420. Fix Version/s: 2.21.0 Resolution: Fixed > Configurable timeout for Kafka

[jira] [Commented] (BEAM-9420) Configurable timeout for Kafka setupInitialOffset()

2020-03-24 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065571#comment-17065571 ] Alexey Romanenko commented on BEAM-9420: I left my comments on the PR page. Sorry for delay with

[jira] [Resolved] (BEAM-9470) :sdks:java:io:kinesis:test is flaky

2020-03-19 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9470. Fix Version/s: 2.21.0 Resolution: Fixed > :sdks:java:io:kinesis:test is flaky >

[jira] [Resolved] (BEAM-9279) Make HBase.ReadAll based on Reads instead of HBaseQuery

2020-03-19 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9279. Fix Version/s: 2.21.0 Resolution: Fixed > Make HBase.ReadAll based on Reads instead

[jira] [Updated] (BEAM-9470) :sdks:java:io:kinesis:test is flaky

2020-03-10 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9470: --- Status: Open (was: Triage Needed) > :sdks:java:io:kinesis:test is flaky >

[jira] [Commented] (BEAM-9470) :sdks:java:io:kinesis:test is flaky

2020-03-09 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055169#comment-17055169 ] Alexey Romanenko commented on BEAM-9470:

[jira] [Comment Edited] (BEAM-9420) Configurable timeout for Kafka setupInitialOffset()

2020-03-05 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052385#comment-17052385 ] Alexey Romanenko edited comment on BEAM-9420 at 3/5/20, 5:55 PM: - Why

[jira] [Commented] (BEAM-9420) Configurable timeout for Kafka setupInitialOffset()

2020-03-05 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052385#comment-17052385 ] Alexey Romanenko commented on BEAM-9420: Why \{{request.timeout.ms}} wouldn't work in this case?

[jira] [Updated] (BEAM-8382) Add polling interval to KinesisIO.Read

2020-03-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-8382: --- Fix Version/s: (was: 2.20.0) 2.21.0 > Add polling interval to

[jira] [Resolved] (BEAM-8382) Add polling interval to KinesisIO.Read

2020-03-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-8382. Fix Version/s: 2.20.0 Resolution: Fixed > Add polling interval to KinesisIO.Read >

[jira] [Resolved] (BEAM-9329) Support request of schemas by version on KafkaIO + Confluent Schema Registry

2020-02-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9329. Fix Version/s: 2.20.0 Resolution: Fixed > Support request of schemas by version on

[jira] [Resolved] (BEAM-9364) Refactor KafkaIO to use DeserializerProviders

2020-02-25 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9364. Resolution: Fixed > Refactor KafkaIO to use DeserializerProviders >

[jira] [Resolved] (BEAM-9281) Update commons-csv to version 1.8

2020-02-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9281. Resolution: Fixed > Update commons-csv to version 1.8 > - >

[jira] [Updated] (BEAM-9292) Provide an ability to specify additional maven repositories for published POMs

2020-02-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9292: --- Description: To support Confluent Schema Registry, KafkaIO has a dependency on

[jira] [Updated] (BEAM-9292) Provide an ability to specify additional maven repositories for published POMs

2020-02-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9292: --- Description: To support Confluent Schema Registry, KafkaIO has a dependency on

[jira] [Updated] (BEAM-9292) Provide an ability to specify additional maven repositories for published POMs

2020-02-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9292: --- Description: To support Confluent Schema Registry, KafkaIO has a dependency on

[jira] [Updated] (BEAM-9292) Provide an ability to specify additional maven repositories for published POMs

2020-02-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9292: --- Description: To support Confluent Schema Registry, KafkaIO has a dependency from

[jira] [Updated] (BEAM-9292) Provide an ability to specify additional maven repositories for published POMs

2020-02-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9292: --- Description: To support Confluent Schema Registry, KafkaIO has a dependency from

[jira] [Updated] (BEAM-9292) Provide an ability to specify additional maven repositories for published POMs

2020-02-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9292: --- Description: To support Confluent Schema Registry, KafkaIO has a dependency on

[jira] [Updated] (BEAM-9292) Provide an ability to specify additional maven repositories for published POMs

2020-02-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9292: --- Description: To support Confluent Schema Registry, KafkaIO has a dependency from

[jira] [Updated] (BEAM-9292) Provide an ability to specify additional maven repositories for published POMs

2020-02-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9292: --- Description: To support Confluent Schema Registry, KafkaIO has a dependency from

[jira] [Created] (BEAM-9292) Provide an ability to specify additional maven repositories for published POMs

2020-02-11 Thread Alexey Romanenko (Jira)
Alexey Romanenko created BEAM-9292: -- Summary: Provide an ability to specify additional maven repositories for published POMs Key: BEAM-9292 URL: https://issues.apache.org/jira/browse/BEAM-9292

[jira] [Assigned] (BEAM-9292) Provide an ability to specify additional maven repositories for published POMs

2020-02-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-9292: -- Assignee: Alexey Romanenko > Provide an ability to specify additional maven

[jira] [Commented] (BEAM-9253) SQL PostCommit failure: ClassCastException: java.lang.Integer cannot be cast to java.lang.Long

2020-02-05 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030661#comment-17030661 ] Alexey Romanenko commented on BEAM-9253: More details about failing test: {code}

[jira] [Commented] (BEAM-9251) :sdks:java:io:kafka:updateOfflineRepository fails

2020-02-05 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030541#comment-17030541 ] Alexey Romanenko commented on BEAM-9251: Thank you for fixing this! >

[jira] [Comment Edited] (BEAM-4420) Add KafkaIO Integration Tests

2020-01-31 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027701#comment-17027701 ] Alexey Romanenko edited comment on BEAM-4420 at 1/31/20 5:56 PM: -

[jira] [Commented] (BEAM-4420) Add KafkaIO Integration Tests

2020-01-31 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027701#comment-17027701 ] Alexey Romanenko commented on BEAM-4420: [~mwalenia] Could we close this issue since KafkaIOIT

[jira] [Resolved] (BEAM-9143) Add withOutputParallelization to RedisIO.Read/ReadAll

2020-01-17 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9143. Fix Version/s: 2.20.0 Resolution: Fixed > Add withOutputParallelization to

[jira] [Updated] (BEAM-9133) CassandraIOTest.classMethod test is still flaky

2020-01-16 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9133: --- Summary: CassandraIOTest.classMethod test is still flaky (was: CassandraIOTest classMethod

[jira] [Updated] (BEAM-9133) CassandraIOTest classMethod test is still flaky

2020-01-16 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9133: --- Summary: CassandraIOTest classMethod test is still flaky (was: Cassandra IO classMethod test

[jira] [Created] (BEAM-9133) Cassandra IO classMethod test is still flaky

2020-01-16 Thread Alexey Romanenko (Jira)
Alexey Romanenko created BEAM-9133: -- Summary: Cassandra IO classMethod test is still flaky Key: BEAM-9133 URL: https://issues.apache.org/jira/browse/BEAM-9133 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-9123) HadoopResourceId returns wrong directory name

2020-01-16 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016913#comment-17016913 ] Alexey Romanenko commented on BEAM-9123: Is it really going to be included into 2.18 release (1st

[jira] [Work started] (BEAM-7310) Confluent Schema Registry support in KafkaIO

2020-01-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-7310 started by Alexey Romanenko. -- > Confluent Schema Registry support in KafkaIO >

[jira] [Updated] (BEAM-8953) Extend ParquetIO.Read/ReadFiles.Builder to support Avro GenericData model

2020-01-09 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-8953: --- Affects Version/s: (was: 2.16.0) > Extend ParquetIO.Read/ReadFiles.Builder to support

[jira] [Resolved] (BEAM-8953) Extend ParquetIO.Read/ReadFiles.Builder to support Avro GenericData model

2020-01-09 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-8953. Fix Version/s: 2.19.0 Resolution: Fixed > Extend ParquetIO.Read/ReadFiles.Builder to

[jira] [Updated] (BEAM-8953) Extend ParquetIO.Read/ReadFiles.Builder to support Avro GenericData model

2020-01-09 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-8953: --- Component/s: (was: examples-java) io-java-parquet > Extend

[jira] [Resolved] (BEAM-8701) Beam Dependency Update Request: commons-io:commons-io

2020-01-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-8701. Fix Version/s: 2.19.0 Resolution: Fixed > Beam Dependency Update Request:

[jira] [Updated] (BEAM-8701) Beam Dependency Update Request: commons-io:commons-io

2020-01-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-8701: --- Status: Open (was: Triage Needed) > Beam Dependency Update Request: commons-io:commons-io >

[jira] [Updated] (BEAM-8749) Beam Dependency Update Request: com.datastax.cassandra:cassandra-driver-mapping

2020-01-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-8749: --- Status: Open (was: Triage Needed) > Beam Dependency Update Request: >

[jira] [Resolved] (BEAM-8749) Beam Dependency Update Request: com.datastax.cassandra:cassandra-driver-mapping

2020-01-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-8749. Fix Version/s: 2.19.0 Resolution: Fixed > Beam Dependency Update Request: >

[jira] [Updated] (BEAM-5546) Beam Dependency Update Request: commons-codec:commons-codec

2020-01-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-5546: --- Fix Version/s: (was: 2.18.0) 2.19.0 > Beam Dependency Update Request:

[jira] [Resolved] (BEAM-5546) Beam Dependency Update Request: commons-codec:commons-codec

2020-01-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-5546. Fix Version/s: (was: Not applicable) 2.18.0 Resolution: Fixed

[jira] [Updated] (BEAM-5546) Beam Dependency Update Request: commons-codec:commons-codec

2020-01-07 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-5546: --- Status: Open (was: Triage Needed) > Beam Dependency Update Request:

[jira] [Resolved] (BEAM-8978) Report saved data size from HadoopFormatIOIT

2019-12-20 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-8978. Fix Version/s: 2.19.0 Resolution: Fixed > Report saved data size from

  1   2   3   4   >