[jira] [Work logged] (BEAM-7800) Make Dataflow container dependencies consistent with setup.py requirements for 2.14.0

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

[jira] [Work logged] (BEAM-7800) Make Dataflow container dependencies consistent with setup.py requirements for 2.14.0

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

[jira] [Work logged] (BEAM-7766) Dataflow runner should default to PiplelineState.UNKNOWN when job state received via v1beta3 cannot be recognized.

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

[jira] [Work logged] (BEAM-7495) Add support for dynamic worker re-balancing when reading BigQuery data using Cloud Dataflow

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

[jira] [Work logged] (BEAM-7744) LTS backport: Temporary directory for WriteOperation may not be unique in FileBaseSink

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

[jira] [Work logged] (BEAM-7696) Detect classpath resources contains directory cause exception

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

[jira] [Work logged] (BEAM-7800) Make Dataflow container dependencies consistent with setup.py requirements for 2.14.0

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

[jira] [Work logged] (BEAM-7800) Make Dataflow container dependencies consistent with setup.py requirements for 2.14.0

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

[jira] [Created] (BEAM-7800) Make Dataflow container dependencies consistent with setup.py requirements for 2.14.0

Valentyn Tymofieiev created BEAM-7800: - Summary: Make Dataflow container dependencies consistent with setup.py requirements for 2.14.0 Key: BEAM-7800 URL: https://issues.apache.org/jira/browse/BEAM-7800

[jira] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[jira] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[jira] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[jira] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[jira] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[jira] [Work logged] (BEAM-7798) After changes in type inference, apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

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

[jira] [Commented] (BEAM-7650) Python Portable and HDFS IT need to clean up the docker image after complete

[ https://issues.apache.org/jira/browse/BEAM-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890570#comment-16890570 ] Udi Meiri commented on BEAM-7650: - This should do the trick: {code} docker system prune --all --filter

[jira] [Created] (BEAM-7799) Support Splittable DoFn in Flink Streaming Runner

Pablo Estrada created BEAM-7799: --- Summary: Support Splittable DoFn in Flink Streaming Runner Key: BEAM-7799 URL: https://issues.apache.org/jira/browse/BEAM-7799 Project: Beam Issue Type:

[jira] [Commented] (BEAM-7798) After changes in type inference, apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

[ https://issues.apache.org/jira/browse/BEAM-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890551#comment-16890551 ] Udi Meiri commented on BEAM-7798: - Thanks for triaging Valentyn. Robert, please add unit test if

[jira] [Commented] (BEAM-7589) Kinesis IO.write throws LimitExceededException

[ https://issues.apache.org/jira/browse/BEAM-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890545#comment-16890545 ] Pablo Estrada commented on BEAM-7589: - I've been assigned the issue, and I'm now waiting for

[jira] [Resolved] (BEAM-7783) Create Custom Statistics Class for BeamCalciteTable to support streams

[ https://issues.apache.org/jira/browse/BEAM-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alireza Samadianzakaria resolved BEAM-7783. --- Resolution: Implemented Fix Version/s: Not applicable > Create Custom

[jira] [Work started] (BEAM-1251) Python 3 Support

[ https://issues.apache.org/jira/browse/BEAM-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-1251 started by Valentyn Tymofieiev. - > Python 3 Support > > > Key:

[jira] [Work logged] (BEAM-7744) LTS backport: Temporary directory for WriteOperation may not be unique in FileBaseSink

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

[jira] [Work logged] (BEAM-7744) LTS backport: Temporary directory for WriteOperation may not be unique in FileBaseSink

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

[jira] [Assigned] (BEAM-1251) Python 3 Support

[ https://issues.apache.org/jira/browse/BEAM-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev reassigned BEAM-1251: - Assignee: Valentyn Tymofieiev (was: Robbe) > Python 3 Support >

[jira] [Assigned] (BEAM-3648) Support Splittable DoFn in Flink Batch Runner

[ https://issues.apache.org/jira/browse/BEAM-3648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada reassigned BEAM-3648: --- Assignee: (was: Aljoscha Krettek) > Support Splittable DoFn in Flink Batch Runner >

[jira] [Commented] (BEAM-3837) Python SDK harness should understand a BundleSplitRequest and respond with a BundleSplit before bundle finishes

[ https://issues.apache.org/jira/browse/BEAM-3837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890508#comment-16890508 ] Pablo Estrada commented on BEAM-3837: - is this done? > Python SDK harness should understand a

[jira] [Comment Edited] (BEAM-1251) Python 3 Support

[ https://issues.apache.org/jira/browse/BEAM-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890504#comment-16890504 ] Valentyn Tymofieiev edited comment on BEAM-1251 at 7/22/19 10:18 PM: -

[jira] [Comment Edited] (BEAM-1251) Python 3 Support

[ https://issues.apache.org/jira/browse/BEAM-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890504#comment-16890504 ] Valentyn Tymofieiev edited comment on BEAM-1251 at 7/22/19 10:17 PM: -

[jira] [Commented] (BEAM-1251) Python 3 Support

[ https://issues.apache.org/jira/browse/BEAM-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890504#comment-16890504 ] Valentyn Tymofieiev commented on BEAM-1251: --- There have been several Python 3-related

[jira] [Resolved] (BEAM-7761) Support transform_name_mapping option in python sdk

[ https://issues.apache.org/jira/browse/BEAM-7761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang resolved BEAM-7761. --- Resolution: Fixed > Support transform_name_mapping option in python sdk >

[jira] [Closed] (BEAM-7586) Add Integration Test for MongoDbIO in python sdk

[ https://issues.apache.org/jira/browse/BEAM-7586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang closed BEAM-7586. - > Add Integration Test for MongoDbIO in python sdk > - > >

[jira] [Work logged] (BEAM-6783) byte[] breaks in BeamSQL codegen

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

[jira] [Work logged] (BEAM-7079) Run Chicago Taxi Example on Dataflow

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

[jira] [Work logged] (BEAM-7798) After changes in type inference, apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

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

[jira] [Work logged] (BEAM-7798) After changes in type inference, apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

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

[jira] [Work logged] (BEAM-7798) After changes in type inference, apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

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

[jira] [Work logged] (BEAM-7060) Design Py3-compatible typehints annotation support in Beam 3.

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

[jira] [Work logged] (BEAM-7798) After changes in type inference, apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

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

[jira] [Work logged] (BEAM-7794) DynamoDBIOTest is blocking forever

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

[jira] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[jira] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[jira] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[jira] [Commented] (BEAM-2155) Investigate problem creating Map PCollection view on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890465#comment-16890465 ] Udi Meiri commented on BEAM-2155: - I've tried my own slightly modified version and it seems to work. Logs

[jira] [Updated] (BEAM-7798) After changes in type inference, apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

[ https://issues.apache.org/jira/browse/BEAM-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-7798: -- Priority: Blocker (was: Major) > After changes in type inference, >

[jira] [Commented] (BEAM-7798) After changes in type inference, apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

[ https://issues.apache.org/jira/browse/BEAM-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890464#comment-16890464 ] Valentyn Tymofieiev commented on BEAM-7798: --- Py 36, Py37 builds also have this error. > After

[jira] [Commented] (BEAM-7798) After changes in type inference, apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

[ https://issues.apache.org/jira/browse/BEAM-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890462#comment-16890462 ] Valentyn Tymofieiev commented on BEAM-7798: --- First failed build shows several type-inference

[jira] [Work logged] (BEAM-7794) DynamoDBIOTest is blocking forever

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

[jira] [Updated] (BEAM-7798) After changes in type inference, apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

[ https://issues.apache.org/jira/browse/BEAM-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-7798: -- Summary: After changes in type inference,

[jira] [Created] (BEAM-7798) apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits

Valentyn Tymofieiev created BEAM-7798: - Summary: apache_beam.io.gcp.bigquery_io_read_it_test.BigqueryIOReadIT.test_bigquery_read_1M_python is failing in Python 3.5 postcommits Key: BEAM-7798 URL:

[jira] [Work logged] (BEAM-6783) byte[] breaks in BeamSQL codegen

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

[jira] [Work logged] (BEAM-7696) Detect classpath resources contains directory cause exception

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

[jira] [Work logged] (BEAM-6783) byte[] breaks in BeamSQL codegen

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

[jira] [Updated] (BEAM-7797) DataflowRunner's upload_graph feature doesn't reduce template file size

[ https://issues.apache.org/jira/browse/BEAM-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-7797: -- Fix Version/s: 2.15.0 > DataflowRunner's upload_graph feature doesn't reduce template file size >

[jira] [Work logged] (BEAM-6783) byte[] breaks in BeamSQL codegen

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

[jira] [Work logged] (BEAM-6783) byte[] breaks in BeamSQL codegen

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

[jira] [Assigned] (BEAM-7724) Codegen should cast(null) to a type to match exact function signature

[ https://issues.apache.org/jira/browse/BEAM-7724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Wang reassigned BEAM-7724: -- Assignee: sridhar Reddy > Codegen should cast(null) to a type to match exact function signature >

[jira] [Work logged] (BEAM-6783) byte[] breaks in BeamSQL codegen

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

[jira] [Assigned] (BEAM-6783) byte[] breaks in BeamSQL codegen

[ https://issues.apache.org/jira/browse/BEAM-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gleb Kanterov reassigned BEAM-6783: --- Assignee: Gleb Kanterov (was: sridhar Reddy) > byte[] breaks in BeamSQL codegen >

[jira] [Created] (BEAM-7797) DataflowRunner's upload_graph feature doesn't reduce template file size

Yunqing Zhou created BEAM-7797: -- Summary: DataflowRunner's upload_graph feature doesn't reduce template file size Key: BEAM-7797 URL: https://issues.apache.org/jira/browse/BEAM-7797 Project: Beam

[jira] [Work logged] (BEAM-7744) LTS backport: Temporary directory for WriteOperation may not be unique in FileBaseSink

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

[jira] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[jira] [Created] (BEAM-7796) Improve health signal for StreamingDataflowWorker

Sam Whittle created BEAM-7796: - Summary: Improve health signal for StreamingDataflowWorker Key: BEAM-7796 URL: https://issues.apache.org/jira/browse/BEAM-7796 Project: Beam Issue Type:

[jira] [Commented] (BEAM-6858) Support side inputs injected into a DoFn

[ https://issues.apache.org/jira/browse/BEAM-6858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890370#comment-16890370 ] Reuven Lax commented on BEAM-6858: -- Inside ParDo, you will need to get the rest of the information of the

[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] [Commented] (BEAM-6858) Support side inputs injected into a DoFn

[ https://issues.apache.org/jira/browse/BEAM-6858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890365#comment-16890365 ] Reuven Lax commented on BEAM-6858: -- Some more details: We need to add a way for the user to control the

[jira] [Work logged] (BEAM-7744) LTS backport: Temporary directory for WriteOperation may not be unique in FileBaseSink

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

[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] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[jira] [Work logged] (BEAM-7747) ERROR: test_sink_transform (apache_beam.io.avroio_test.TestFastAvro) Fails on Windows

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

[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] [Work logged] (BEAM-7608) v1new ReadFromDatastore skips entities

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

[jira] [Work logged] (BEAM-7608) v1new ReadFromDatastore skips entities

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

[jira] [Work logged] (BEAM-6694) ApproximateQuantiles transform for Python SDK

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

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

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

[jira] [Work logged] (BEAM-7766) Dataflow runner should default to PiplelineState.UNKNOWN when job state received via v1beta3 cannot be recognized.

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

[jira] [Work logged] (BEAM-7783) Create Custom Statistics Class for BeamCalciteTable to support streams

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

[jira] [Work logged] (BEAM-7079) Run Chicago Taxi Example on Dataflow

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

[jira] [Work logged] (BEAM-7680) synthetic_pipeline_test.py flaky

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

[jira] [Work logged] (BEAM-7680) synthetic_pipeline_test.py flaky

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

[jira] [Work logged] (BEAM-7783) Create Custom Statistics Class for BeamCalciteTable to support streams

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

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

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

[jira] [Work logged] (BEAM-7574) Spark runner: Combine.perKey performance issues

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

[jira] [Work logged] (BEAM-5191) Add support for writing to BigQuery clustered tables

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

[jira] [Work logged] (BEAM-7679) examples.complete.game ITs might use the same BQ dataset

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

[jira] [Work logged] (BEAM-7732) Allow access to SpannerOptions in Beam

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

[jira] [Work logged] (BEAM-7680) synthetic_pipeline_test.py flaky

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

[jira] [Work logged] (BEAM-7664) Add the rest of GBK tests in Jenkins job [Flink]

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

[jira] [Work logged] (BEAM-7732) Allow access to SpannerOptions in Beam

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-2264) Re-use credential instead of generating a new one one each GCS call

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

[jira] [Work logged] (BEAM-2264) Re-use credential instead of generating a new one one each GCS call

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

[jira] [Work logged] (BEAM-2264) Re-use credential instead of generating a new one one each GCS call

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

[jira] [Work logged] (BEAM-7739) Add ValueState in Python sdk

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

[jira] [Updated] (BEAM-7794) DynamoDBIOTest is blocking forever

[ https://issues.apache.org/jira/browse/BEAM-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7794: --- Status: Open (was: Triage Needed) > DynamoDBIOTest is blocking forever >

[jira] [Created] (BEAM-7794) DynamoDBIOTest is blocking forever

Ismaël Mejía created BEAM-7794: -- Summary: DynamoDBIOTest is blocking forever Key: BEAM-7794 URL: https://issues.apache.org/jira/browse/BEAM-7794 Project: Beam Issue Type: Bug

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

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

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

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

  1   2   >