[jira] [Assigned] (BEAM-2546) Add InfluxDbIO

2020-09-08 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-2546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-2546: -- Assignee: Bipin Upadhyaya > Add InfluxDbIO > -- > > Key: BE

[jira] [Updated] (BEAM-2546) Add InfluxDbIO

2020-09-08 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-2546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-2546: --- Priority: P2 (was: P3) > Add InfluxDbIO > -- > > Key: BEAM-2546 >

[jira] [Created] (BEAM-11016) SqsIO exception when moving to AWS2 SDK

2020-10-05 Thread Alexey Romanenko (Jira)
Alexey Romanenko created BEAM-11016: --- Summary: SqsIO exception when moving to AWS2 SDK Key: BEAM-11016 URL: https://issues.apache.org/jira/browse/BEAM-11016 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-11016) SqsIO exception when moving to AWS2 SDK

2020-10-05 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11016: Description: tclem...@tutanota.com reported in [email thread|https://lists.apache.org/thre

[jira] [Assigned] (BEAM-11016) SqsIO exception when moving to AWS2 SDK

2020-10-06 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-11016: --- Assignee: Alexey Romanenko > SqsIO exception when moving to AWS2 SDK > -

[jira] [Updated] (BEAM-11016) SqsIO exception when moving to AWS2 SDK

2020-10-06 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11016: Status: Open (was: Triage Needed) > SqsIO exception when moving to AWS2 SDK >

[jira] [Commented] (BEAM-11016) SqsIO exception when moving to AWS2 SDK

2020-10-06 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208825#comment-17208825 ] Alexey Romanenko commented on BEAM-11016: - There is an issue with non-serialisabl

[jira] [Updated] (BEAM-10969) Upgrade Spark to version 2.4.7

2020-10-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10969: Fix Version/s: 2.26.0 > Upgrade Spark to version 2.4.7 > -- > >

[jira] [Updated] (BEAM-10969) Upgrade Spark to version 2.4.7

2020-10-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10969: Status: Resolved (was: Open) > Upgrade Spark to version 2.4.7 > --

[jira] [Updated] (BEAM-10628) Beam Dependency Update Request: com.amazonaws:amazon-kinesis-producer

2020-10-14 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10628: Status: Resolved (was: Open) > Beam Dependency Update Request: com.amazonaws:amazon-kinesi

[jira] [Updated] (BEAM-10628) Beam Dependency Update Request: com.amazonaws:amazon-kinesis-producer

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

[jira] [Updated] (BEAM-10628) Beam Dependency Update Request: com.amazonaws:amazon-kinesis-producer

2020-10-14 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10628: Fix Version/s: 2.26.0 > Beam Dependency Update Request: com.amazonaws:amazon-kinesis-produc

[jira] [Assigned] (BEAM-10628) Beam Dependency Update Request: com.amazonaws:amazon-kinesis-producer

2020-10-14 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-10628: --- Assignee: Pawel Pasterz > Beam Dependency Update Request: com.amazonaws:amazon-kines

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

2020-10-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220754#comment-17220754 ] Alexey Romanenko commented on BEAM-9627: Hi [~mwz] , I don't think it's possible t

[jira] [Updated] (BEAM-11058) Run HadoopFormatIOElasticIT in Java PostCommit

2020-10-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11058: Status: Resolved (was: Open) > Run HadoopFormatIOElasticIT in Java PostCommit > --

[jira] [Updated] (BEAM-11058) Run HadoopFormatIOElasticIT in Java PostCommit

2020-10-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11058: Fix Version/s: 2.26.0 > Run HadoopFormatIOElasticIT in Java PostCommit > --

[jira] [Updated] (BEAM-11160) Fix HadoopFormatIOIT

2020-11-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11160: Status: Resolved (was: Open) > Fix HadoopFormatIOIT > > >

[jira] [Updated] (BEAM-11160) Fix HadoopFormatIOIT

2020-11-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11160: Fix Version/s: 2.26.0 > Fix HadoopFormatIOIT > > > Key

[jira] [Updated] (BEAM-11172) Set up Java Kafka performance test with runner v2

2020-11-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11172: Component/s: io-java-kafka > Set up Java Kafka performance test with runner v2 > --

[jira] [Updated] (BEAM-10123) Create CommitOffsetTransform to commit Kafka record offset

2020-11-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10123: Status: Resolved (was: Open) > Create CommitOffsetTransform to commit Kafka record offset

[jira] [Updated] (BEAM-10123) Create CommitOffsetTransform to commit Kafka record offset

2020-11-03 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10123: Fix Version/s: 2.26.0 > Create CommitOffsetTransform to commit Kafka record offset > --

[jira] [Updated] (BEAM-11091) HadoopFormatIO should allow to specify coders

2020-11-04 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11091: Status: Resolved (was: Open) > HadoopFormatIO should allow to specify coders > ---

[jira] [Updated] (BEAM-11091) HadoopFormatIO should allow to specify coders

2020-11-04 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11091: Fix Version/s: 2.26.0 > HadoopFormatIO should allow to specify coders > ---

[jira] [Updated] (BEAM-11172) Set up Java Kafka performance test with Dataflow runner v2

2020-11-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11172: Summary: Set up Java Kafka performance test with Dataflow runner v2 (was: Set up Java Kafk

[jira] [Updated] (BEAM-11172) Set up Java Kafka performance test with Dataflow runner v2

2020-11-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11172: Status: Resolved (was: Open) > Set up Java Kafka performance test with Dataflow runner v2

[jira] [Updated] (BEAM-11172) Set up Java Kafka performance test with Dataflow runner v2

2020-11-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11172: Fix Version/s: 2.27.0 > Set up Java Kafka performance test with Dataflow runner v2 > --

[jira] [Updated] (BEAM-11172) Set up Java Kafka performance test with Dataflow runner v2

2020-11-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-11172: Component/s: runner-dataflow > Set up Java Kafka performance test with Dataflow runner v2 >

[jira] [Assigned] (BEAM-8727) Beam Dependency Update Request: software.amazon.awssdk

2020-07-15 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-8727: -- Assignee: Alexey Romanenko > Beam Dependency Update Request: software.amazon.awssdk > -

[jira] [Commented] (BEAM-8727) Beam Dependency Update Request: software.amazon.awssdk

2020-07-16 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159153#comment-17159153 ] Alexey Romanenko commented on BEAM-8727: Hmm, why you are not sure? Do you have an

[jira] [Comment Edited] (BEAM-8727) Beam Dependency Update Request: software.amazon.awssdk

2020-07-16 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159153#comment-17159153 ] Alexey Romanenko edited comment on BEAM-8727 at 7/16/20, 11:56 AM: -

[jira] [Commented] (BEAM-10481) MetricsAccumulator is not registering when resuming from a checkpoint

2020-07-16 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159354#comment-17159354 ] Alexey Romanenko commented on BEAM-10481: - Thanks for reporting. It's strange sin

[jira] [Comment Edited] (BEAM-10481) MetricsAccumulator is not registering when resuming from a checkpoint

2020-07-16 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159354#comment-17159354 ] Alexey Romanenko edited comment on BEAM-10481 at 7/16/20, 5:02 PM:

[jira] [Commented] (BEAM-10481) MetricsAccumulator is not registering when resuming from a checkpoint

2020-07-16 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159390#comment-17159390 ] Alexey Romanenko commented on BEAM-10481: - I guess this test could be not very co

[jira] [Assigned] (BEAM-6466) KafkaIO doesn't commit offsets while being used as bounded source

2020-07-17 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-6466: -- Assignee: (was: Alexey Romanenko) > KafkaIO doesn't commit offsets while being used

[jira] [Updated] (BEAM-6466) KafkaIO doesn't commit offsets while being used as bounded source

2020-07-17 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-6466: --- Priority: P1 (was: P2) > KafkaIO doesn't commit offsets while being used as bounded source >

[jira] [Commented] (BEAM-10493) Unbounded sources unable to recover from checkpointMark when withMaxReadTime() is used

2020-07-17 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160074#comment-17160074 ] Alexey Romanenko commented on BEAM-10493: - It could be related to BEAM-6466 > Un

[jira] [Assigned] (BEAM-9857) Update Spark runner page to include Docker job server

2020-07-22 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-9857: -- Assignee: Alexey Romanenko > Update Spark runner page to include Docker job server > --

[jira] [Updated] (BEAM-9857) Update Spark runner page to include Docker job server

2020-07-27 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9857: --- Status: Resolved (was: Resolved) > Update Spark runner page to include Docker job server > --

[jira] [Assigned] (BEAM-9702) Update Java KinesisIO to support AWS SDK v2

2020-07-27 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-9702: -- Assignee: Jonothan Farr > Update Java KinesisIO to support AWS SDK v2 > ---

[jira] [Updated] (BEAM-9702) Update Java KinesisIO to support AWS SDK v2

2020-07-27 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9702: --- Fix Version/s: 2.24.0 > Update Java KinesisIO to support AWS SDK v2 >

[jira] [Updated] (BEAM-9702) Update Java KinesisIO to support AWS SDK v2

2020-07-27 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9702: --- Status: Resolved (was: Open) > Update Java KinesisIO to support AWS SDK v2 >

[jira] [Assigned] (BEAM-10532) BigQueryUtils.fromTableSchema breaks when field in TableSchema has a NUMERIC data type

2020-07-27 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-10532: --- Assignee: Matthew Ouyang > BigQueryUtils.fromTableSchema breaks when field in TableS

[jira] [Updated] (BEAM-9702) Update Java KinesisIO.Read to support AWS SDK v2

2020-07-27 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9702: --- Summary: Update Java KinesisIO.Read to support AWS SDK v2 (was: Update Java KinesisIO to supp

[jira] [Updated] (BEAM-10294) Beam metrics are unreadable in Spark history server

2020-07-28 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10294: Fix Version/s: 2.24.0 > Beam metrics are unreadable in Spark history server > -

[jira] [Updated] (BEAM-10294) Beam metrics are unreadable in Spark history server

2020-07-28 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10294: Status: Resolved (was: Open) > Beam metrics are unreadable in Spark history server > -

[jira] [Updated] (BEAM-10332) Fix docstring for TypeDescriptor

2020-06-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10332: Status: Open (was: Triage Needed) > Fix docstring for TypeDescriptor > ---

[jira] [Resolved] (BEAM-10332) Fix docstring for TypeDescriptor

2020-06-26 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-10332. - Fix Version/s: 2.23.0 Assignee: Tobias Kaymak Resolution: Fixed > Fix doc

[jira] [Updated] (BEAM-10335) Add STS Assume role credentials provider to AwsModule

2020-06-30 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10335: Status: Open (was: Triage Needed) > Add STS Assume role credentials provider to AwsModule

[jira] [Updated] (BEAM-10294) Beam metrics are unreadable in Spark history server

2020-07-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10294: Status: Open (was: Triage Needed) > Beam metrics are unreadable in Spark history server >

[jira] [Assigned] (BEAM-10294) Beam metrics are unreadable in Spark history server

2020-07-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-10294: --- Assignee: David Janicek > Beam metrics are unreadable in Spark history server >

[jira] [Updated] (BEAM-10294) Beam metrics are unreadable in Spark history server

2020-07-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10294: Affects Version/s: 2.13.0 > Beam metrics are unreadable in Spark history server > -

[jira] [Resolved] (BEAM-10335) Add STS Assume role credentials provider to AwsModule

2020-07-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-10335. - Fix Version/s: 2.24.0 Resolution: Fixed > Add STS Assume role credentials provider

[jira] [Updated] (BEAM-10335) Add STS Assume role credentials provider to AwsModule

2020-07-02 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10335: Affects Version/s: (was: 2.22.0) > Add STS Assume role credentials provider to AwsModul

[jira] [Updated] (BEAM-10263) release-2.21.0 branch source does not compile

2020-07-06 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10263: Description: On a fresh Beam clone, the 2.21.0 release branch no longer compiles. {code} E

[jira] [Resolved] (BEAM-10431) Change Graphite Metrics sink message format to include missing metric step.

2020-07-10 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-10431. - Fix Version/s: 2.24.0 Resolution: Fixed > Change Graphite Metrics sink message for

[jira] [Updated] (BEAM-7632) Update Python quickstart guide for Flink and Spark

2020-08-04 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-7632: --- Status: Resolved (was: Open) > Update Python quickstart guide for Flink and Spark > -

[jira] [Updated] (BEAM-7632) Update Python quickstart guide for Flink and Spark

2020-08-04 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-7632: --- Status: Resolved (was: Resolved) > Update Python quickstart guide for Flink and Spark > -

[jira] [Updated] (BEAM-7632) Update Python quickstart guide for Flink and Spark

2020-08-04 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-7632: --- Fix Version/s: Not applicable > Update Python quickstart guide for Flink and Spark > -

[jira] [Commented] (BEAM-9700) Support ValueProvider for HCatalogIO

2020-08-04 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170931#comment-17170931 ] Alexey Romanenko commented on BEAM-9700: [~hayashidac] Any updates on this Jira?

[jira] [Updated] (BEAM-10412) Add readAll transform for pubsub

2020-08-04 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10412: Component/s: (was: io-java-aws) > Add readAll transform for pubsub > --

[jira] [Updated] (BEAM-10668) Replace toLowerCase().equals() with equalsIgnoreCase

2020-08-10 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10668: Fix Version/s: 2.25.0 > Replace toLowerCase().equals() with equalsIgnoreCase >

[jira] [Updated] (BEAM-10668) Replace toLowerCase().equals() with equalsIgnoreCase

2020-08-10 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10668: Status: Resolved (was: In Progress) > Replace toLowerCase().equals() with equalsIgnoreCase

[jira] [Updated] (BEAM-10668) Replace toLowerCase().equals() with equalsIgnoreCase

2020-08-10 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10668: Fix Version/s: (was: 2.25.0) 2.24.0 > Replace toLowerCase().equals()

[jira] [Updated] (BEAM-601) Enable Kinesis integration tests

2020-08-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-601: -- Status: Resolved (was: Open) > Enable Kinesis integration tests > --

[jira] [Updated] (BEAM-601) Enable Kinesis integration tests

2020-08-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-601: -- Fix Version/s: 2.24.0 > Enable Kinesis integration tests > > >

[jira] [Commented] (BEAM-4379) Make ParquetIO Read splittable

2020-08-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175638#comment-17175638 ] Alexey Romanenko commented on BEAM-4379: [~danielxjd] Thanks! I see several discus

[jira] [Assigned] (BEAM-4379) Make ParquetIO Read splittable

2020-08-11 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-4379: -- Assignee: Jiadai Xia > Make ParquetIO Read splittable > --

[jira] [Updated] (BEAM-10694) HCatalogIO.Read transform does not survive multiple serialization round trips

2020-08-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10694: Status: Resolved (was: Open) > HCatalogIO.Read transform does not survive multiple seriali

[jira] [Updated] (BEAM-10694) HCatalogIO.Read transform does not survive multiple serialization round trips

2020-08-13 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10694: Fix Version/s: 2.25.0 > HCatalogIO.Read transform does not survive multiple serialization r

[jira] [Assigned] (BEAM-10706) DynamoDBIO fail to write to the same key in short consecution

2020-08-14 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-10706: --- Assignee: Dennis Yung > DynamoDBIO fail to write to the same key in short consecutio

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

2020-06-17 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9742. Fix Version/s: 2.23.0 Resolution: Fixed > Add ability to pass FluentBackoff to JdbcIo

[jira] [Commented] (BEAM-8218) Implement Apache PulsarIO

2020-06-18 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139476#comment-17139476 ] Alexey Romanenko commented on BEAM-8218: Does anyone work on this? Are any updates

[jira] [Updated] (BEAM-9702) Update Java KinesisIO to support AWS SDK v2

2020-06-18 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-9702: --- Parent: BEAM-7555 Issue Type: Sub-task (was: Improvement) > Update Java KinesisIO to

[jira] [Resolved] (BEAM-7638) Migrate KinesisIO to AWS SDK for Java 2

2020-06-18 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-7638. Fix Version/s: Not applicable Resolution: Duplicate Closed at a duplicate of BEAM-970

[jira] [Created] (BEAM-10296) Support Process environment on Mac OS (Java SDK)

2020-06-22 Thread Alexey Romanenko (Jira)
Alexey Romanenko created BEAM-10296: --- Summary: Support Process environment on Mac OS (Java SDK) Key: BEAM-10296 URL: https://issues.apache.org/jira/browse/BEAM-10296 Project: Beam Issue Typ

[jira] [Work started] (BEAM-10296) Support Process environment on Mac OS (Java SDK)

2020-06-22 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-10296 started by Alexey Romanenko. --- > Support Process environment on Mac OS (Java SDK) > -

[jira] [Resolved] (BEAM-9747) Deprecate RedisIO.readAll() and add RedisIO.readKeyPatterns() as a replacement

2020-06-22 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9747. Resolution: Fixed > Deprecate RedisIO.readAll() and add RedisIO.readKeyPatterns() as a repla

[jira] [Comment Edited] (BEAM-6466) KafkaIO doesn't commit offsets while being used as bounded source

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142823#comment-17142823 ] Alexey Romanenko edited comment on BEAM-6466 at 6/23/20, 10:29 AM: -

[jira] [Commented] (BEAM-6466) KafkaIO doesn't commit offsets while being used as bounded source

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142823#comment-17142823 ] Alexey Romanenko commented on BEAM-6466: [~chai.nadig] Could you provide more deta

[jira] [Assigned] (BEAM-6466) KafkaIO doesn't commit offsets while being used as bounded source

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-6466: -- Assignee: Alexey Romanenko > KafkaIO doesn't commit offsets while being used as bounded

[jira] [Updated] (BEAM-6466) KafkaIO doesn't commit offsets while being used as bounded source

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-6466: --- Priority: P2 (was: P3) > KafkaIO doesn't commit offsets while being used as bounded source >

[jira] [Assigned] (BEAM-1974) Metrics documentation

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-1974: -- Assignee: Alexey Romanenko > Metrics documentation > - > >

[jira] [Resolved] (BEAM-1974) Metrics documentation

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

[jira] [Commented] (BEAM-3032) Add RedshiftIO

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-3032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142833#comment-17142833 ] Alexey Romanenko commented on BEAM-3032: Is there any progress on this? > Add Red

[jira] [Commented] (BEAM-4379) Make ParquetIO Read splittable

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142971#comment-17142971 ] Alexey Romanenko commented on BEAM-4379: [~heejong] Do you know if there is any pr

[jira] [Commented] (BEAM-6992) Implement KinesisIO.Write using AWS SDK

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143004#comment-17143004 ] Alexey Romanenko commented on BEAM-6992: Starting from version 0.13.1, Amazon Kine

[jira] [Closed] (BEAM-6992) Implement KinesisIO.Write using AWS SDK

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko closed BEAM-6992. -- Fix Version/s: Not applicable Resolution: Won't Do > Implement KinesisIO.Write using AWS

[jira] [Commented] (BEAM-3549) Move KinesisIO into the amazon-web-services module

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-3549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143008#comment-17143008 ] Alexey Romanenko commented on BEAM-3549: Do we still need to do that? With develop

[jira] [Comment Edited] (BEAM-6992) Implement KinesisIO.Write using AWS SDK

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143004#comment-17143004 ] Alexey Romanenko edited comment on BEAM-6992 at 6/23/20, 4:27 PM: --

[jira] [Commented] (BEAM-10123) Create CommitOffsetTransform to commit Kafka record offset

2020-06-23 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143103#comment-17143103 ] Alexey Romanenko commented on BEAM-10123: - [~boyuanz] Could you elaborate a bit a

[jira] [Created] (BEAM-10325) Create ZeroMqIO

2020-06-25 Thread Alexey Romanenko (Jira)
Alexey Romanenko created BEAM-10325: --- Summary: Create ZeroMqIO Key: BEAM-10325 URL: https://issues.apache.org/jira/browse/BEAM-10325 Project: Beam Issue Type: New Feature Compone

[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&focusedCommentId=17123706#comment-17123706 ] Alexey Romanenko commented on BEAM-9742: UPD: PRs review is in process. > Add ab

[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] [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&focusedCommentId=17123706#comment-17123706 ] Alexey Romanenko edited comment on BEAM-9742 at 6/2/20, 12:22 PM: --

[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 I

[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 Javado

[jira] [Updated] (BEAM-13839) Upgrade zstd-jni to version 1.5.2-1

2022-02-08 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-13839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-13839: Fix Version/s: 2.37.0 Resolution: Fixed Status: Resolved (was: Open) > U

[jira] [Updated] (BEAM-13839) Upgrade zstd-jni to version 1.5.2-1

2022-02-08 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-13839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-13839: Affects Version/s: (was: 2.37.0) > Upgrade zstd-jni to version 1.5.2-1 > --

[jira] [Updated] (BEAM-13246) Add support for S3 Bucket Key at the object level (AWS SDK v2)

2022-02-08 Thread Alexey Romanenko (Jira)
[ https://issues.apache.org/jira/browse/BEAM-13246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-13246: Fix Version/s: 2.37.0 Resolution: Fixed Status: Resolved (was: In Progres

  1   2   3   4   5   6   7   8   9   10   >