[jira] [Work logged] (BEAM-14101) [CdapIO] Design and implement Spark Receiver Builder

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

[jira] [Work logged] (BEAM-14101) [CdapIO] Design and implement Spark Receiver Builder

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

[jira] [Work logged] (BEAM-14101) [CdapIO] Design and implement Spark Receiver Builder

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

[jira] [Work logged] (BEAM-14101) [CdapIO] Design and implement Spark Receiver Builder

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

[jira] [Updated] (BEAM-14070) Beam worker closing gRPC connection with many workers and large shuffle sizes

[ https://issues.apache.org/jira/browse/BEAM-14070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Janek Bevendorff updated BEAM-14070: Labels: (was: stale-P2) > Beam worker closing gRPC connection with many workers and large

[jira] [Updated] (BEAM-14080) Portable runner does not return job exit status to client after long-running job

[ https://issues.apache.org/jira/browse/BEAM-14080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Janek Bevendorff updated BEAM-14080: Labels: (was: stale-P2) > Portable runner does not return job exit status to client after

[jira] [Updated] (BEAM-13669) Install Python wheel and dependencies to local venv in SDK harness

[ https://issues.apache.org/jira/browse/BEAM-13669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Janek Bevendorff updated BEAM-13669: Priority: P1 (was: P2) > Install Python wheel and dependencies to local venv in SDK harnes

[jira] [Work logged] (BEAM-12792) Multiple jobs running on Flink session cluster reuse the persistent Python environment.

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

[jira] [Commented] (BEAM-11998) Portable runners should be able to issue checkpoints to Splittable DoFn

[ https://issues.apache.org/jira/browse/BEAM-11998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541396#comment-17541396 ] Abhinav Jha commented on BEAM-11998: I am also facing the same issue. While running i

[jira] [Work logged] (BEAM-13532) Pubsub-IO dynamic destination

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

[jira] [Work logged] (BEAM-14000) Elastic search IO doesnot work when both username/password and keystore are used

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

[jira] [Work logged] (BEAM-14442) Create issue templates for common scenarios

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

[jira] [Commented] (BEAM-5336) Support for a Dask runner

[ https://issues.apache.org/jira/browse/BEAM-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541472#comment-17541472 ] Ryan Abernathey commented on BEAM-5336: --- (y) to a Dask runner for Beam. What would b

[jira] [Work logged] (BEAM-14315) Update fileio.MatchContinuously to allow reading already read files with a new timestamp

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

[jira] [Work logged] (BEAM-9324) Python SDK Incompatibility with Cython

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

[jira] [Updated] (BEAM-14205) [Playground] Tests for app states

[ https://issues.apache.org/jira/browse/BEAM-14205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Zhuravlev updated BEAM-14205: --- Fix Version/s: Not applicable Resolution: Fixed Status: Resolved (w

[jira] [Work started] (BEAM-14203) [Playground] Improve test coverage of the frontend part

[ https://issues.apache.org/jira/browse/BEAM-14203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-14203 started by null. --- > [Playground] Improve test coverage of the frontend part > --

[jira] [Updated] (BEAM-14204) [Playground] Tests for example repository

[ https://issues.apache.org/jira/browse/BEAM-14204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Zhuravlev updated BEAM-14204: --- Fix Version/s: Not applicable Resolution: Fixed Status: Resolved (w

[jira] [Updated] (BEAM-14203) [Playground] Improve test coverage of the frontend part

[ https://issues.apache.org/jira/browse/BEAM-14203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Zhuravlev updated BEAM-14203: --- Fix Version/s: Not applicable Resolution: Fixed Status: Resolved (w

[jira] [Created] (BEAM-14503) Support Flink 1.15

Julien Tournay created BEAM-14503: - Summary: Support Flink 1.15 Key: BEAM-14503 URL: https://issues.apache.org/jira/browse/BEAM-14503 Project: Beam Issue Type: Improvement Component

[jira] [Work logged] (BEAM-14503) Support Flink 1.15

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

[jira] [Work logged] (BEAM-14503) Support Flink 1.15

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

[jira] [Work logged] (BEAM-14503) Support Flink 1.15

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

[jira] [Work logged] (BEAM-14503) Support Flink 1.15

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

[jira] [Work logged] (BEAM-14503) Support Flink 1.15

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

[jira] [Updated] (BEAM-12308) CrossLanguageKafkaIOTest.test_kafkaio flake

[ https://issues.apache.org/jira/browse/BEAM-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-12308: --- Labels: flake (was: ) > CrossLanguageKafkaIOTest.test_kafkaio flake > --

[jira] [Updated] (BEAM-14504) Add support for including addittional parameters to executebundle method in fhirio.

[ https://issues.apache.org/jira/browse/BEAM-14504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-14504: - Status: Open (was: Triage Needed) > Add support for including addittional parameters to executeb

[jira] [Created] (BEAM-14504) Add support for including addittional parameters to executebundle method in fhirio.

Fathima Mohammed created BEAM-14504: --- Summary: Add support for including addittional parameters to executebundle method in fhirio. Key: BEAM-14504 URL: https://issues.apache.org/jira/browse/BEAM-14504

[jira] [Reopened] (BEAM-12308) CrossLanguageKafkaIOTest.test_kafkaio flake

[ https://issues.apache.org/jira/browse/BEAM-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev reopened BEAM-12308: Assignee: John Casey > CrossLanguageKafkaIOTest.test_kafkaio flake > --

[jira] [Commented] (BEAM-12308) CrossLanguageKafkaIOTest.test_kafkaio flake

[ https://issues.apache.org/jira/browse/BEAM-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541493#comment-17541493 ] Valentyn Tymofieiev commented on BEAM-12308: Kafka tests are currently permar

[jira] [Updated] (BEAM-12308) CrossLanguageKafkaIOTest.test_kafkaio flake

[ https://issues.apache.org/jira/browse/BEAM-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-12308: --- Status: Open (was: Triage Needed) > CrossLanguageKafkaIOTest.test_kafkaio flake > --

[jira] [Work logged] (BEAM-12308) CrossLanguageKafkaIOTest.test_kafkaio flake

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

[jira] [Work logged] (BEAM-12308) CrossLanguageKafkaIOTest.test_kafkaio flake

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

[jira] [Work logged] (BEAM-12308) CrossLanguageKafkaIOTest.test_kafkaio flake

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

[jira] [Work logged] (BEAM-14503) Support Flink 1.15

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

[jira] [Work logged] (BEAM-14504) Add support for including addittional parameters to executebundle method in fhirio.

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

[jira] [Work logged] (BEAM-14004) [CosmosDB] com.mongodb.MongoCommandException: Command failed with error 115: Command is not supported

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

[jira] [Work logged] (BEAM-14504) Add support for including addittional parameters to executebundle method in fhirio.

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

[jira] [Work logged] (BEAM-14504) Add support for including addittional parameters to executebundle method in fhirio.

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

[jira] [Work logged] (BEAM-12308) CrossLanguageKafkaIOTest.test_kafkaio flake

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

[jira] [Work logged] (BEAM-12308) CrossLanguageKafkaIOTest.test_kafkaio flake

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

[jira] [Updated] (BEAM-14485) Modify offsetrange RTracker to behave properly in the self-checkpointing case

[ https://issues.apache.org/jira/browse/BEAM-14485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jack McCluskey updated BEAM-14485: -- Fix Version/s: 2.40.0 Resolution: Not A Problem Status: Resolved (was: Open)

[jira] [Work logged] (BEAM-14053) [CdapIO] Design and implement generic plugin class

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

[jira] [Reopened] (BEAM-14297) Enable null key and value for metadata kafka xlang

[ https://issues.apache.org/jira/browse/BEAM-14297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Casey reopened BEAM-14297: --- > Enable null key and value for metadata kafka xlang > --

[jira] [Work logged] (BEAM-14297) Enable null key and value for metadata kafka xlang

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

[jira] [Work logged] (BEAM-14297) Enable null key and value for metadata kafka xlang

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

[jira] [Work logged] (BEAM-14297) Enable null key and value for metadata kafka xlang

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

[jira] [Work logged] (BEAM-14297) Enable null key and value for metadata kafka xlang

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

[jira] [Work logged] (BEAM-14297) Enable null key and value for metadata kafka xlang

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

[jira] [Work logged] (BEAM-14297) Enable null key and value for metadata kafka xlang

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

[jira] [Work logged] (BEAM-14298) Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde

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

[jira] [Work logged] (BEAM-3221) Model pipeline representation improvements

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

[jira] [Updated] (BEAM-14298) Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde

[ https://issues.apache.org/jira/browse/BEAM-14298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-14298: - Fix Version/s: Not applicable Assignee: Yi Hu (was: Kenneth Knowles) Resolution: Fixed

[jira] [Work logged] (BEAM-14129) Fix issues with Pub/Sub Lite IO at high volumes

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

[jira] [Work logged] (BEAM-14496) PrecombineGroupingTable not inheriting a values output

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

[jira] [Commented] (BEAM-9337) DataflowPipelineJob.waitUntilFinish() crashes when it has created a template.

[ https://issues.apache.org/jira/browse/BEAM-9337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541593#comment-17541593 ] Djane Luz commented on BEAM-9337: - Any updates on that? > DataflowPipelineJob.waitUntilFi

[jira] [Work logged] (BEAM-9324) Python SDK Incompatibility with Cython

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

[jira] [Work logged] (BEAM-14471) Adding testcases and examples for xlang Python DataframeTransform

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

[jira] [Work logged] (BEAM-14471) Adding testcases and examples for xlang Python DataframeTransform

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

[jira] [Updated] (BEAM-14334) Avoid using forkEvery in Spark runner tests

[ https://issues.apache.org/jira/browse/BEAM-14334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moritz Mack updated BEAM-14334: --- Fix Version/s: 2.40.0 Resolution: Fixed Status: Resolved (was: Open) > Avoid using

[jira] [Updated] (BEAM-13174) Deprecate amazon-web-services & kinesis module (SDK v1)

[ https://issues.apache.org/jira/browse/BEAM-13174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moritz Mack updated BEAM-13174: --- Labels: aws-sdk-v1 (was: aws-sdk-v1 stale-assigned) > Deprecate amazon-web-services & kinesis module

[jira] [Updated] (BEAM-11653) MetricsSinkTest is failing with Spark 3

[ https://issues.apache.org/jira/browse/BEAM-11653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moritz Mack updated BEAM-11653: --- Fix Version/s: 2.40.0 Resolution: Fixed Status: Resolved (was: Open) > MetricsSink

[jira] [Updated] (BEAM-11653) MetricsSinkTest is failing with Spark 3

[ https://issues.apache.org/jira/browse/BEAM-11653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moritz Mack updated BEAM-11653: --- Labels: (was: stale-assigned) > MetricsSinkTest is failing with Spark 3 > -

[jira] [Work logged] (BEAM-14426) Allow skipping of any output when writing an empty PCollection.

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

[jira] [Commented] (BEAM-9324) Python SDK Incompatibility with Cython

[ https://issues.apache.org/jira/browse/BEAM-9324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541604#comment-17541604 ] Yi Hu commented on BEAM-9324: - This is due to Cython.Shadow.cast(Receiver, value) attempting t

[jira] [Work logged] (BEAM-9324) Python SDK Incompatibility with Cython

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

[jira] [Work logged] (BEAM-14053) [CdapIO] Design and implement generic plugin class

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

[jira] [Updated] (BEAM-14469) TestCheckpointing produces too many zero-length restrictions

[ https://issues.apache.org/jira/browse/BEAM-14469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jack McCluskey updated BEAM-14469: -- Fix Version/s: 2.40.0 Resolution: Fixed Status: Resolved (was: Open) > TestC

[jira] [Work logged] (BEAM-14502) Create separate BigtableIO reader that splits large scans into smaller segments

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

[jira] [Work logged] (BEAM-14502) Create separate BigtableIO reader that splits large scans into smaller segments

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

[jira] [Work logged] (BEAM-14502) Create separate BigtableIO reader that splits large scans into smaller segments

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

[jira] [Work logged] (BEAM-14502) Create separate BigtableIO reader that splits large scans into smaller segments

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

[jira] [Work logged] (BEAM-14170) Create a test that runs sickbayed tests

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

[jira] [Commented] (BEAM-8218) Implement Apache PulsarIO

[ https://issues.apache.org/jira/browse/BEAM-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541619#comment-17541619 ] Marco Robles commented on BEAM-8218: Hi [~lokesh2922]  This connector is the first ver

[jira] [Comment Edited] (BEAM-10160) Add Apache Iceberg IO connector

[ https://issues.apache.org/jira/browse/BEAM-10160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530587#comment-17530587 ] Bruce Arctor edited comment on BEAM-10160 at 5/24/22 4:58 PM: -

[jira] [Work logged] (BEAM-14269) PulsarIOTest.testReadFromSimpleTopic is very flaky

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

[jira] [Work logged] (BEAM-14297) Enable null key and value for metadata kafka xlang

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

[jira] [Work logged] (BEAM-14297) Enable null key and value for metadata kafka xlang

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

[jira] [Work logged] (BEAM-14502) Create separate BigtableIO reader that splits large scans into smaller segments

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

[jira] [Commented] (BEAM-14127) Timers with same family ids in same stage (but different transforms) are buffered together

[ https://issues.apache.org/jira/browse/BEAM-14127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541630#comment-17541630 ] Beam JIRA Bot commented on BEAM-14127: -- This issue is P2 but has been unassigned wit

[jira] [Updated] (BEAM-14114) Parsing datetime string with 0 to 6 decimal points for BigQuery

[ https://issues.apache.org/jira/browse/BEAM-14114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-14114: - Labels: stale-P2 (was: ) > Parsing datetime string with 0 to 6 decimal points for BigQuery > ---

[jira] [Updated] (BEAM-14127) Timers with same family ids in same stage (but different transforms) are buffered together

[ https://issues.apache.org/jira/browse/BEAM-14127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-14127: - Labels: stale-P2 (was: ) > Timers with same family ids in same stage (but different transforms)

[jira] [Commented] (BEAM-14114) Parsing datetime string with 0 to 6 decimal points for BigQuery

[ https://issues.apache.org/jira/browse/BEAM-14114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541629#comment-17541629 ] Beam JIRA Bot commented on BEAM-14114: -- This issue is P2 but has been unassigned wit

[jira] [Commented] (BEAM-11648) Implement new BigQuery sink (Vortex)

[ https://issues.apache.org/jira/browse/BEAM-11648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541632#comment-17541632 ] Beam JIRA Bot commented on BEAM-11648: -- This issue was marked "stale-P2" and has not

[jira] [Updated] (BEAM-11648) Implement new BigQuery sink (Vortex)

[ https://issues.apache.org/jira/browse/BEAM-11648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-11648: - Labels: (was: stale-P2) > Implement new BigQuery sink (Vortex) > --

[jira] [Commented] (BEAM-14067) Beam Core IO: WriteFiles stuck

[ https://issues.apache.org/jira/browse/BEAM-14067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541631#comment-17541631 ] Beam JIRA Bot commented on BEAM-14067: -- This issue was marked "stale-P2" and has not

[jira] [Updated] (BEAM-11648) Implement new BigQuery sink (Vortex)

[ https://issues.apache.org/jira/browse/BEAM-11648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-11648: - Priority: P3 (was: P2) > Implement new BigQuery sink (Vortex) >

[jira] [Updated] (BEAM-14067) Beam Core IO: WriteFiles stuck

[ https://issues.apache.org/jira/browse/BEAM-14067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-14067: - Labels: (was: stale-P2) > Beam Core IO: WriteFiles stuck > -- > >

[jira] [Work logged] (BEAM-14471) Adding testcases and examples for xlang Python DataframeTransform

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

[jira] [Updated] (BEAM-14067) Beam Core IO: WriteFiles stuck

[ https://issues.apache.org/jira/browse/BEAM-14067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-14067: - Priority: P3 (was: P2) > Beam Core IO: WriteFiles stuck > -- > >

[jira] [Work logged] (BEAM-14504) Add support for including addittional parameters to executebundle method in fhirio.

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

[jira] [Commented] (BEAM-14482) Mismatch in event publish_time

[ https://issues.apache.org/jira/browse/BEAM-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541639#comment-17541639 ] Daljeet Singh commented on BEAM-14482: -- ok, let me try this and will post the result

[jira] [Work logged] (BEAM-14475) Add exception test cases to GcsFileSystem

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

[jira] [Work logged] (BEAM-14471) Adding testcases and examples for xlang Python DataframeTransform

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

[jira] [Work logged] (BEAM-14129) Fix issues with Pub/Sub Lite IO at high volumes

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

[jira] [Work logged] (BEAM-3221) Model pipeline representation improvements

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

[jira] [Work logged] (BEAM-14496) PrecombineGroupingTable not inheriting a values output

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

[jira] [Work logged] (BEAM-14471) Adding testcases and examples for xlang Python DataframeTransform

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

[jira] [Work logged] (BEAM-14471) Adding testcases and examples for xlang Python DataframeTransform

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

[jira] [Work logged] (BEAM-14053) [CdapIO] Design and implement generic plugin class

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

  1   2   >