[jira] [Assigned] (BEAM-8347) UnboundedRabbitMqReader can fail to advance watermark if no new data comes in

[ https://issues.apache.org/jira/browse/BEAM-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-8347: -- Assignee: Jean-Baptiste Onofré > UnboundedRabbitMqReader can fail to advance wa

[jira] [Work logged] (BEAM-8347) UnboundedRabbitMqReader can fail to advance watermark if no new data comes in

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

[jira] [Work logged] (BEAM-8347) UnboundedRabbitMqReader can fail to advance watermark if no new data comes in

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

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

[ https://issues.apache.org/jira/browse/BEAM-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-8513: -- Assignee: Jean-Baptiste Onofré > RabbitMqIO: Allow reads from exchange-bound qu

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

[ https://issues.apache.org/jira/browse/BEAM-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-8513: --- Status: Open (was: Triage Needed) > RabbitMqIO: Allow reads from exchange-bound queue

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

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

[jira] [Updated] (BEAM-8539) Clearly define the valid job state transitions

[ https://issues.apache.org/jira/browse/BEAM-8539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chad Dombrova updated BEAM-8539: Description: The Beam job state transitions are ill-defined, which is big problem for anything that

[jira] [Updated] (BEAM-8539) Clearly define the valid job state transitions

[ https://issues.apache.org/jira/browse/BEAM-8539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chad Dombrova updated BEAM-8539: Description: The Beam job state transitions are ill-defined, which is big problem for anything that

[jira] [Commented] (BEAM-8539) Clearly define the valid job state transitions

[ https://issues.apache.org/jira/browse/BEAM-8539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964580#comment-16964580 ] Chad Dombrova commented on BEAM-8539: - [~lcwik], [~mxm] you might be interested in thi

[jira] [Created] (BEAM-8539) Clearly define the valid job state transitions

Chad Dombrova created BEAM-8539: --- Summary: Clearly define the valid job state transitions Key: BEAM-8539 URL: https://issues.apache.org/jira/browse/BEAM-8539 Project: Beam Issue Type: Improveme

[jira] [Work logged] (BEAM-8347) UnboundedRabbitMqReader can fail to advance watermark if no new data comes in

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

[jira] [Work logged] (BEAM-8347) UnboundedRabbitMqReader can fail to advance watermark if no new data comes in

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

[jira] [Work logged] (BEAM-7434) RabbitMqIO uses a deprecated API

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

[jira] [Work logged] (BEAM-7434) RabbitMqIO uses a deprecated API

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

[jira] [Work logged] (BEAM-8347) UnboundedRabbitMqReader can fail to advance watermark if no new data comes in

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

[jira] [Work logged] (BEAM-8514) ZetaSql should use cost-based optimization to take advantage of Join Reordering Rule and Push-Down Rule

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

[jira] [Commented] (BEAM-8243) Document behavior of FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-8243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964541#comment-16964541 ] Thomas Weise commented on BEAM-8243: Looking forward to see the gradle commands disapp

[jira] [Work logged] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

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

[jira] [Commented] (BEAM-8243) Document behavior of FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-8243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964534#comment-16964534 ] Thomas Weise commented on BEAM-8243: [~ibzib] [~robertwb] is this going to cover docum

[jira] [Updated] (BEAM-8372) Allow submission of Flink UberJar directly to flink cluster.

[ https://issues.apache.org/jira/browse/BEAM-8372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated BEAM-8372: --- Fix Version/s: 2.17.0 > Allow submission of Flink UberJar directly to flink cluster. > ---

[jira] [Updated] (BEAM-8372) Allow submission of Flink UberJar directly to flink cluster.

[ https://issues.apache.org/jira/browse/BEAM-8372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated BEAM-8372: --- Labels: portability portability-flink (was: ) > Allow submission of Flink UberJar directly to flink c

[jira] [Work logged] (BEAM-8435) Allow access to PaneInfo from Python DoFns

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

[jira] [Work logged] (BEAM-8435) Allow access to PaneInfo from Python DoFns

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

[jira] [Work logged] (BEAM-8435) Allow access to PaneInfo from Python DoFns

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

[jira] [Commented] (BEAM-8534) XlangParquetIOTest failing

[ https://issues.apache.org/jira/browse/BEAM-8534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964492#comment-16964492 ] Heejong Lee commented on BEAM-8534: --- Looks like there's a mismatch between published doc

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

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

[jira] [Work logged] (BEAM-7013) A new count distinct transform based on BigQuery compatible HyperLogLog++ implementation

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

[jira] [Work logged] (BEAM-7013) A new count distinct transform based on BigQuery compatible HyperLogLog++ implementation

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

[jira] [Created] (BEAM-8537) Provide WatermarkEstimatorProvider for different types of WatermarkEstimator

Boyuan Zhang created BEAM-8537: -- Summary: Provide WatermarkEstimatorProvider for different types of WatermarkEstimator Key: BEAM-8537 URL: https://issues.apache.org/jira/browse/BEAM-8537 Project: Beam

[jira] [Created] (BEAM-8538) Python typehints: support namedtuples

Udi Meiri created BEAM-8538: --- Summary: Python typehints: support namedtuples Key: BEAM-8538 URL: https://issues.apache.org/jira/browse/BEAM-8538 Project: Beam Issue Type: Bug Components:

[jira] [Assigned] (BEAM-8536) Migrate usage of DelayedBundleApplication.requested_execution_time to time duration

[ https://issues.apache.org/jira/browse/BEAM-8536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyuan Zhang reassigned BEAM-8536: -- Assignee: Boyuan Zhang > Migrate usage of DelayedBundleApplication.requested_execution_time to

[jira] [Work logged] (BEAM-8451) Interactive Beam example failing from stack overflow

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

[jira] [Work logged] (BEAM-8451) Interactive Beam example failing from stack overflow

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

[jira] [Work logged] (BEAM-7013) A new count distinct transform based on BigQuery compatible HyperLogLog++ implementation

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

[jira] [Work logged] (BEAM-7013) A new count distinct transform based on BigQuery compatible HyperLogLog++ implementation

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

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

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

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

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

[jira] [Work logged] (BEAM-8252) (Python SDK) Add worker_region and worker_zone options

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

[jira] [Work logged] (BEAM-8254) (Java SDK) Add workerRegion and workerZone options

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

[jira] [Work logged] (BEAM-8491) Add ability for multiple output PCollections from composites

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

[jira] [Work logged] (BEAM-8491) Add ability for multiple output PCollections from composites

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

[jira] [Resolved] (BEAM-8365) Add project push-down capability to IO APIs

[ https://issues.apache.org/jira/browse/BEAM-8365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirill Kozlov resolved BEAM-8365. - Fix Version/s: 2.18.0 Resolution: Fixed > Add project push-down capability to IO APIs > ---

[jira] [Work logged] (BEAM-8533) test_java_expansion_portable_runner failing

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

[jira] [Created] (BEAM-8536) Migrate usage of DelayedBundleApplication.requested_execution_time to time duration

Boyuan Zhang created BEAM-8536: -- Summary: Migrate usage of DelayedBundleApplication.requested_execution_time to time duration Key: BEAM-8536 URL: https://issues.apache.org/jira/browse/BEAM-8536 Project:

[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=16964406#comment-16964406 ] Chad Dombrova commented on BEAM-8523: - WIP: https://github.com/apache/beam/pull/9959

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

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

[jira] [Work logged] (BEAM-8532) Beam Python trigger driver sets incorrect timestamp for output windows.

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

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

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

[jira] [Created] (BEAM-8535) TextIO.read doesn't work with single wildcard with relative path

Tim created BEAM-8535: - Summary: TextIO.read doesn't work with single wildcard with relative path Key: BEAM-8535 URL: https://issues.apache.org/jira/browse/BEAM-8535 Project: Beam Issue Type: Bug

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

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

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

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

[jira] [Work logged] (BEAM-8533) test_java_expansion_portable_runner failing

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

[jira] [Work logged] (BEAM-8451) Interactive Beam example failing from stack overflow

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

[jira] [Work logged] (BEAM-8442) Unfiy bundle register in Python SDK harness

[ https://issues.apache.org/jira/browse/BEAM-8442?focusedWorklogId=337053&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-337053 ] ASF GitHub Bot logged work on BEAM-8442: 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: https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ Edit: Made subtasks for what appe

[jira] [Updated] (BEAM-8533) test_java_expansion_portable_runner failing

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

[jira] [Work logged] (BEAM-8530) Dataflow portable runner fails timer ordering tests

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

[jira] [Created] (BEAM-8534) XlangParquetIOTest failing

Kyle Weaver created BEAM-8534: - Summary: XlangParquetIOTest failing Key: BEAM-8534 URL: https://issues.apache.org/jira/browse/BEAM-8534 Project: Beam Issue Type: Sub-task Components: te

[jira] [Created] (BEAM-8533) test_java_expansion_portable_runner failing

Kyle Weaver created BEAM-8533: - Summary: test_java_expansion_portable_runner failing Key: BEAM-8533 URL: https://issues.apache.org/jira/browse/BEAM-8533 Project: Beam Issue Type: Sub-task

[jira] [Work logged] (BEAM-8491) Add ability for multiple output PCollections from composites

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

[jira] [Work logged] (BEAM-8427) [SQL] Add support for MongoDB source

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

[jira] [Work logged] (BEAM-8427) [SQL] Add support for MongoDB source

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

[jira] [Created] (BEAM-8532) Beam Python trigger driver sets incorrect timestamp for output windows.

Robert Bradshaw created BEAM-8532: - Summary: Beam Python trigger driver sets incorrect timestamp for output windows. Key: BEAM-8532 URL: https://issues.apache.org/jira/browse/BEAM-8532 Project: Beam

[jira] [Work logged] (BEAM-8427) [SQL] Add support for MongoDB source

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

[jira] [Created] (BEAM-8531) DoFnTester should either be removed from the documentation or undeprecated.

Daniel Collins created BEAM-8531: Summary: DoFnTester should either be removed from the documentation or undeprecated. Key: BEAM-8531 URL: https://issues.apache.org/jira/browse/BEAM-8531 Project: Beam

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

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

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

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

[jira] [Work logged] (BEAM-8434) Allow trigger transcript tests to be run as ValidatesRunner tests.

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

[jira] [Work logged] (BEAM-8427) [SQL] Add support for MongoDB source

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

[jira] [Resolved] (BEAM-8008) Show error message from expansion service in Java External transform

[ https://issues.apache.org/jira/browse/BEAM-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee resolved BEAM-8008. --- Fix Version/s: 2.16.0 Resolution: Fixed > Show error message from expansion service in Java Ext

[jira] [Work logged] (BEAM-8427) [SQL] Add support for MongoDB source

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

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

[ https://issues.apache.org/jira/browse/BEAM-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964253#comment-16964253 ] Kyle Weaver commented on BEAM-8521: --- I think I have tracked the Python failure: https:/

[jira] [Work logged] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

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

[jira] [Work logged] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Resolved] (BEAM-8397) DataflowRunnerTest.test_remote_runner_display_data sometimes fails due to infinite recursion during pickling on Python 3.7.

[ https://issues.apache.org/jira/browse/BEAM-8397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev resolved BEAM-8397. --- Fix Version/s: 2.17.0 Resolution: Fixed > DataflowRunnerTest.test_remote_runner

[jira] [Work logged] (BEAM-8442) Unfiy bundle register in Python SDK harness

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

[jira] [Work logged] (BEAM-8397) DataflowRunnerTest.test_remote_runner_display_data sometimes fails due to infinite recursion during pickling on Python 3.7.

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

  1   2   >