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

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

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

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

[jira] [Work logged] (BEAM-8503) Improve TestBigQuery and TestPubsub

[ https://issues.apache.org/jira/browse/BEAM-8503?focusedWorklogId=336619&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336619 ] ASF GitHub Bot logged work on BEAM-8503: 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=336616&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336616 ] 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=336617&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336617 ] ASF GitHub Bot logged work on BEAM-8508: Author: ASF GitHub Bot

[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&focusedCommentId=16963645#comment-16963645 ] Chad Dombrova commented on BEAM-8523: - {quote} Seems to make sense but we might as wel

[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&focusedCommentId=16963624#comment-16963624 ] Luke Cwik commented on BEAM-8523: - Seems to make sense but we might as well just have all

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

[ https://issues.apache.org/jira/browse/BEAM-8508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8508: -- Status: Open (was: Triage Needed) > [SQL] Support predicate push-down without project push-down

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

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

[jira] [Work logged] (BEAM-7526) beam_PostCommit_SQL suite is failing since June 7.

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

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

[ https://issues.apache.org/jira/browse/BEAM-7746?focusedWorklogId=336546&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336546 ] ASF GitHub Bot logged work on BEAM-7746: 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=336544&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336544 ] 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=336545&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336545 ] 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=336543&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336543 ] 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=336542&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336542 ] ASF GitHub Bot logged work on BEAM-8513: Author: ASF GitHub Bot

[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&focusedCommentId=16963522#comment-16963522 ] Chad Dombrova commented on BEAM-8523: - [~lcwik] does this change sound reasonable to y

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

[jira] [Work logged] (BEAM-8396) Default to LOOPBACK mode for local flink (spark, ...) runner.

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

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

[ https://issues.apache.org/jira/browse/BEAM-8525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-8525: Status: Open (was: Triage Needed) > trivial_inference: slice of Const[List[T]] returns T instead of List[T]

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

[ https://issues.apache.org/jira/browse/BEAM-8525?focusedWorklogId=336537&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336537 ] ASF GitHub Bot logged work on BEAM-8525: 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 Iss

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

[ https://issues.apache.org/jira/browse/BEAM-8508?focusedWorklogId=336533&page=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&page=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&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336534 ] 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=336531&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336531 ] 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=336530&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336530 ] 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=336532&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336532 ] ASF GitHub Bot logged work on BEAM-7746: 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&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336519 ] ASF GitHub Bot logged work on BEAM-8508: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-8470) Create a new Spark runner based on Spark Structured streaming framework

[ https://issues.apache.org/jira/browse/BEAM-8470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8470: --- Status: Open (was: Triage Needed) > Create a new Spark runner based on Spark Structured streaming fra

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

[ https://issues.apache.org/jira/browse/BEAM-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8521: -- Status: Open (was: Triage Needed) > beam_PostCommit_XVR_Flink failing > ---

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

[ https://issues.apache.org/jira/browse/BEAM-8524?focusedWorklogId=336507&page=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-3288) Guard against unsafe triggers at construction time

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

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

[ https://issues.apache.org/jira/browse/BEAM-3288?focusedWorklogId=336502&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336502 ] ASF GitHub Bot logged work on BEAM-3288: 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=336501&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336501 ] 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=336500&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336500 ] ASF GitHub Bot logged work on BEAM-8507: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8474) A microbenchmark that exercises the FnAPI runner functionality

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

[jira] [Work logged] (BEAM-8474) A microbenchmark that exercises the FnAPI runner functionality

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

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

[ https://issues.apache.org/jira/browse/BEAM-8524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963452#comment-16963452 ] Boyuan Zhang commented on BEAM-8524: Dataflow runner should translate streaming fnapi

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

Boyuan Zhang created BEAM-8524: -- Summary: Stop using pubsub in fnapi streaming dataflow Impluse Key: BEAM-8524 URL: https://issues.apache.org/jira/browse/BEAM-8524 Project: Beam Issue Type: Impr

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

Chad Dombrova created BEAM-8523: --- Summary: Add useful timestamp to job servicer GetJobs Key: BEAM-8523 URL: https://issues.apache.org/jira/browse/BEAM-8523 Project: Beam Issue Type: New Feature

[jira] [Updated] (BEAM-8522) beam_PreCommit_Python2_PVR_Flink_Commit failure

[ https://issues.apache.org/jira/browse/BEAM-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8522: -- Description: I'm confused by why this happens, as we added flink-master-url as an alias for flink-maste

[jira] [Work logged] (BEAM-8467) Enable reading compressed files with Python fileio

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

[jira] [Work logged] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO

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

[jira] [Work logged] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO

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

[jira] [Work logged] (BEAM-8521) beam_PostCommit_XVR_Flink failing

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

[jira] [Created] (BEAM-8522) beam_PreCommit_Python2_PVR_Flink_Commit failure

Kyle Weaver created BEAM-8522: - Summary: beam_PreCommit_Python2_PVR_Flink_Commit failure Key: BEAM-8522 URL: https://issues.apache.org/jira/browse/BEAM-8522 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO

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

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

[ https://issues.apache.org/jira/browse/BEAM-7746?focusedWorklogId=336475&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336475 ] 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=336474&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336474 ] ASF GitHub Bot logged work on BEAM-7746: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7230) Using JdbcIO creates huge amount of connections

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

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

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

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

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

[jira] [Work logged] (BEAM-8467) Enable reading compressed files with Python fileio

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

[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&focusedCommentId=16963427#comment-16963427 ] Rafal Wojdyla commented on BEAM-8485: - Hi [~ttanay] We are not using dynamic destinati

[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&focusedCommentId=16963426#comment-16963426 ] Maximilian Michels commented on BEAM-8512: -- Ah, didn't see that this was also par

[jira] [Work logged] (BEAM-8521) beam_PostCommit_XVR_Flink failing

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

[jira] [Work logged] (BEAM-8521) beam_PostCommit_XVR_Flink failing

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

[jira] [Commented] (BEAM-2572) Implement an S3 filesystem for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963425#comment-16963425 ] Pablo Estrada commented on BEAM-2572: - Very cool! Thanks [~mattmorgis]. I think you ca

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

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

[jira] [Work logged] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO

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

[jira] [Work logged] (BEAM-8358) Failing test in UTC+8 timezone

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

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

[ https://issues.apache.org/jira/browse/BEAM-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8521: -- Description: *11:13:37* java.util.concurrent.ExecutionException: java.lang.RuntimeException: Error rece

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

[ https://issues.apache.org/jira/browse/BEAM-8507?focusedWorklogId=336453&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336453 ] 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=336452&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336452 ] ASF GitHub Bot logged work on BEAM-8507: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8374) PublishResult returned by SnsIO is missing sdkResponseMetadata and sdkHttpMetadata

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

[jira] [Work logged] (BEAM-8374) PublishResult returned by SnsIO is missing sdkResponseMetadata and sdkHttpMetadata

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

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

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

[jira] [Resolved] (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 ] Udi Meiri resolved BEAM-7577. - Resolution: Fixed > Allow the use of ValueProviders in > datastore.v1new.datastoreio.ReadFromDatastore qu

[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 ] Udi Meiri updated BEAM-7577: Fix Version/s: 2.16.0 > Allow the use of ValueProviders in > datastore.v1new.datastoreio.ReadFromDatastore

[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&focusedCommentId=16963397#comment-16963397 ] Udi Meiri commented on BEAM-7577: - 2.16 has been released already. You are listed in the l

[jira] [Commented] (BEAM-2572) Implement an S3 filesystem for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963385#comment-16963385 ] Matt Morgis commented on BEAM-2572: --- [~pabloem] - I have had some free time at work, and

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

[ https://issues.apache.org/jira/browse/BEAM-8507?focusedWorklogId=336438&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336438 ] 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=336437&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336437 ] 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=336435&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336435 ] 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=336434&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336434 ] ASF GitHub Bot logged work on BEAM-8507: Author: ASF GitHub Bot

[jira] [Assigned] (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 ] Kyle Weaver reassigned BEAM-8512: - Assignee: Kyle Weaver > Add integration tests for Python "flink_runner.py" >

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

[ https://issues.apache.org/jira/browse/BEAM-7746?focusedWorklogId=336431&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336431 ] 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=336430&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336430 ] 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=336429&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336429 ] 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=336427&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336427 ] 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=336425&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336425 ] 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=336422&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336422 ] 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=336423&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336423 ] ASF GitHub Bot logged work on BEAM-7746: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

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

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

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

[ https://issues.apache.org/jira/browse/BEAM-7746?focusedWorklogId=336417&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336417 ] 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=336416&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336416 ] ASF GitHub Bot logged work on BEAM-7746: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

[ https://issues.apache.org/jira/browse/BEAM-4775?focusedWorklogId=336415&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336415 ] ASF GitHub Bot logged work on BEAM-4775: 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&page=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-7389) Colab examples for element-wise transforms (Python)

[ https://issues.apache.org/jira/browse/BEAM-7389?focusedWorklogId=336411&page=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-7746) Add type hints to python code

[ https://issues.apache.org/jira/browse/BEAM-7746?focusedWorklogId=336406&page=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&page=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&page=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&page=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&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336405 ] ASF GitHub Bot logged work on BEAM-7746: 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-8457) Instrument Dataflow jobs that are launched from Notebooks

[ https://issues.apache.org/jira/browse/BEAM-8457?focusedWorklogId=336366&page=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-8428) [SQL] BigQuery should support project push-down in DIRECT_READ mode

[ https://issues.apache.org/jira/browse/BEAM-8428?focusedWorklogId=336359&page=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-8428) [SQL] BigQuery should support project push-down in DIRECT_READ mode

[ https://issues.apache.org/jira/browse/BEAM-8428?focusedWorklogId=336360&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-336360 ] ASF GitHub Bot logged work on BEAM-8428: 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 > --

  1   2   >