[jira] [Closed] (BEAM-6188) Create unbounded synthetic source

[ https://issues.apache.org/jira/browse/BEAM-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gajowy closed BEAM-6188. --- Resolution: Done Fix Version/s: 2.10.0 > Create unbounded synthetic source >

[jira] [Commented] (BEAM-6401) NullPointerException and regression in BeamCalcRel

[ https://issues.apache.org/jira/browse/BEAM-6401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739472#comment-16739472 ] Gleb Kanterov commented on BEAM-6401: - Thanks for looking into this. I found a way workaround this

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

[ https://issues.apache.org/jira/browse/BEAM-6326?focusedWorklogId=183726=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183726 ] ASF GitHub Bot logged work on BEAM-6326: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6405) Improve PortableValidatesRunner test reliability on Jenkins

Maximilian Michels created BEAM-6405: Summary: Improve PortableValidatesRunner test reliability on Jenkins Key: BEAM-6405 URL: https://issues.apache.org/jira/browse/BEAM-6405 Project: Beam

[jira] [Commented] (BEAM-6405) Improve PortableValidatesRunner test reliability on Jenkins

[ https://issues.apache.org/jira/browse/BEAM-6405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739478#comment-16739478 ] Maximilian Michels commented on BEAM-6405: -- CC [~thw] > Improve PortableValidatesRunner test

[jira] [Commented] (BEAM-68) Support for limiting parallelism of a step

[ https://issues.apache.org/jira/browse/BEAM-68?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739492#comment-16739492 ] Fabiano Francesconi commented on BEAM-68: - I found this ticket after looking to do the same.

[jira] [Resolved] (BEAM-6276) Performance regression caused by extra calls to TypeDescriptor.getRawType

[ https://issues.apache.org/jira/browse/BEAM-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-6276. Resolution: Fixed Fix Version/s: 2.10.0 > Performance regression caused by extra calls to

[jira] [Work logged] (BEAM-6294) Use Flink's redistribute for reshuffle.

[ https://issues.apache.org/jira/browse/BEAM-6294?focusedWorklogId=183725=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183725 ] ASF GitHub Bot logged work on BEAM-6294: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-5927) FnApiRunner KeyError

[ https://issues.apache.org/jira/browse/BEAM-5927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Bradshaw resolved BEAM-5927. --- Resolution: Duplicate Fix Version/s: Not applicable > FnApiRunner KeyError >

[jira] [Work logged] (BEAM-6294) Use Flink's redistribute for reshuffle.

[ https://issues.apache.org/jira/browse/BEAM-6294?focusedWorklogId=183699=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183699 ] ASF GitHub Bot logged work on BEAM-6294: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6294) Use Flink's redistribute for reshuffle.

[ https://issues.apache.org/jira/browse/BEAM-6294?focusedWorklogId=183698=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183698 ] ASF GitHub Bot logged work on BEAM-6294: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6334) Change status of LoadTests after failure on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-6334?focusedWorklogId=183704=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183704 ] ASF GitHub Bot logged work on BEAM-6334: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-3323) Create a generator of finite-but-unbounded PCollection's for integration testing

[ https://issues.apache.org/jira/browse/BEAM-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739453#comment-16739453 ] Lukasz Gajowy commented on BEAM-3323: - Currently, we have both UnboundedSyntheticSource that generates

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

[ https://issues.apache.org/jira/browse/BEAM-6164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739480#comment-16739480 ] Ismaël Mejía commented on BEAM-6164: Is this going to be backported somehow for 2.9.1 otherwise fix

[jira] [Commented] (BEAM-6294) Use Flink's redistribute for reshuffle.

[ https://issues.apache.org/jira/browse/BEAM-6294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739383#comment-16739383 ] Robert Bradshaw commented on BEAM-6294: --- I figured out what the issue was:

[jira] [Comment Edited] (BEAM-3323) Create a generator of finite-but-unbounded PCollection's for integration testing

[ https://issues.apache.org/jira/browse/BEAM-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739453#comment-16739453 ] Lukasz Gajowy edited comment on BEAM-3323 at 1/10/19 2:36 PM: -- Currently, we

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

[ https://issues.apache.org/jira/browse/BEAM-6326?focusedWorklogId=183727=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183727 ] ASF GitHub Bot logged work on BEAM-6326: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6404) FnAPI translation error

[ https://issues.apache.org/jira/browse/BEAM-6404?focusedWorklogId=183652=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183652 ] ASF GitHub Bot logged work on BEAM-6404: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-6368) NoSuchMethodError in streaming load tests

[ https://issues.apache.org/jira/browse/BEAM-6368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-6368. Resolution: Invalid Fix Version/s: Not applicable Resolving because it is the case, this

[jira] [Resolved] (BEAM-3508) Beam does not compile with Eclipse

[ https://issues.apache.org/jira/browse/BEAM-3508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-3508. Resolution: Fixed Fix Version/s: 2.2.0 > Beam does not compile with Eclipse >

[jira] [Updated] (BEAM-3925) Support ValueProviders in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-3925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-3925: --- Summary: Support ValueProviders in KafkaIO (was: Allow ValueProvider for KafkaIO) > Support

[jira] [Resolved] (BEAM-1664) Support Kafka0.8.x client in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-1664. Resolution: Won't Fix Fix Version/s: Not applicable KafkaIO supports only versions > 0.9.x.

[jira] [Commented] (BEAM-3772) BigQueryIO - Can't use DynamicDestination with CREATE_IF_NEEDED for unbounded PCollection and FILE_LOADS

[ https://issues.apache.org/jira/browse/BEAM-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739264#comment-16739264 ] Marco Veluscek commented on BEAM-3772: -- I am experiencing the same issue with Beam 2.6.0 and 2.9.0.

[jira] [Work logged] (BEAM-6397) Add KeyValue attribute to SyntheticDataPubSubPublisher

[ https://issues.apache.org/jira/browse/BEAM-6397?focusedWorklogId=183640=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183640 ] ASF GitHub Bot logged work on BEAM-6397: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6397) Add KeyValue attribute to SyntheticDataPubSubPublisher

[ https://issues.apache.org/jira/browse/BEAM-6397?focusedWorklogId=183645=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183645 ] ASF GitHub Bot logged work on BEAM-6397: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-3259) KafkaIO.read fails job upon broker death

[ https://issues.apache.org/jira/browse/BEAM-3259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-3259: -- Assignee: (was: Reuven Lax) > KafkaIO.read fails job upon broker death >

[jira] [Updated] (BEAM-3925) Allow ValueProvider for KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-3925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-3925: --- Component/s: (was: sdk-java-core) io-java-kafka > Allow ValueProvider

[jira] [Updated] (BEAM-3925) Allow ValueProvider for KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-3925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-3925: --- Component/s: (was: io-java-kafka) > Allow ValueProvider for KafkaIO >

[jira] [Resolved] (BEAM-3936) Python direct runner breaks with cython 0.28.1

[ https://issues.apache.org/jira/browse/BEAM-3936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-3936. Resolution: Invalid Fix Version/s: Not applicable > Python direct runner breaks with cython

[jira] [Resolved] (BEAM-2449) Support ValueProviders in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-2449. Resolution: Duplicate Fix Version/s: Not applicable > Support ValueProviders in KafkaIO >

[jira] [Commented] (BEAM-4608) Improve / Fix documentation examples for Beam 2.4.0 for TextIO and BigQueryIO

[ https://issues.apache.org/jira/browse/BEAM-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739257#comment-16739257 ] Tobias Kaymak commented on BEAM-4608: - [~iemejia] I checked the code just know and there has been no

[jira] [Created] (BEAM-6404) FnAPI translation error

Robert Bradshaw created BEAM-6404: - Summary: FnAPI translation error Key: BEAM-6404 URL: https://issues.apache.org/jira/browse/BEAM-6404 Project: Beam Issue Type: New Feature

[jira] [Work logged] (BEAM-6404) FnAPI translation error

[ https://issues.apache.org/jira/browse/BEAM-6404?focusedWorklogId=183651=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183651 ] ASF GitHub Bot logged work on BEAM-6404: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-6207) extend "Data insertion Pipeline" with Kafka IO

[ https://issues.apache.org/jira/browse/BEAM-6207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-6207: --- Component/s: io-java-kafka > extend "Data insertion Pipeline" with Kafka IO >

[jira] [Assigned] (BEAM-1664) Support Kafka0.8.x client in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1664: -- Assignee: (was: Reuven Lax) > Support Kafka0.8.x client in KafkaIO >

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

[ https://issues.apache.org/jira/browse/BEAM-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-4420: --- Summary: Add KafkaIO Integration Tests (was: Add KafkaIOIT) > Add KafkaIO Integration Tests >

[jira] [Commented] (BEAM-4608) Improve / Fix documentation examples for Beam 2.4.0 for TextIO and BigQueryIO

[ https://issues.apache.org/jira/browse/BEAM-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739266#comment-16739266 ] Ismaël Mejía commented on BEAM-4608: Thanks for answering [~james-woods], just wanted to confirm.

[jira] [Work logged] (BEAM-6397) Add KeyValue attribute to SyntheticDataPubSubPublisher

[ https://issues.apache.org/jira/browse/BEAM-6397?focusedWorklogId=183646=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183646 ] ASF GitHub Bot logged work on BEAM-6397: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-2855) Implement a python version of the nexmark queries

[ https://issues.apache.org/jira/browse/BEAM-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-2855: -- Assignee: (was: María GH) > Implement a python version of the nexmark queries >

[jira] [Resolved] (BEAM-1840) shaded classes are not getting into the proper package

[ https://issues.apache.org/jira/browse/BEAM-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-1840. Resolution: Invalid Fix Version/s: Not applicable This does not apply now after the move to

[jira] [Commented] (BEAM-3494) Snapshot state of aggregated data of apache beam project is not maintained in flink's checkpointing

[ https://issues.apache.org/jira/browse/BEAM-3494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739362#comment-16739362 ] Ismaël Mejía commented on BEAM-3494: [~mxm] do you know if this is still an issue? > Snapshot state

[jira] [Resolved] (BEAM-4086) KafkaIOTest is flaky

[ https://issues.apache.org/jira/browse/BEAM-4086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-4086. Resolution: Fixed Fix Version/s: 2.6.0 Not applicable > KafkaIOTest is

[jira] [Assigned] (BEAM-3398) KafkaRecordCoder.encode throws NullPointerException

[ https://issues.apache.org/jira/browse/BEAM-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-3398: -- Assignee: (was: Reuven Lax) > KafkaRecordCoder.encode throws NullPointerException >

[jira] [Commented] (BEAM-4250) Add Go SDK support for native Kafka IO on Flink

[ https://issues.apache.org/jira/browse/BEAM-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739306#comment-16739306 ] Ismaël Mejía commented on BEAM-4250: This looks like a duplicate of BEAM-6260 or does this refer to

[jira] [Commented] (BEAM-6206) Dataflow template which reads from BigQuery fails if used more than once

[ https://issues.apache.org/jira/browse/BEAM-6206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739568#comment-16739568 ] Chamikara Jayalath commented on BEAM-6206: -- You have to use withTemplateCompatibility() for

[jira] [Assigned] (BEAM-4520) No messages delivered after a while with PubsubIO

[ https://issues.apache.org/jira/browse/BEAM-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-4520: Assignee: (was: Chamikara Jayalath) > No messages delivered after a while with

[jira] [Updated] (BEAM-6206) Dataflow template which reads from BigQuery fails if used more than once

[ https://issues.apache.org/jira/browse/BEAM-6206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath updated BEAM-6206: - Priority: Major (was: Blocker) > Dataflow template which reads from BigQuery fails if

[jira] [Resolved] (BEAM-6206) Dataflow template which reads from BigQuery fails if used more than once

[ https://issues.apache.org/jira/browse/BEAM-6206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath resolved BEAM-6206. -- Resolution: Fixed Fix Version/s: Not applicable > Dataflow template which reads

[jira] [Commented] (BEAM-4520) No messages delivered after a while with PubsubIO

[ https://issues.apache.org/jira/browse/BEAM-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739581#comment-16739581 ] Maximilian Michels commented on BEAM-4520: -- I suppose this is more of a Runner problem. We could

[jira] [Assigned] (BEAM-5635) FR: Enable Transactional writes with DatastoreIO

[ https://issues.apache.org/jira/browse/BEAM-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-5635: Assignee: (was: Chamikara Jayalath) > FR: Enable Transactional writes with

[jira] [Assigned] (BEAM-5934) FileSink affected by S3 eventual consistency

[ https://issues.apache.org/jira/browse/BEAM-5934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-5934: Assignee: (was: Chamikara Jayalath) > FileSink affected by S3 eventual

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183786=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183786 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-5417) FileSystems.match behaviour diff between GCS and local file system

[ https://issues.apache.org/jira/browse/BEAM-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739591#comment-16739591 ] Chamikara Jayalath commented on BEAM-5417: -- Joar, did you try with the latest version of Beam ?

[jira] [Assigned] (BEAM-4904) Beam Dependency Update Request: de.flapdoodle.embed:de.flapdoodle.embed.mongo 2.1.1

[ https://issues.apache.org/jira/browse/BEAM-4904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-4904: Assignee: (was: Chamikara Jayalath) > Beam Dependency Update Request:

[jira] [Assigned] (BEAM-5676) Allow to change the PubsubClientFactory when using PubsubIO

[ https://issues.apache.org/jira/browse/BEAM-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-5676: Assignee: (was: Chamikara Jayalath) > Allow to change the PubsubClientFactory

[jira] [Commented] (BEAM-5676) Allow to change the PubsubClientFactory when using PubsubIO

[ https://issues.apache.org/jira/browse/BEAM-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739597#comment-16739597 ] Logan HAUSPIE commented on BEAM-5676: - I will do it next month if no one else has done it before me >

[jira] [Updated] (BEAM-6393) Rohit travels & tours

[ https://issues.apache.org/jira/browse/BEAM-6393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6393: --- Fix Version/s: (was: 3.0.0) > Rohit travels & tours > - > >

[jira] [Work started] (BEAM-6290) Make the schema for BQ tables storing metric results more generic (JAVA)

[ https://issues.apache.org/jira/browse/BEAM-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-6290 started by Lukasz Gajowy. --- > Make the schema for BQ tables storing metric results more generic (JAVA) >

[jira] [Work logged] (BEAM-6405) Improve PortableValidatesRunner test reliability on Jenkins

[ https://issues.apache.org/jira/browse/BEAM-6405?focusedWorklogId=183767=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183767 ] ASF GitHub Bot logged work on BEAM-6405: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6405) Improve PortableValidatesRunner test reliability on Jenkins

[ https://issues.apache.org/jira/browse/BEAM-6405?focusedWorklogId=183772=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183772 ] ASF GitHub Bot logged work on BEAM-6405: Author: ASF GitHub Bot

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

[ https://issues.apache.org/jira/browse/BEAM-6164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739553#comment-16739553 ] Andrew Brampton commented on BEAM-6164: --- My bad, I changed the fix version to 2.11.0. > GCS

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

[ https://issues.apache.org/jira/browse/BEAM-6164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Brampton updated BEAM-6164: -- Fix Version/s: (was: 2.9.1) 2.11.0 > GCS OpenRead and OpenWrite do not

[jira] [Assigned] (BEAM-6337) testE2EV1ReadWithGQLQueryWithNoLimit failed owing to assertion error

[ https://issues.apache.org/jira/browse/BEAM-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-6337: Assignee: (was: Chamikara Jayalath) > testE2EV1ReadWithGQLQueryWithNoLimit

[jira] [Commented] (BEAM-6344) :beam-sdks-java-io-elasticsearch-tests-2:test failed owing to get 503 from ES

[ https://issues.apache.org/jira/browse/BEAM-6344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739560#comment-16739560 ] Chamikara Jayalath commented on BEAM-6344: -- cc: [~echauchot] [~ŁukaszG] >

[jira] [Commented] (BEAM-5434) Issue with BigQueryIO in Template

[ https://issues.apache.org/jira/browse/BEAM-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739564#comment-16739564 ] Chamikara Jayalath commented on BEAM-5434: -- You have to use withTemplateCompatiblity() for

[jira] [Updated] (BEAM-5434) Issue with BigQueryIO in Template

[ https://issues.apache.org/jira/browse/BEAM-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath updated BEAM-5434: - Priority: Major (was: Blocker) > Issue with BigQueryIO in Template >

[jira] [Resolved] (BEAM-5434) Issue with BigQueryIO in Template

[ https://issues.apache.org/jira/browse/BEAM-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath resolved BEAM-5434. -- Resolution: Fixed Fix Version/s: Not applicable > Issue with BigQueryIO in

[jira] [Comment Edited] (BEAM-5434) Issue with BigQueryIO in Template

[ https://issues.apache.org/jira/browse/BEAM-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739564#comment-16739564 ] Chamikara Jayalath edited comment on BEAM-5434 at 1/10/19 4:14 PM: --- You

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183782=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183782 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183787=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183787 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183785=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183785 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183789=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183789 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183792=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183792 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183784=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183784 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183788=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183788 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183793=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183793 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183790=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183790 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183791=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183791 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-5966) When working "LiteralGqlQuery", Error: Query cannot have any sort orders.

[ https://issues.apache.org/jira/browse/BEAM-5966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739585#comment-16739585 ] Chamikara Jayalath commented on BEAM-5966: -- Was your question resolved or is there something more

[jira] [Assigned] (BEAM-5614) Using gs:// paths without first doing a "gcloud auth" gives an unhelpful error message

[ https://issues.apache.org/jira/browse/BEAM-5614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-5614: Assignee: (was: Chamikara Jayalath) > Using gs:// paths without first doing a

[jira] [Assigned] (BEAM-5420) BigtableIO tries to get runtime parameters when collecting display data at pipeline construction time

[ https://issues.apache.org/jira/browse/BEAM-5420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-5420: Assignee: Pablo Estrada (was: Chamikara Jayalath) > BigtableIO tries to get

[jira] [Updated] (BEAM-6393) Rohit travels & tours

[ https://issues.apache.org/jira/browse/BEAM-6393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6393: --- Labels: (was: PAK) > Rohit travels & tours > - > > Key:

[jira] [Updated] (BEAM-6393) Rohit travels & tours

[ https://issues.apache.org/jira/browse/BEAM-6393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6393: --- Affects Version/s: (was: 2.9.0) > Rohit travels & tours > - > >

[jira] [Work logged] (BEAM-6290) Make the schema for BQ tables storing metric results more generic (JAVA)

[ https://issues.apache.org/jira/browse/BEAM-6290?focusedWorklogId=183744=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183744 ] ASF GitHub Bot logged work on BEAM-6290: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6405) Improve PortableValidatesRunner test reliability on Jenkins

[ https://issues.apache.org/jira/browse/BEAM-6405?focusedWorklogId=183774=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183774 ] ASF GitHub Bot logged work on BEAM-6405: Author: ASF GitHub Bot

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

[ https://issues.apache.org/jira/browse/BEAM-6155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Brampton updated BEAM-6155: -- Fix Version/s: (was: 2.9.1) 2.11.0 > Migrate the Go SDK to the modern

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183776=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183776 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-5806) Allow to change the PubsubClientFactory when using PubsubIO

[ https://issues.apache.org/jira/browse/BEAM-5806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739571#comment-16739571 ] Chamikara Jayalath commented on BEAM-5806: -- cc: [~reuvenlax] [~mil...@google.com] > Allow to

[jira] [Assigned] (BEAM-5806) Allow to change the PubsubClientFactory when using PubsubIO

[ https://issues.apache.org/jira/browse/BEAM-5806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-5806: Assignee: (was: Chamikara Jayalath) > Allow to change the PubsubClientFactory

[jira] [Commented] (BEAM-4520) No messages delivered after a while with PubsubIO

[ https://issues.apache.org/jira/browse/BEAM-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739570#comment-16739570 ] Chamikara Jayalath commented on BEAM-4520: -- cc: [~reuvenlax] [~mil...@google.com] > No messages

[jira] [Resolved] (BEAM-6064) Python BigQuery performance much worse than Java

[ https://issues.apache.org/jira/browse/BEAM-6064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath resolved BEAM-6064. -- Resolution: Fixed Fix Version/s: 2.9.0 > Python BigQuery performance much worse

[jira] [Commented] (BEAM-6064) Python BigQuery performance much worse than Java

[ https://issues.apache.org/jira/browse/BEAM-6064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739582#comment-16739582 ] Chamikara Jayalath commented on BEAM-6064: -- Fastavro support for BigQuery for DataflowRunner is

[jira] [Assigned] (BEAM-5929) BigQueryIO DynamicDestination should support JSONSchema

[ https://issues.apache.org/jira/browse/BEAM-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-5929: Assignee: (was: Chamikara Jayalath) > BigQueryIO DynamicDestination should

[jira] [Commented] (BEAM-5694) OOMs on Pub/Sub to BigQuery via FILE_LOADS

[ https://issues.apache.org/jira/browse/BEAM-5694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739588#comment-16739588 ] Chamikara Jayalath commented on BEAM-5694: -- R: [~reuvenlax] > OOMs on Pub/Sub to BigQuery via

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=183800=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183800 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6405) Improve PortableValidatesRunner test reliability on Jenkins

[ https://issues.apache.org/jira/browse/BEAM-6405?focusedWorklogId=183804=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183804 ] ASF GitHub Bot logged work on BEAM-6405: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6365) Add ZStandard compression support for Java SDK

[ https://issues.apache.org/jira/browse/BEAM-6365?focusedWorklogId=183737=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183737 ] ASF GitHub Bot logged work on BEAM-6365: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-6393) Rohit travels & tours

[ https://issues.apache.org/jira/browse/BEAM-6393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-6393. Resolution: Invalid Assignee: (was: Kenneth Knowles) Fix Version/s: Not

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

[ https://issues.apache.org/jira/browse/BEAM-6326?focusedWorklogId=183761=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183761 ] ASF GitHub Bot logged work on BEAM-6326: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6241) MongoDbIO - Add Limit and Aggregates Support

[ https://issues.apache.org/jira/browse/BEAM-6241?focusedWorklogId=183760=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-183760 ] ASF GitHub Bot logged work on BEAM-6241: Author: ASF GitHub Bot

  1   2   >