[jira] [Assigned] (BEAM-9917) BigQueryBatchFileLoads dynamic destination

[ https://issues.apache.org/jira/browse/BEAM-9917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli reassigned BEAM-9917: Assignee: Tanay Tummalapalli > BigQueryBatchFileLoads dynamic destination >

[jira] [Assigned] (BEAM-8485) Python Beam job is successful regardless of the result of the BigQuery load job (for the BigQuery File Loads)

[ https://issues.apache.org/jira/browse/BEAM-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli reassigned BEAM-8485: Assignee: (was: Tanay Tummalapalli) Unassigning. Don't have the bandwidth

[jira] [Updated] (BEAM-8578) PubSubBigQueryIT.test_file_loads fails on Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-8578: - Status: Open (was: Triage Needed) > PubSubBigQueryIT.test_file_loads fails on Dataflow

[jira] [Created] (BEAM-8578) PubSubBigQueryIT.test_file_loads fails on Dataflow Runner

Tanay Tummalapalli created BEAM-8578: Summary: PubSubBigQueryIT.test_file_loads fails on Dataflow Runner Key: BEAM-8578 URL: https://issues.apache.org/jira/browse/BEAM-8578 Project: Beam

[jira] [Commented] (BEAM-8485) Python Beam job is successful regardless of the result of the BigQuery load job (for the BigQuery File Loads)

[ https://issues.apache.org/jira/browse/BEAM-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962959#comment-16962959 ] Tanay Tummalapalli commented on BEAM-8485: -- Hi [~rgruener] Are you using Dynamic Destinations? Or

[jira] [Assigned] (BEAM-8485) Python Beam job is successful regardless of the result of the BigQuery load job (for the BigQuery File Loads)

[ https://issues.apache.org/jira/browse/BEAM-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli reassigned BEAM-8485: Assignee: Tanay Tummalapalli > Python Beam job is successful regardless of the

[jira] [Updated] (BEAM-6611) A Python Sink for BigQuery with File Loads in Streaming

[ https://issues.apache.org/jira/browse/BEAM-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-6611: - Fix Version/s: 2.16.0 > A Python Sink for BigQuery with File Loads in Streaming >

[jira] [Comment Edited] (BEAM-6928) Make Python SDK custom Sink the default Sink for BigQuery

[ https://issues.apache.org/jira/browse/BEAM-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896337#comment-16896337 ] Tanay Tummalapalli edited comment on BEAM-6928 at 7/30/19 5:17 PM: ---

[jira] [Updated] (BEAM-7822) TriggerCopyJobs in BQ file loads is not atmomic in case of failure

[ https://issues.apache.org/jira/browse/BEAM-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7822: - Priority: Minor (was: Critical) > TriggerCopyJobs in BQ file loads is not atmomic in

[jira] [Comment Edited] (BEAM-6928) Make Python SDK custom Sink the default Sink for BigQuery

[ https://issues.apache.org/jira/browse/BEAM-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896337#comment-16896337 ] Tanay Tummalapalli edited comment on BEAM-6928 at 7/30/19 5:16 PM: ---

[jira] [Comment Edited] (BEAM-6928) Make Python SDK custom Sink the default Sink for BigQuery

[ https://issues.apache.org/jira/browse/BEAM-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896337#comment-16896337 ] Tanay Tummalapalli edited comment on BEAM-6928 at 7/30/19 5:16 PM: ---

[jira] [Commented] (BEAM-6928) Make Python SDK custom Sink the default Sink for BigQuery

[ https://issues.apache.org/jira/browse/BEAM-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896337#comment-16896337 ] Tanay Tummalapalli commented on BEAM-6928: -- Changes related to improving how quota limits are

[jira] [Updated] (BEAM-6928) Make Python SDK custom Sink the default Sink for BigQuery

[ https://issues.apache.org/jira/browse/BEAM-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-6928: - Fix Version/s: (was: 2.15.0) 2.16.0 > Make Python SDK custom Sink

[jira] [Resolved] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli resolved BEAM-7437. -- Resolution: Fixed Fix Version/s: Not applicable > Integration Test for BQ

[jira] [Created] (BEAM-7822) TriggerCopyJobs in BQ file loads is not atmomic in case of failure

Tanay Tummalapalli created BEAM-7822: Summary: TriggerCopyJobs in BQ file loads is not atmomic in case of failure Key: BEAM-7822 URL: https://issues.apache.org/jira/browse/BEAM-7822 Project: Beam

[jira] [Closed] (BEAM-7795) test_bigquery_read_1M_python failing in Python PostCommit

[ https://issues.apache.org/jira/browse/BEAM-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli closed BEAM-7795. Resolution: Fixed Fix Version/s: Not applicable Duplicate of

[jira] [Updated] (BEAM-7795) test_bigquery_read_1M_python failing in Python PostCommit

[ https://issues.apache.org/jira/browse/BEAM-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7795: - Description: The test test_bigquery_read_1M_python from

[jira] [Updated] (BEAM-7795) test_bigquery_read_1M_python failing in Python PostCommit

[ https://issues.apache.org/jira/browse/BEAM-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7795: - Summary: test_bigquery_read_1M_python failing in Python PostCommit (was:

[jira] [Updated] (BEAM-7795) test_bigquery_read_1M_python failing in Python 2 PostCommit

[ https://issues.apache.org/jira/browse/BEAM-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7795: - Summary: test_bigquery_read_1M_python failing in Python 2 PostCommit (was:

[jira] [Updated] (BEAM-7795) test_bigquery_read_1M_python failing in Python PostCommit

[ https://issues.apache.org/jira/browse/BEAM-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7795: - Labels: test (was: ) > test_bigquery_read_1M_python failing in Python PostCommit >

[jira] [Created] (BEAM-7795) test_bigquery_read_1M_python failing in Python PostCommit

Tanay Tummalapalli created BEAM-7795: Summary: test_bigquery_read_1M_python failing in Python PostCommit Key: BEAM-7795 URL: https://issues.apache.org/jira/browse/BEAM-7795 Project: Beam

[jira] [Updated] (BEAM-7795) test_bigquery_read_1M_python failing in Python PostCommit

[ https://issues.apache.org/jira/browse/BEAM-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7795: - Status: Open (was: Triage Needed) > test_bigquery_read_1M_python failing in Python

[jira] [Commented] (BEAM-7742) BigQuery File Loads to work well with load job size limits

[ https://issues.apache.org/jira/browse/BEAM-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889583#comment-16889583 ] Tanay Tummalapalli commented on BEAM-7742: -- Yes, I'll work on this. I'm a bit late on the design

[jira] [Commented] (BEAM-7674) Define streaming ITs tests for direct runner in consistent way in Python 2 and Python 3 suites.

[ https://issues.apache.org/jira/browse/BEAM-7674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886204#comment-16886204 ] Tanay Tummalapalli commented on BEAM-7674: -- I've combined the test -

[jira] [Closed] (BEAM-7494) Add Integration tests using streaming pipelines to Python 3 test suite

[ https://issues.apache.org/jira/browse/BEAM-7494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli closed BEAM-7494. Resolution: Duplicate Fix Version/s: Not applicable Closed in favour of

[jira] [Updated] (BEAM-7494) Add Integration tests using streaming pipelines to Python 3 test suite

[ https://issues.apache.org/jira/browse/BEAM-7494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7494: - Labels: duplicate newbie test (was: newbie test) > Add Integration tests using streaming

[jira] [Assigned] (BEAM-3759) Add support for PaneInfo descriptor in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli reassigned BEAM-3759: Assignee: Tanay Tummalapalli > Add support for PaneInfo descriptor in Python SDK >

[jira] [Updated] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7437: - Status: Open (was: Triage Needed) > Integration Test for BQ streaming inserts for

[jira] [Reopened] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli reopened BEAM-7437: -- Missed adding streaming=True to PipelineOptions > Integration Test for BQ streaming

[jira] [Closed] (BEAM-7625) Add Streaming version of BigqueryFullResultMatcher

[ https://issues.apache.org/jira/browse/BEAM-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli closed BEAM-7625. Resolution: Duplicate Fix Version/s: Not applicable > Add Streaming version of

[jira] [Created] (BEAM-7625) Add Streaming version of BigqueryFullResultMatcher

Tanay Tummalapalli created BEAM-7625: Summary: Add Streaming version of BigqueryFullResultMatcher Key: BEAM-7625 URL: https://issues.apache.org/jira/browse/BEAM-7625 Project: Beam Issue

[jira] [Resolved] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli resolved BEAM-7437. -- Resolution: Fixed Thank You [~kedin] Yes, the PR merged resolved this. > Integration

[jira] [Updated] (BEAM-7499) ReifyTest.test_window fails in DirectRunner due to 'assign_context.window should not be None.'

[ https://issues.apache.org/jira/browse/BEAM-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7499: - Component/s: test-failures > ReifyTest.test_window fails in DirectRunner due to

[jira] [Comment Edited] (BEAM-7499) ReifyTest.test_window fails in DirectRunner due to 'assign_context.window should not be None.'

[ https://issues.apache.org/jira/browse/BEAM-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858916#comment-16858916 ] Tanay Tummalapalli edited comment on BEAM-7499 at 6/7/19 7:06 PM: -- Hi

[jira] [Commented] (BEAM-7499) ReifyTest.test_window fails in DirectRunner due to 'assign_context.window should not be None.'

[ https://issues.apache.org/jira/browse/BEAM-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858916#comment-16858916 ] Tanay Tummalapalli commented on BEAM-7499: -- Hi [~lcwik], Thanks for fixing the test failure. I

[jira] [Commented] (BEAM-7499) ReifyTest.test_window fails in DirectRunner due to 'assign_context.window should not be None.'

[ https://issues.apache.org/jira/browse/BEAM-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858255#comment-16858255 ] Tanay Tummalapalli commented on BEAM-7499: -- I'll look into this. > ReifyTest.test_window fails

[jira] [Assigned] (BEAM-7494) Add Integration tests using streaming pipelines to Python 3 test suite

[ https://issues.apache.org/jira/browse/BEAM-7494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli reassigned BEAM-7494: Assignee: Tanay Tummalapalli > Add Integration tests using streaming pipelines to

[jira] [Updated] (BEAM-7494) Add Integration tests using streaming pipelines to Python 3 test suite

[ https://issues.apache.org/jira/browse/BEAM-7494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7494: - Status: Open (was: Triage Needed) > Add Integration tests using streaming pipelines to

[jira] [Commented] (BEAM-7408) Beam Programming Guide inconsistencies

[ https://issues.apache.org/jira/browse/BEAM-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856941#comment-16856941 ] Tanay Tummalapalli commented on BEAM-7408: -- Hi [~davidyan] Can this be closed? > Beam

[jira] [Updated] (BEAM-7408) Beam Programming Guide inconsistencies

[ https://issues.apache.org/jira/browse/BEAM-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7408: - Status: Open (was: Triage Needed) > Beam Programming Guide inconsistencies >

[jira] [Updated] (BEAM-7408) Beam Programming Guide inconsistencies

[ https://issues.apache.org/jira/browse/BEAM-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7408: - Labels: documentation newbie (was: ) > Beam Programming Guide inconsistencies >

[jira] [Updated] (BEAM-7408) Beam Programming Guide inconsistencies

[ https://issues.apache.org/jira/browse/BEAM-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7408: - Fix Version/s: Not applicable > Beam Programming Guide inconsistencies >

[jira] [Updated] (BEAM-7408) Beam Programming Guide inconsistencies

[ https://issues.apache.org/jira/browse/BEAM-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7408: - Affects Version/s: Not applicable > Beam Programming Guide inconsistencies >

[jira] [Updated] (BEAM-7445) Add search field to Beam website

[ https://issues.apache.org/jira/browse/BEAM-7445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7445: - Labels: documentation usability (was: ) > Add search field to Beam website >

[jira] [Updated] (BEAM-7445) Add search field to Beam website

[ https://issues.apache.org/jira/browse/BEAM-7445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7445: - Affects Version/s: Not applicable > Add search field to Beam website >

[jira] [Updated] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7437: - Status: Open (was: Triage Needed) > Integration Test for BQ streaming inserts for

[jira] [Updated] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7437: - Labels: test (was: ) > Integration Test for BQ streaming inserts for streaming pipelines

[jira] [Updated] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7437: - Fix Version/s: 2.14.0 > Integration Test for BQ streaming inserts for streaming pipelines

[jira] [Issue Comment Deleted] (BEAM-7388) Reify PTransform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7388: - Comment: was deleted (was: PR merged.) > Reify PTransform for Python SDK >

[jira] [Updated] (BEAM-7388) Reify PTransform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7388: - Status: Open (was: Triage Needed) > Reify PTransform for Python SDK >

[jira] [Updated] (BEAM-7388) Reify PTransform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7388: - Fix Version/s: 2.14.0 > Reify PTransform for Python SDK > ---

[jira] [Updated] (BEAM-7494) Add Integration tests using streaming pipelines to Python 3 test suite

[ https://issues.apache.org/jira/browse/BEAM-7494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7494: - Labels: newbie test (was: ) > Add Integration tests using streaming pipelines to Python

[jira] [Created] (BEAM-7494) Add Integration tests using streaming pipelines to Python 3 test suite

Tanay Tummalapalli created BEAM-7494: Summary: Add Integration tests using streaming pipelines to Python 3 test suite Key: BEAM-7494 URL: https://issues.apache.org/jira/browse/BEAM-7494 Project:

[jira] [Resolved] (BEAM-6695) Latest transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli resolved BEAM-6695. -- Resolution: Fixed PR merged. > Latest transform for Python SDK >

[jira] [Updated] (BEAM-6695) Latest transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-6695: - Fix Version/s: 2.14.0 > Latest transform for Python SDK > ---

[jira] [Comment Edited] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16853808#comment-16853808 ] Tanay Tummalapalli edited comment on BEAM-7437 at 6/1/19 8:08 PM: -- I am

[jira] [Commented] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16853808#comment-16853808 ] Tanay Tummalapalli commented on BEAM-7437: -- I am getting consistent failures on the Integration

[jira] [Commented] (BEAM-3759) Add support for PaneInfo descriptor in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16853152#comment-16853152 ] Tanay Tummalapalli commented on BEAM-3759: -- Thanks [~ccy]! I'd love to work on adding full

[jira] [Updated] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7437: - Description: Integration Test for BigQuery Sink using Streaming Inserts for streaming

[jira] [Created] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

Tanay Tummalapalli created BEAM-7437: Summary: Integration Test for BQ streaming inserts for streaming pipelines Key: BEAM-7437 URL: https://issues.apache.org/jira/browse/BEAM-7437 Project: Beam

[jira] [Updated] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7437: - Description: Integration Test for BigQuery Sink using Streaming Inserts for streaming

[jira] [Comment Edited] (BEAM-3759) Add support for PaneInfo descriptor in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844971#comment-16844971 ] Tanay Tummalapalli edited comment on BEAM-3759 at 5/27/19 3:15 PM: --- Hi

[jira] [Assigned] (BEAM-7388) Reify PTransform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli reassigned BEAM-7388: Assignee: Tanay Tummalapalli > Reify PTransform for Python SDK >

[jira] [Created] (BEAM-7388) Reify PTransform for Python SDK

Tanay Tummalapalli created BEAM-7388: Summary: Reify PTransform for Python SDK Key: BEAM-7388 URL: https://issues.apache.org/jira/browse/BEAM-7388 Project: Beam Issue Type: Improvement

[jira] [Assigned] (BEAM-7023) WithKeys transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-7023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli reassigned BEAM-7023: Assignee: Tanay Tummalapalli > WithKeys transform for Python SDK >

[jira] [Commented] (BEAM-2518) Support TimestampCombiner in Python streaming mode GroupByKey

[ https://issues.apache.org/jira/browse/BEAM-2518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844978#comment-16844978 ] Tanay Tummalapalli commented on BEAM-2518: -- Hi [~ccy], I'd like to work on this. Do you have any

[jira] [Commented] (BEAM-3759) Add support for PaneInfo descriptor in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844971#comment-16844971 ] Tanay Tummalapalli commented on BEAM-3759: -- Hi [~ccy] The PR for this issue was merged. Can I

[jira] [Commented] (BEAM-5503) Updated BigQueryIO time partitioning doc snippet

[ https://issues.apache.org/jira/browse/BEAM-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824385#comment-16824385 ] Tanay Tummalapalli commented on BEAM-5503: -- Thanks [~dcavazos]! > Updated BigQueryIO time

[jira] [Comment Edited] (BEAM-5503) Updated BigQueryIO time partitioning doc snippet

[ https://issues.apache.org/jira/browse/BEAM-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812674#comment-16812674 ] Tanay Tummalapalli edited comment on BEAM-5503 at 4/8/19 6:10 PM: -- Hi

[jira] [Commented] (BEAM-5503) Updated BigQueryIO time partitioning doc snippet

[ https://issues.apache.org/jira/browse/BEAM-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812674#comment-16812674 ] Tanay Tummalapalli commented on BEAM-5503: -- Hi [~dcavazos] May I take this? > Updated BigQueryIO

[jira] [Commented] (BEAM-3208) add Distinct for consistency between SDK languages

[ https://issues.apache.org/jira/browse/BEAM-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802899#comment-16802899 ] Tanay Tummalapalli commented on BEAM-3208: -- Thank You :) > add Distinct for consistency between

[jira] [Commented] (BEAM-3208) add Distinct for consistency between SDK languages

[ https://issues.apache.org/jira/browse/BEAM-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801608#comment-16801608 ] Tanay Tummalapalli commented on BEAM-3208: -- The PR for this was merged. The fix version for this

[jira] [Commented] (BEAM-6695) Latest transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16797368#comment-16797368 ] Tanay Tummalapalli commented on BEAM-6695: -- Thank you [~altay]! I've been sick for the past week.

[jira] [Commented] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796170#comment-16796170 ] Tanay Tummalapalli commented on BEAM-6711: -- The test - *test_multiple_destinations_transform* was

[jira] [Commented] (BEAM-6695) Latest transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794340#comment-16794340 ] Tanay Tummalapalli commented on BEAM-6695: -- How do I get the event time of an element in a

[jira] [Comment Edited] (BEAM-6695) Latest transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794340#comment-16794340 ] Tanay Tummalapalli edited comment on BEAM-6695 at 3/16/19 8:54 PM: --- How

[jira] [Commented] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794325#comment-16794325 ] Tanay Tummalapalli commented on BEAM-6711: -- Can we mark this as resolved? > Bigquery Tornadoes

[jira] [Commented] (BEAM-6695) Latest transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792990#comment-16792990 ] Tanay Tummalapalli commented on BEAM-6695: -- Thank You :) > Latest transform for Python SDK >

[jira] [Commented] (BEAM-6695) Latest transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792974#comment-16792974 ] Tanay Tummalapalli commented on BEAM-6695: -- Hey [~altay]  I'd like to take this up. > Latest

[jira] [Commented] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792961#comment-16792961 ] Tanay Tummalapalli commented on BEAM-6711: -- Hey [~tvalentyn], [~pabloem] made a change in this

[jira] [Commented] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789988#comment-16789988 ] Tanay Tummalapalli commented on BEAM-6711: -- [~tvalentyn] I'll find the answer to those questions.

[jira] [Commented] (BEAM-2857) Create FileIO in Python

[ https://issues.apache.org/jira/browse/BEAM-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784871#comment-16784871 ] Tanay Tummalapalli commented on BEAM-2857: -- Hey [~rohanjulka19] You can get the Slack invite

[jira] [Commented] (BEAM-3885) Python SDK Read IO is expressed as Impulse -> ParDo

[ https://issues.apache.org/jira/browse/BEAM-3885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784662#comment-16784662 ] Tanay Tummalapalli commented on BEAM-3885: -- [~robertwb] The PR for this was merged. Can this be

[jira] [Commented] (BEAM-3435) Python SDK examples should use beam.io.WriteToBigQuery transform rather than the BigQuerySink to interact with BQ.

[ https://issues.apache.org/jira/browse/BEAM-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784358#comment-16784358 ] Tanay Tummalapalli commented on BEAM-3435: -- Hey [~tvalentyn] The PR for this was merged. Can

[jira] [Commented] (BEAM-4037) Add Python streaming wordcount snippets and test

[ https://issues.apache.org/jira/browse/BEAM-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782964#comment-16782964 ] Tanay Tummalapalli commented on BEAM-4037: -- The PR for this issue was merged. Is this still open?

[jira] [Comment Edited] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782745#comment-16782745 ] Tanay Tummalapalli edited comment on BEAM-6711 at 3/3/19 2:34 PM: --

[jira] [Comment Edited] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782745#comment-16782745 ] Tanay Tummalapalli edited comment on BEAM-6711 at 3/3/19 2:19 PM: --

[jira] [Comment Edited] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782745#comment-16782745 ] Tanay Tummalapalli edited comment on BEAM-6711 at 3/3/19 2:18 PM: --

[jira] [Comment Edited] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782745#comment-16782745 ] Tanay Tummalapalli edited comment on BEAM-6711 at 3/3/19 2:21 PM: --

[jira] [Comment Edited] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782745#comment-16782745 ] Tanay Tummalapalli edited comment on BEAM-6711 at 3/3/19 2:20 PM: --

[jira] [Comment Edited] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782745#comment-16782745 ] Tanay Tummalapalli edited comment on BEAM-6711 at 3/3/19 2:20 PM: --

[jira] [Commented] (BEAM-6711) Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.

[ https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782745#comment-16782745 ] Tanay Tummalapalli commented on BEAM-6711: -- [~pabloem] Looks like the `class TableReference`

[jira] [Commented] (BEAM-6611) A Python Sink for BigQuery with File Loads in Streaming

[ https://issues.apache.org/jira/browse/BEAM-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781573#comment-16781573 ] Tanay Tummalapalli commented on BEAM-6611: -- Thanks [~pabloem]. I'll go through it and get back to

[jira] [Commented] (BEAM-6611) A Python Sink for BigQuery with File Loads in Streaming

[ https://issues.apache.org/jira/browse/BEAM-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778653#comment-16778653 ] Tanay Tummalapalli commented on BEAM-6611: -- Hey [~pabloem] I am interested in this project for

[jira] [Commented] (BEAM-3208) add Distinct for consistency between SDK languages

[ https://issues.apache.org/jira/browse/BEAM-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16774849#comment-16774849 ] Tanay Tummalapalli commented on BEAM-3208: -- [~altay] Should I add a deprecation warning to

[jira] [Assigned] (BEAM-3208) add Distinct for consistency between SDK languages

[ https://issues.apache.org/jira/browse/BEAM-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli reassigned BEAM-3208: Assignee: Tanay Tummalapalli > add Distinct for consistency between SDK languages

[jira] [Commented] (BEAM-3208) add Distinct for consistency between SDK languages

[ https://issues.apache.org/jira/browse/BEAM-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770651#comment-16770651 ] Tanay Tummalapalli commented on BEAM-3208: -- Hey [~altay] I'd like to take this up. Since the