[jira] [Commented] (BEAM-8207) KafkaIOITs generate different hashes each run, sometimes dropping records

[ https://issues.apache.org/jira/browse/BEAM-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969909#comment-16969909 ] Michal Walenia commented on BEAM-8207: -- [~aromanenko] Yes, the issue can be closed now. Thanks! >

[jira] [Work logged] (BEAM-8157) Key encoding for state requests is not consistent across SDKs

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

[jira] [Updated] (BEAM-8591) Exception is thrown while running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Gong updated BEAM-8591: - Summary: Exception is thrown while running Beam Pipeline on Kubernetes Flink Cluster. (was:

[jira] [Updated] (BEAM-8591) Exception is thrown when running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Gong updated BEAM-8591: - Description: h2. Setup Clusters * Setup Local Flink Cluster: 

[jira] [Work logged] (BEAM-8157) Key encoding for state requests is not consistent across SDKs

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

[jira] [Work logged] (BEAM-8594) Remove unnecessary error check of the control service accessing in DataFlow Runner

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

[jira] [Created] (BEAM-8594) Remove unnecessary error check of the control service accessing in DataFlow Runner

sunjincheng created BEAM-8594: - Summary: Remove unnecessary error check of the control service accessing in DataFlow Runner Key: BEAM-8594 URL: https://issues.apache.org/jira/browse/BEAM-8594 Project:

[jira] [Work logged] (BEAM-7948) Add time-based cache threshold support in the Java data service

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

[jira] [Work logged] (BEAM-8592) DataCatalogTableProvider should not squash table components together into a string

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

[jira] [Created] (BEAM-8593) Define expected behavior of running ZetaSQL query on tables with unsupported field types

Yueyang Qiu created BEAM-8593: - Summary: Define expected behavior of running ZetaSQL query on tables with unsupported field types Key: BEAM-8593 URL: https://issues.apache.org/jira/browse/BEAM-8593

[jira] [Work logged] (BEAM-8566) Checkpoint buffer is flushed prematurely when another bundle is started during checkpointing

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

[jira] [Commented] (BEAM-8592) DataCatalogTableProvider should not squash table components together into a string

[ https://issues.apache.org/jira/browse/BEAM-8592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969807#comment-16969807 ] Kenneth Knowles commented on BEAM-8592: --- CC [~apilloud] [~amaliujia] > DataCatalogTableProvider

[jira] [Created] (BEAM-8592) DataCatalogTableProvider should not squash table components together into a string

Kenneth Knowles created BEAM-8592: - Summary: DataCatalogTableProvider should not squash table components together into a string Key: BEAM-8592 URL: https://issues.apache.org/jira/browse/BEAM-8592

[jira] [Updated] (BEAM-8592) DataCatalogTableProvider should not squash table components together into a string

[ https://issues.apache.org/jira/browse/BEAM-8592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8592: -- Status: Open (was: Triage Needed) > DataCatalogTableProvider should not squash table

[jira] [Updated] (BEAM-8456) Add pipeline option to control truncate of BigQuery data processed by Beam SQL

[ https://issues.apache.org/jira/browse/BEAM-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8456: -- Summary: Add pipeline option to control truncate of BigQuery data processed by Beam SQL (was:

[jira] [Resolved] (BEAM-8456) Add pipeline option to control truncate of BigQuery data processed by Beam SQL

[ https://issues.apache.org/jira/browse/BEAM-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-8456. --- Fix Version/s: 2.18.0 Resolution: Fixed > Add pipeline option to control truncate of

[jira] [Updated] (BEAM-8591) Exception is thrown when running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Gong updated BEAM-8591: - Description: h2. Setup Clusters * Setup Local Flink Cluster: 

[jira] [Updated] (BEAM-8591) Exception is thrown when running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Gong updated BEAM-8591: - Description: h2. Setup Clusters   * Setup Local Flink Cluster: 

[jira] [Updated] (BEAM-8591) Exception is thrown when running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Gong updated BEAM-8591: - Description: h2. Setup Clusters   * Setup Local Flink Cluster: 

[jira] [Updated] (BEAM-8591) Exception is thrown when running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Gong updated BEAM-8591: - Description: h2. Setup Clusters   * Setup Local Flink Cluster: 

[jira] [Updated] (BEAM-8591) Exception is thrown when running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Gong updated BEAM-8591: - Description: # Apache Beam and Flink Walkthrough Test ## Setup Clusters 1. Setup Local Flink

[jira] [Updated] (BEAM-8591) Exception is thrown when running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Gong updated BEAM-8591: - Description: # h2. Setup Clusters # Setup Local Flink Cluster: 

[jira] [Created] (BEAM-8591) Exception is thrown when running Beam Pipeline on Kubernetes Flink Cluster.

Mingliang Gong created BEAM-8591: Summary: Exception is thrown when running Beam Pipeline on Kubernetes Flink Cluster. Key: BEAM-8591 URL: https://issues.apache.org/jira/browse/BEAM-8591 Project:

[jira] [Updated] (BEAM-8590) Python typehints: native types: consider bare container types as containing Any

[ https://issues.apache.org/jira/browse/BEAM-8590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-8590: Status: Open (was: Triage Needed) > Python typehints: native types: consider bare container types as

[jira] [Created] (BEAM-8590) Python typehints: native types: consider bare container types as containing Any

Udi Meiri created BEAM-8590: --- Summary: Python typehints: native types: consider bare container types as containing Any Key: BEAM-8590 URL: https://issues.apache.org/jira/browse/BEAM-8590 Project: Beam

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

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

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

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

[jira] [Assigned] (BEAM-8588) MapTuple(fn) fails if fn has type hints but no default args

[ https://issues.apache.org/jira/browse/BEAM-8588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri reassigned BEAM-8588: --- Assignee: (was: Udi Meiri) > MapTuple(fn) fails if fn has type hints but no default args >

[jira] [Created] (BEAM-8589) Add instrumentation to portable runner to print pipeline proto and options when logging level is set to Debug.

Valentyn Tymofieiev created BEAM-8589: - Summary: Add instrumentation to portable runner to print pipeline proto and options when logging level is set to Debug. Key: BEAM-8589 URL:

[jira] [Commented] (BEAM-8588) MapTuple(fn) fails if fn has type hints but no default args

[ https://issues.apache.org/jira/browse/BEAM-8588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969702#comment-16969702 ] Udi Meiri commented on BEAM-8588: - [~robertwb] I'm leaving this unassigned for now. > MapTuple(fn) fails

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

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

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

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

[jira] [Commented] (BEAM-8588) MapTuple(fn) fails if fn has type hints but no default args

[ https://issues.apache.org/jira/browse/BEAM-8588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969696#comment-16969696 ] Udi Meiri commented on BEAM-8588: - For this example: {code} def fn(element1: int, element2: int, side1:

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

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

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

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

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

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

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

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

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

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

[jira] [Commented] (BEAM-8588) MapTuple(fn) fails if fn has type hints but no default args

[ https://issues.apache.org/jira/browse/BEAM-8588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969686#comment-16969686 ] Udi Meiri commented on BEAM-8588: - One subtlety here is that it seems that the correct type hint for the

[jira] [Created] (BEAM-8588) MapTuple(fn) fails if fn has type hints but no default args

Udi Meiri created BEAM-8588: --- Summary: MapTuple(fn) fails if fn has type hints but no default args Key: BEAM-8588 URL: https://issues.apache.org/jira/browse/BEAM-8588 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-8581) Python SDK labels ontime empty panes as late

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

[jira] [Work logged] (BEAM-8581) Python SDK labels ontime empty panes as late

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

[jira] [Updated] (BEAM-8273) Improve worker script for environment_type=PROCESS

[ https://issues.apache.org/jira/browse/BEAM-8273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8273: -- Description: When environment_type=PROCESS, environment_config specifies the command to run the worker

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

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

[jira] [Resolved] (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 resolved BEAM-8521. --- Resolution: Fixed > beam_PostCommit_XVR_Flink failing > - > >

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

[ https://issues.apache.org/jira/browse/BEAM-8534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-8534. --- Fix Version/s: Not applicable Resolution: Fixed > XlangParquetIOTest failing >

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

[ https://issues.apache.org/jira/browse/BEAM-8534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969668#comment-16969668 ] Kyle Weaver commented on BEAM-8534: --- Fixed by [https://github.com/apache/beam/pull/10017]. 

[jira] [Commented] (BEAM-8298) Implement state caching for side inputs

[ https://issues.apache.org/jira/browse/BEAM-8298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969667#comment-16969667 ] Jing Chen commented on BEAM-8298: - [~mxm] would you mind sharing details on the issue? I am kinda

[jira] [Resolved] (BEAM-8570) Use SDK version in default Java container tag

[ https://issues.apache.org/jira/browse/BEAM-8570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-8570. --- Fix Version/s: 2.18.0 Resolution: Fixed > Use SDK version in default Java container tag >

[jira] [Resolved] (BEAM-8294) Spark portable validates runner tests timing out

[ https://issues.apache.org/jira/browse/BEAM-8294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-8294. --- Fix Version/s: Not applicable Resolution: Fixed > Spark portable validates runner tests timing

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Commented] (BEAM-8561) Add ThriftIO to Support IO for Thrift Files

[ https://issues.apache.org/jira/browse/BEAM-8561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969660#comment-16969660 ] Chris Larsen commented on BEAM-8561: [~jkff] definitely, will do :) > Add ThriftIO to Support IO for

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

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

[jira] [Work logged] (BEAM-8570) Use SDK version in default Java container tag

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

[jira] [Work logged] (BEAM-876) Support schemaUpdateOption in BigQueryIO

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

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

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

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

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

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

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

[jira] [Updated] (BEAM-8583) [SQL] BigQuery should support predicate push-down in DIRECT_READ mode

[ https://issues.apache.org/jira/browse/BEAM-8583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirill Kozlov updated BEAM-8583: Description: * Add BigQuery Dialect with TypeTranslation (since it is not implemented in Calcite

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

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

[jira] [Work logged] (BEAM-8294) Spark portable validates runner tests timing out

[ https://issues.apache.org/jira/browse/BEAM-8294?focusedWorklogId=340220=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-340220 ] ASF GitHub Bot logged work on BEAM-8294: 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=340219=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-340219 ] 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=340218=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-340218 ] 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=340216=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-340216 ] ASF GitHub Bot logged work on BEAM-8508: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-8418) Fix handling of Impulse transform in Dataflow runner.

[ https://issues.apache.org/jira/browse/BEAM-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969621#comment-16969621 ] Valentyn Tymofieiev commented on BEAM-8418: --- For anyone following this, the issues is fixed in

[jira] [Created] (BEAM-8587) Add TestStream support for Dataflow runner

Andrew Crites created BEAM-8587: --- Summary: Add TestStream support for Dataflow runner Key: BEAM-8587 URL: https://issues.apache.org/jira/browse/BEAM-8587 Project: Beam Issue Type: Improvement

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

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

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

[jira] [Closed] (BEAM-8574) [SQL] MongoDb PostCommit_SQL fails

[ https://issues.apache.org/jira/browse/BEAM-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirill Kozlov closed BEAM-8574. --- Fix Version/s: 2.18.0 Resolution: Resolved > [SQL] MongoDb PostCommit_SQL fails >

[jira] [Work logged] (BEAM-8585) Include path in error message in path_to_beam_jar

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

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

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

[jira] [Updated] (BEAM-8585) Include path in error message in path_to_beam_jar

[ https://issues.apache.org/jira/browse/BEAM-8585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8585: -- Priority: Trivial (was: Minor) > Include path in error message in path_to_beam_jar >

[jira] [Created] (BEAM-8586) Add a server for MongoDb Integration Test

Kirill Kozlov created BEAM-8586: --- Summary: Add a server for MongoDb Integration Test Key: BEAM-8586 URL: https://issues.apache.org/jira/browse/BEAM-8586 Project: Beam Issue Type: Test

[jira] [Updated] (BEAM-8585) Include path in error message in path_to_beam_jar

[ https://issues.apache.org/jira/browse/BEAM-8585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8585: -- Status: Open (was: Triage Needed) > Include path in error message in path_to_beam_jar >

[jira] [Created] (BEAM-8585) Include path in error message in path_to_beam_jar

Kyle Weaver created BEAM-8585: - Summary: Include path in error message in path_to_beam_jar Key: BEAM-8585 URL: https://issues.apache.org/jira/browse/BEAM-8585 Project: Beam Issue Type:

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

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

[jira] [Created] (BEAM-8584) Remove TestPipelineOptions

Brian Hulette created BEAM-8584: --- Summary: Remove TestPipelineOptions Key: BEAM-8584 URL: https://issues.apache.org/jira/browse/BEAM-8584 Project: Beam Issue Type: Improvement

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

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

[jira] [Closed] (BEAM-6274) Timer Backlog Bug

[ https://issues.apache.org/jira/browse/BEAM-6274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Rohde closed BEAM-6274. --- Fix Version/s: Not applicable Resolution: Won't Fix > Timer Backlog Bug > - > >

[jira] [Assigned] (BEAM-6453) Create a single Jenkins job or Gradle task to serve for release test validation

[ https://issues.apache.org/jira/browse/BEAM-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Rohde reassigned BEAM-6453: --- Assignee: (was: Sam Rohde) > Create a single Jenkins job or Gradle task to serve for release

[jira] [Assigned] (BEAM-6672) Make bundle execution with ExecutableStage support user states

[ https://issues.apache.org/jira/browse/BEAM-6672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Rohde reassigned BEAM-6672: --- Assignee: (was: Sam Rohde) > Make bundle execution with ExecutableStage support user states >

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

[ https://issues.apache.org/jira/browse/BEAM-8491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Rohde resolved BEAM-8491. - Fix Version/s: 2.16.0 Resolution: Fixed > Add ability for multiple output PCollections from

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

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

[jira] [Created] (BEAM-8583) [SQL] BigQuery should support predicate push-down in DIRECT_READ mode

Kirill Kozlov created BEAM-8583: --- Summary: [SQL] BigQuery should support predicate push-down in DIRECT_READ mode Key: BEAM-8583 URL: https://issues.apache.org/jira/browse/BEAM-8583 Project: Beam

[jira] [Created] (BEAM-8582) Python SDK emits duplicate records for Default and AfterWatermark triggers

Sam Rohde created BEAM-8582: --- Summary: Python SDK emits duplicate records for Default and AfterWatermark triggers Key: BEAM-8582 URL: https://issues.apache.org/jira/browse/BEAM-8582 Project: Beam

[jira] [Created] (BEAM-8581) Python SDK labels ontime empty panes as late

Sam Rohde created BEAM-8581: --- Summary: Python SDK labels ontime empty panes as late Key: BEAM-8581 URL: https://issues.apache.org/jira/browse/BEAM-8581 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-8580) Request Python API to support windows ClosingBehavior

wendy liu created BEAM-8580: --- Summary: Request Python API to support windows ClosingBehavior Key: BEAM-8580 URL: https://issues.apache.org/jira/browse/BEAM-8580 Project: Beam Issue Type: New

[jira] [Work logged] (BEAM-8559) Run Dataflow Nexmark suites with Java 11

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

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

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

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

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

[jira] [Work logged] (BEAM-8559) Run Dataflow Nexmark suites with Java 11

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

[jira] [Work logged] (BEAM-8559) Run Dataflow Nexmark suites with Java 11

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

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

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

[jira] [Work logged] (BEAM-8559) Run Dataflow Nexmark suites with Java 11

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

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

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

  1   2   3   >