[jira] [Work logged] (BEAM-7303) Move Portable Runner and other of reference runner.

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

[jira] [Work logged] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

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

[jira] [Work logged] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

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

[jira] [Commented] (BEAM-8512) Add integration tests for Python "flink_runner.py"

[ https://issues.apache.org/jira/browse/BEAM-8512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962942#comment-16962942 ] Maximilian Michels commented on BEAM-8512: -- This is just your test script though? We need

[jira] [Updated] (BEAM-8512) Add integration tests for Python "flink_runner.py"

[ https://issues.apache.org/jira/browse/BEAM-8512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8512: - Status: Open (was: Triage Needed) > Add integration tests for Python "flink_runner.py" >

[jira] [Work logged] (BEAM-8518) Pipeline options translation fails silently with incompatible jackson-core library

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

[jira] [Updated] (BEAM-8518) Pipeline options translation fails silently with incompatible jackson-core library

[ https://issues.apache.org/jira/browse/BEAM-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8518: - Status: Open (was: Triage Needed) > Pipeline options translation fails silently with

[jira] [Resolved] (BEAM-8518) Pipeline options translation fails silently with incompatible jackson-core library

[ https://issues.apache.org/jira/browse/BEAM-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8518. -- Fix Version/s: 2.18.0 Resolution: Fixed > Pipeline options translation fails

[jira] [Work logged] (BEAM-6860) WriteToText crash with "GlobalWindow -> ._IntervalWindowBase"

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

[jira] [Work logged] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

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

[jira] [Work logged] (BEAM-7730) Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-7730) Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9

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

[jira] [Commented] (BEAM-7577) Allow the use of ValueProviders in datastore.v1new.datastoreio.ReadFromDatastore query

[ https://issues.apache.org/jira/browse/BEAM-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962960#comment-16962960 ] EDjur commented on BEAM-7577: - Looks like this has been integrated into the 2.16.0 release. Please feel free

[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] [Updated] (BEAM-7577) Allow the use of ValueProviders in datastore.v1new.datastoreio.ReadFromDatastore query

[ https://issues.apache.org/jira/browse/BEAM-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] EDjur updated BEAM-7577: Fix Version/s: 2.16.0 > Allow the use of ValueProviders in > datastore.v1new.datastoreio.ReadFromDatastore query >

[jira] [Work logged] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

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

[jira] [Commented] (BEAM-8512) Add integration tests for Python "flink_runner.py"

[ https://issues.apache.org/jira/browse/BEAM-8512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963044#comment-16963044 ] Maximilian Michels commented on BEAM-8512: -- You seem to have that almost setup [~ibzib]. Do you

[jira] [Updated] (BEAM-7577) Allow the use of ValueProviders in datastore.v1new.datastoreio.ReadFromDatastore query

[ https://issues.apache.org/jira/browse/BEAM-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] EDjur updated BEAM-7577: Fix Version/s: (was: 2.16.0) > Allow the use of ValueProviders in >

[jira] [Comment Edited] (BEAM-7577) Allow the use of ValueProviders in datastore.v1new.datastoreio.ReadFromDatastore query

[ https://issues.apache.org/jira/browse/BEAM-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962960#comment-16962960 ] EDjur edited comment on BEAM-7577 at 10/30/19 12:00 PM: Looks like this has been

[jira] [Closed] (BEAM-8410) JdbcIO should support setConnectionInitSqls in its DataSource

[ https://issues.apache.org/jira/browse/BEAM-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko closed BEAM-8410. -- Fix Version/s: 2.17.0 Resolution: Fixed > JdbcIO should support setConnectionInitSqls in

[jira] [Work logged] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

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

[jira] [Work logged] (BEAM-8398) Upgrade Dataflow Java Client API

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

[jira] [Commented] (BEAM-3288) Guard against unsafe triggers at construction time

[ https://issues.apache.org/jira/browse/BEAM-3288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963195#comment-16963195 ] Kenneth Knowles commented on BEAM-3288: --- I believe it is a fundamental design but to have triggers

[jira] [Created] (BEAM-8519) Typehint for Python CombineFn Accumulator

Yifan Mai created BEAM-8519: --- Summary: Typehint for Python CombineFn Accumulator Key: BEAM-8519 URL: https://issues.apache.org/jira/browse/BEAM-8519 Project: Beam Issue Type: New Feature

[jira] [Work logged] (BEAM-8402) Create a class hierarchy to represent environments

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

[jira] [Commented] (BEAM-7594) test_read_from_text_with_file_name_file_pattern is flaky

[ https://issues.apache.org/jira/browse/BEAM-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963277#comment-16963277 ] Valentyn Tymofieiev commented on BEAM-7594: --- Failed yesterday in

[jira] [Commented] (BEAM-7594) test_read_from_text_with_file_name_file_pattern is flaky

[ https://issues.apache.org/jira/browse/BEAM-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963275#comment-16963275 ] Valentyn Tymofieiev commented on BEAM-7594: --- This test keeps failing in precommits - do you

[jira] [Commented] (BEAM-8411) Re-enable pylint checks disabled due to pylint bug

[ https://issues.apache.org/jira/browse/BEAM-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963278#comment-16963278 ] Udi Meiri commented on BEAM-8411: - This seems to be resolved since we use pylint 2.4.2 now? > Re-enable

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

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

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

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

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

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

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

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

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

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

[jira] [Assigned] (BEAM-7250) Use annotation based parameters for SDF on Java

[ https://issues.apache.org/jira/browse/BEAM-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada reassigned BEAM-7250: --- Assignee: Boyuan Zhang > Use annotation based parameters for SDF on Java >

[jira] [Commented] (BEAM-7250) Use annotation based parameters for SDF on Java

[ https://issues.apache.org/jira/browse/BEAM-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963174#comment-16963174 ] Pablo Estrada commented on BEAM-7250: - Assigning to Boyuan to take a look : ) > Use annotation based

[jira] [Work logged] (BEAM-6892) Use temp_location for BQ FILE_LOADS on DirectRunner, and autocreate it in GCS if not specified by user.

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

[jira] [Commented] (BEAM-8012) Perf improvements for Python WriteToBigQuery with Streaming Inserts

[ https://issues.apache.org/jira/browse/BEAM-8012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963173#comment-16963173 ] Pablo Estrada commented on BEAM-8012: - Unassigning for now to see if anyone takes a look > Perf

[jira] [Work logged] (BEAM-8450) ParDoLifecycleTest does not allow for empty bundles

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

[jira] [Work logged] (BEAM-8472) Get default GCP region from gcloud

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

[jira] [Created] (BEAM-8520) Expansion of _CombinePerKeyWithHotKeyFanout has no typehints

Yifan Mai created BEAM-8520: --- Summary: Expansion of _CombinePerKeyWithHotKeyFanout has no typehints Key: BEAM-8520 URL: https://issues.apache.org/jira/browse/BEAM-8520 Project: Beam Issue Type:

[jira] [Updated] (BEAM-8381) Typehints on DoFn subclass are incorrectly set on superclass

[ https://issues.apache.org/jira/browse/BEAM-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai updated BEAM-8381: Summary: Typehints on DoFn subclass are incorrectly set on superclass (was: Typehints on DoFn subclass are

[jira] [Work logged] (BEAM-8513) RabbitMqIO: Allow reads from exchange-bound queue without declaring the exchange

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

[jira] [Updated] (BEAM-8472) Get default GCP region from gcloud

[ https://issues.apache.org/jira/browse/BEAM-8472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8472: -- Status: Open (was: Triage Needed) > Get default GCP region from gcloud >

[jira] [Updated] (BEAM-8516) sdist build fails when artifacts from different versions are present

[ https://issues.apache.org/jira/browse/BEAM-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8516: -- Status: Open (was: Triage Needed) > sdist build fails when artifacts from different versions are

[jira] [Work logged] (BEAM-8398) Upgrade Dataflow Java Client API

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

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

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

[jira] [Work logged] (BEAM-7926) Visualize PCollection with Interactive Beam

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

[jira] [Work logged] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

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

[jira] [Work logged] (BEAM-8428) [SQL] BigQuery should support project push-down in DIRECT_READ mode

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-8398) Upgrade Dataflow Java Client API

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-8398) Upgrade Dataflow Java Client API

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

[jira] [Assigned] (BEAM-7288) Upgrade bcprov-jdk15on

[ https://issues.apache.org/jira/browse/BEAM-7288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mujuzi Moses reassigned BEAM-7288: -- Assignee: Mujuzi Moses > Upgrade bcprov-jdk15on > -- > >

[jira] [Updated] (BEAM-8460) Portable Flink runner fails UsesStrictTimerOrdering category tests

[ https://issues.apache.org/jira/browse/BEAM-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8460: - Status: Open (was: Triage Needed) > Portable Flink runner fails UsesStrictTimerOrdering

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-6892) Use temp_location for BQ FILE_LOADS on DirectRunner, and autocreate it in GCS if not specified by user.

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

[jira] [Assigned] (BEAM-8012) Perf improvements for Python WriteToBigQuery with Streaming Inserts

[ https://issues.apache.org/jira/browse/BEAM-8012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada reassigned BEAM-8012: --- Assignee: (was: Tanay Tummalapalli) > Perf improvements for Python WriteToBigQuery with

[jira] [Work logged] (BEAM-8398) Upgrade Dataflow Java Client API

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

[jira] [Work logged] (BEAM-8398) Upgrade Dataflow Java Client API

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

[jira] [Work logged] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

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

[jira] [Work logged] (BEAM-8398) Upgrade Dataflow Java Client API

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

[jira] [Resolved] (BEAM-8398) Upgrade Dataflow Java Client API

[ https://issues.apache.org/jira/browse/BEAM-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-8398. - Fix Version/s: 2.18.0 Resolution: Fixed > Upgrade Dataflow Java Client API >

[jira] [Updated] (BEAM-8519) Typehint for Python CombineFn Accumulator

[ https://issues.apache.org/jira/browse/BEAM-8519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai updated BEAM-8519: Description: Feature request: Allow users to specify a typehint for the accumulator type of CombineFn,

[jira] [Updated] (BEAM-7594) test_read_from_text_with_file_name_file_pattern is flaky

[ https://issues.apache.org/jira/browse/BEAM-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-7594: -- Labels: currently-failing (was: ) > test_read_from_text_with_file_name_file_pattern is

[jira] [Work logged] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

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

[jira] [Commented] (BEAM-8411) Re-enable pylint checks disabled due to pylint bug

[ https://issues.apache.org/jira/browse/BEAM-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963296#comment-16963296 ] Chad Dombrova commented on BEAM-8411: - No, this was introduced with 2.4.2. we need to switch to

[jira] [Work logged] (BEAM-8457) Instrument Dataflow jobs that are launched from Notebooks

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

[jira] [Work logged] (BEAM-8398) Upgrade Dataflow Java Client API

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

[jira] [Work logged] (BEAM-8398) Upgrade Dataflow Java Client API

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

[jira] [Work logged] (BEAM-8511) Support for enhanced fan-out in KinesisIO

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

[jira] [Work logged] (BEAM-8513) RabbitMqIO: Allow reads from exchange-bound queue without declaring the exchange

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

[jira] [Work logged] (BEAM-8513) RabbitMqIO: Allow reads from exchange-bound queue without declaring the exchange

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

[jira] [Work logged] (BEAM-8428) [SQL] BigQuery should support project push-down in DIRECT_READ mode

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

[jira] [Created] (BEAM-8521) beam_PostCommit_XVR_Flink failing

Kyle Weaver created BEAM-8521: - Summary: beam_PostCommit_XVR_Flink failing Key: BEAM-8521 URL: https://issues.apache.org/jira/browse/BEAM-8521 Project: Beam Issue Type: Bug Components:

[jira] [Work logged] (BEAM-8524) Stop using pubsub in fnapi streaming dataflow Impluse

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

[jira] [Work logged] (BEAM-8508) [SQL] Support predicate push-down without project push-down

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

[jira] [Work logged] (BEAM-8508) [SQL] Support predicate push-down without project push-down

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

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

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

[jira] [Created] (BEAM-8525) trivial_inference: slice of Const[List[T]] returns T instead of List[T]

Udi Meiri created BEAM-8525: --- Summary: trivial_inference: slice of Const[List[T]] returns T instead of List[T] Key: BEAM-8525 URL: https://issues.apache.org/jira/browse/BEAM-8525 Project: Beam

[jira] [Commented] (BEAM-8523) Add useful timestamp to job servicer GetJobs

[ https://issues.apache.org/jira/browse/BEAM-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963522#comment-16963522 ] Chad Dombrova commented on BEAM-8523: - [~lcwik] does this change sound reasonable to you? > Add

[jira] [Updated] (BEAM-8523) Add useful timestamp to job servicer GetJobs

[ https://issues.apache.org/jira/browse/BEAM-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chad Dombrova updated BEAM-8523: Description: As a user querying jobs with JobService.GetJobs, it would be useful if the JobInfo

[jira] [Work logged] (BEAM-8513) RabbitMqIO: Allow reads from exchange-bound queue without declaring the exchange

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

[jira] [Work logged] (BEAM-7926) Visualize PCollection with Interactive Beam

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

[jira] [Assigned] (BEAM-3288) Guard against unsafe triggers at construction time

[ https://issues.apache.org/jira/browse/BEAM-3288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-3288: - Assignee: Kenneth Knowles (was: Eugene Kirpichov) > Guard against unsafe triggers at

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

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

[jira] [Work logged] (BEAM-8398) Upgrade Dataflow Java Client API

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

[jira] [Work logged] (BEAM-8511) Support for enhanced fan-out in KinesisIO

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

[jira] [Work logged] (BEAM-8511) Support for enhanced fan-out in KinesisIO

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

[jira] [Work logged] (BEAM-8511) Support for enhanced fan-out in KinesisIO

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

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

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

[jira] [Work logged] (BEAM-8513) RabbitMqIO: Allow reads from exchange-bound queue without declaring the exchange

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

[jira] [Work logged] (BEAM-8513) RabbitMqIO: Allow reads from exchange-bound queue without declaring the exchange

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

[jira] [Work logged] (BEAM-8508) [SQL] Support predicate push-down without project push-down

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

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

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

  1   2   >