[jira] [Commented] (BEAM-12544) Add support for Avro timestamps in microseconds

[ https://issues.apache.org/jira/browse/BEAM-12544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474332#comment-17474332 ] Tobias Hermann commented on BEAM-12544: --- [~kenn] No, the pull request did not resol

[jira] [Work logged] (BEAM-13544) [Playground] Add logs to examples CI/CD to see the progress

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

[jira] [Work logged] (BEAM-13398) [Playground] Split LifeCycle to DTO and business logic

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

[jira] [Work logged] (BEAM-13398) [Playground] Split LifeCycle to DTO and business logic

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

[jira] [Work logged] (BEAM-13544) [Playground] Add logs to examples CI/CD to see the progress

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

[jira] [Work logged] (BEAM-13398) [Playground] Split LifeCycle to DTO and business logic

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

[jira] [Work logged] (BEAM-13398) [Playground] Split LifeCycle to DTO and business logic

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

[jira] [Work logged] (BEAM-13398) [Playground] Split LifeCycle to DTO and business logic

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

[jira] [Work logged] (BEAM-13398) [Playground] Split LifeCycle to DTO and business logic

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

[jira] [Work logged] (BEAM-13398) [Playground] Split LifeCycle to DTO and business logic

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

[jira] [Commented] (BEAM-13567) [Playground] Add using of GetPreparationOutput in case of PreparationError

[ https://issues.apache.org/jira/browse/BEAM-13567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474318#comment-17474318 ] Aydar Zaynutdinov commented on BEAM-13567: -- [~kenn] attached pull request is not

[jira] [Updated] (BEAM-13604) NPE while getting null from BigDecimal column

[ https://issues.apache.org/jira/browse/BEAM-13604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Ivanov updated BEAM-13604: - Fix Version/s: 2.35.0 Resolution: Fixed Status: Resolved (was: Triage Needed)

[jira] [Work logged] (BEAM-13616) Update protobuf-java to 3.19.2 and other vendored dependencies that use protobuf

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

[jira] [Updated] (BEAM-13524) ParDo comment is grammatically incorrect and ambiguous.

[ https://issues.apache.org/jira/browse/BEAM-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David updated BEAM-13524: - Resolution: Fixed Status: Resolved (was: Triage Needed) > ParDo comment is grammatically incorrect and a

[jira] [Updated] (BEAM-13604) NPE while getting null from BigDecimal column

[ https://issues.apache.org/jira/browse/BEAM-13604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Ivanov updated BEAM-13604: - Fix Version/s: 2.36.0 (was: 2.35.0) > NPE while getting null from BigDecim

[jira] [Reopened] (BEAM-13609) Not all variable length types works properly for Oracle DB

[ https://issues.apache.org/jira/browse/BEAM-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Ivanov reopened BEAM-13609: -- > Not all variable length types works properly for Oracle DB >

[jira] [Updated] (BEAM-13269) Data exceeds database column capacity error while inserting in fixed length string column

[ https://issues.apache.org/jira/browse/BEAM-13269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Ivanov updated BEAM-13269: - Fix Version/s: 2.35.0 Resolution: Fixed Status: Resolved (was: Triage Needed)

[jira] [Updated] (BEAM-13609) Not all variable length types works properly for Oracle DB

[ https://issues.apache.org/jira/browse/BEAM-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Ivanov updated BEAM-13609: - Fix Version/s: (was: 2.36.0) > Not all variable length types works properly for Oracle DB > -

[jira] [Updated] (BEAM-13609) Not all variable length types works properly for Oracle DB

[ https://issues.apache.org/jira/browse/BEAM-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Ivanov updated BEAM-13609: - Fix Version/s: 2.36.0 Resolution: Fixed Status: Resolved (was: Triage Needed)

[jira] [Assigned] (BEAM-13609) Not all variable length types works properly for Oracle DB

[ https://issues.apache.org/jira/browse/BEAM-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Ivanov reassigned BEAM-13609: Assignee: Vitaly Ivanov > Not all variable length types works properly for Oracle DB > ---

[jira] [Commented] (BEAM-12824) Beam Connector for Reading Data from Delta Lake

[ https://issues.apache.org/jira/browse/BEAM-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474279#comment-17474279 ] Michael commented on BEAM-12824: One thing that is left is to convert pom.xml to build.gr

[jira] [Updated] (BEAM-8191) Multiple Flatten.pCollections() transforms generate an overwhelming number of tasks

[ https://issues.apache.org/jira/browse/BEAM-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Backx updated BEAM-8191: -- Resolution: Won't Do Status: Resolved (was: Open) See my previous comment. > Multiple Flatten.

[jira] [Comment Edited] (BEAM-8191) Multiple Flatten.pCollections() transforms generate an overwhelming number of tasks

[ https://issues.apache.org/jira/browse/BEAM-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474276#comment-17474276 ] Peter Backx edited comment on BEAM-8191 at 1/12/22, 6:34 AM: -

[jira] [Commented] (BEAM-8191) Multiple Flatten.pCollections() transforms generate an overwhelming number of tasks

[ https://issues.apache.org/jira/browse/BEAM-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474276#comment-17474276 ] Peter Backx commented on BEAM-8191: --- Hi Kenneth, the pull request was never merged so th

[jira] [Updated] (BEAM-11832) Time correction by NTP sync can skew metrics

[ https://issues.apache.org/jira/browse/BEAM-11832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Minbo Bae updated BEAM-11832: - Resolution: Fixed Status: Resolved (was: Open) > Time correction by NTP sync can skew metrics >

[jira] [Updated] (BEAM-12504) SpannerIO Read SessionNotFoundException for long-running pipline

[ https://issues.apache.org/jira/browse/BEAM-12504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Minbo Bae updated BEAM-12504: - Resolution: Fixed Status: Resolved (was: Triage Needed) > SpannerIO Read SessionNotFoundExceptio

[jira] [Updated] (BEAM-12751) Python DataflowRunner doesn't set client_request_id

[ https://issues.apache.org/jira/browse/BEAM-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Minbo Bae updated BEAM-12751: - Resolution: Fixed Status: Resolved (was: Open) > Python DataflowRunner doesn't set client_reques

[jira] [Updated] (BEAM-4645) Docker images not cleaned up when run_validatescontainer.sh fails

[ https://issues.apache.org/jira/browse/BEAM-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Myrvold updated BEAM-4645: --- Resolution: Fixed Status: Resolved (was: Open) > Docker images not cleaned up when run_valida

[jira] [Updated] (BEAM-6197) Log time for Dataflow GCS upload of staged files

[ https://issues.apache.org/jira/browse/BEAM-6197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Myrvold updated BEAM-6197: --- Resolution: Fixed Status: Resolved (was: Open) > Log time for Dataflow GCS upload of staged f

[jira] [Commented] (BEAM-6197) Log time for Dataflow GCS upload of staged files

[ https://issues.apache.org/jira/browse/BEAM-6197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474263#comment-17474263 ] Alan Myrvold commented on BEAM-6197: Resolved > Log time for Dataflow GCS upload of s

[jira] [Commented] (BEAM-10900) stats.ApproximateUniqueCombineFn should handle numpy array

[ https://issues.apache.org/jira/browse/BEAM-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474252#comment-17474252 ] Monica Song commented on BEAM-10900: No, the pull request did not resolve the issue. 

[jira] [Commented] (BEAM-13589) Fixing typos

[ https://issues.apache.org/jira/browse/BEAM-13589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474241#comment-17474241 ] Martin Blais commented on BEAM-13589: - Hi Ken. I made the pull request. > Fixing ty

[jira] [Work logged] (BEAM-13321) [Cross-Language] Externalize a minimal Implementation of Java's BigQuery IO

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

[jira] [Work logged] (BEAM-13321) [Cross-Language] Externalize a minimal Implementation of Java's BigQuery IO

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

[jira] [Updated] (BEAM-13638) SqsMessage class have package private access for getters

[ https://issues.apache.org/jira/browse/BEAM-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bala barath updated BEAM-13638: --- Affects Version/s: 2.34.0 > SqsMessage class have package private access for getters > --

[jira] [Commented] (BEAM-13321) [Cross-Language] Externalize a minimal Implementation of Java's BigQuery IO

[ https://issues.apache.org/jira/browse/BEAM-13321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474236#comment-17474236 ] Daniel Oliveira commented on BEAM-13321: It doesn't, there's still some additiona

[jira] [Updated] (BEAM-9624) Combine operation should support only converting to accumulators

[ https://issues.apache.org/jira/browse/BEAM-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-9624: Resolution: Fixed Status: Resolved (was: Open) > Combine operation should support only converting t

[jira] [Assigned] (BEAM-9624) Combine operation should support only converting to accumulators

[ https://issues.apache.org/jira/browse/BEAM-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-9624: --- Assignee: Andrew Crites > Combine operation should support only converting to accumulators >

[jira] [Updated] (BEAM-2354) Add streaming support to Python DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2354: Resolution: Fixed Status: Resolved (was: Open) This is supported by Dataflow prime. > Add streamin

[jira] [Created] (BEAM-13638) SqsMessage class have package private access for getters

bala barath created BEAM-13638: -- Summary: SqsMessage class have package private access for getters Key: BEAM-13638 URL: https://issues.apache.org/jira/browse/BEAM-13638 Project: Beam Issue Type:

[jira] [Updated] (BEAM-3020) Model MultimapUserState

[ https://issues.apache.org/jira/browse/BEAM-3020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-3020: Assignee: Luke Cwik Resolution: Fixed Status: Resolved (was: Open) Was done a while ago. > M

[jira] [Updated] (BEAM-6299) Update JUnit to fix incompatibility between parameterized tests and include categories

[ https://issues.apache.org/jira/browse/BEAM-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-6299: - Resolution: Fixed Status: Resolved (was: Open) > Update JUnit to fix incompatibility between para

[jira] [Updated] (BEAM-12579) Deduplicate expiry timer shouldn't hold back the watermark

[ https://issues.apache.org/jira/browse/BEAM-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-12579: -- Resolution: Fixed Status: Resolved (was: Triage Needed) > Deduplicate expiry timer shouldn't h

[jira] [Updated] (BEAM-12720) GroupIntoBatches override incorrectly modifies variables after outputting them

[ https://issues.apache.org/jira/browse/BEAM-12720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-12720: -- Resolution: Fixed Status: Resolved (was: Triage Needed) > GroupIntoBatches override incorrectl

[jira] [Updated] (BEAM-13576) Update Beam GCS BOM to 24.1.1

[ https://issues.apache.org/jira/browse/BEAM-13576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-13576: -- Resolution: Fixed Status: Resolved (was: Triage Needed) > Update Beam GCS BOM to 24.1.1 >

[jira] [Updated] (BEAM-1438) The default behavior for the Write transform doesn't work well with the Dataflow streaming runner

[ https://issues.apache.org/jira/browse/BEAM-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-1438: - Resolution: Fixed Status: Resolved (was: Open) > The default behavior for the Write transform doe

[jira] [Updated] (BEAM-9370) ParDoSchemaTests fail when run with Java 11 on Flink 1.10

[ https://issues.apache.org/jira/browse/BEAM-9370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-9370: - Resolution: Fixed Status: Resolved (was: Open) > ParDoSchemaTests fail when run with Java 11 on F

[jira] [Updated] (BEAM-13617) StorageApi sink might try to reuse closed stream in batch mode and in STORAGE_API_AT_LEAST_ONCE mode

[ https://issues.apache.org/jira/browse/BEAM-13617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-13617: -- Resolution: Fixed Status: Resolved (was: Triage Needed) > StorageApi sink might try to reuse c

[jira] [Commented] (BEAM-9272) Remove obsolete SDF URNs

[ https://issues.apache.org/jira/browse/BEAM-9272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474231#comment-17474231 ] Luke Cwik commented on BEAM-9272: - These others are used to support non portable SDF expan

[jira] [Updated] (BEAM-7336) KafkaIO should support inferring schemas when reading Avro

[ https://issues.apache.org/jira/browse/BEAM-7336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-7336: - Resolution: Fixed Status: Resolved (was: Open) > KafkaIO should support inferring schemas when re

[jira] [Updated] (BEAM-2058) BigQuery load job id should be generated at run time, not submission time

[ https://issues.apache.org/jira/browse/BEAM-2058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-2058: - Resolution: Fixed Status: Resolved (was: Open) > BigQuery load job id should be generated at run

[jira] [Updated] (BEAM-3519) GCP IO exposes netty on its API surface, causing conflicts with runners

[ https://issues.apache.org/jira/browse/BEAM-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-3519: Assignee: Luke Cwik Resolution: Fixed Status: Resolved (was: Open) The usage of the GCP libra

[jira] [Updated] (BEAM-6953) BigQueryIO has constants that should be PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-6953: - Resolution: Fixed Status: Resolved (was: Open) > BigQueryIO has constants that should be Pipeline

[jira] [Updated] (BEAM-12686) Support self-managed relative timers

[ https://issues.apache.org/jira/browse/BEAM-12686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-12686: -- Resolution: Fixed Status: Resolved (was: Triage Needed) > Support self-managed relative timers

[jira] [Updated] (BEAM-13263) Support OnWindowExpiration in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-13263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-13263: -- Resolution: Fixed Status: Resolved (was: Triage Needed) > Support OnWindowExpiration in Flink

[jira] [Assigned] (BEAM-7246) Add Google Spanner IO on Python SDK

[ https://issues.apache.org/jira/browse/BEAM-7246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax reassigned BEAM-7246: Assignee: Chamikara Madhusanka Jayalath > Add Google Spanner IO on Python SDK > --

[jira] [Updated] (BEAM-10212) Add support for Java SDK harness state caching

[ https://issues.apache.org/jira/browse/BEAM-10212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-10212: - Fix Version/s: 2.36.0 Assignee: Luke Cwik Resolution: Fixed Status: Resolved (

[jira] [Commented] (BEAM-10212) Add support for Java SDK harness state caching

[ https://issues.apache.org/jira/browse/BEAM-10212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474228#comment-17474228 ] Luke Cwik commented on BEAM-10212: -- Most of the work happened under BEAM-13015 and this

[jira] [Commented] (BEAM-9309) Remove deprecated primitive beam:transform:read:v1 and beam_fn_api_use_deprecated_read experiment everywhere

[ https://issues.apache.org/jira/browse/BEAM-9309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474227#comment-17474227 ] Luke Cwik commented on BEAM-9309: - We still have this for Kafka and in some runners. > Re

[jira] [Updated] (BEAM-13352) Non serializable member variables not marked transient

[ https://issues.apache.org/jira/browse/BEAM-13352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-13352: -- Resolution: Fixed Status: Resolved (was: Triage Needed) > Non serializable member variables no

[jira] [Updated] (BEAM-6433) Clean up an untracked file generated by python doctest

[ https://issues.apache.org/jira/browse/BEAM-6433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kengo Seki updated BEAM-6433: - Assignee: Kengo Seki Resolution: Fixed Status: Resolved (was: Open) Sorry for forgetting to

[jira] [Commented] (BEAM-9397) new DoFn should allow injecting all parameters in StartBundleContext/FinishBundleContext

[ https://issues.apache.org/jira/browse/BEAM-9397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474225#comment-17474225 ] Luke Cwik commented on BEAM-9397: - Output receiver is the one that is still missing, PR 10

[jira] [Updated] (BEAM-10303) FnApiDoFnRunner window observing optimization

[ https://issues.apache.org/jira/browse/BEAM-10303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-10303: - Assignee: Luke Cwik Resolution: Fixed Status: Resolved (was: Open) This was fixed a while

[jira] [Commented] (BEAM-13580) Nexmark Query 14

[ https://issues.apache.org/jira/browse/BEAM-13580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474221#comment-17474221 ] Arun Pandian commented on BEAM-13580: - The pull request resolves it. Closing this. >

[jira] [Updated] (BEAM-898) BigQueryTornadoes IT has invalid PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-898: --- Resolution: Fixed Status: Resolved (was: Open) Resolved along time ago. > BigQueryTornadoes IT has in

[jira] [Updated] (BEAM-13580) Nexmark Query 14

[ https://issues.apache.org/jira/browse/BEAM-13580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Pandian updated BEAM-13580: Resolution: Fixed Status: Resolved (was: Triage Needed) > Nexmark Query 14 > -

[jira] [Updated] (BEAM-4948) Beam Dependency Update Request: com.google.guava

[ https://issues.apache.org/jira/browse/BEAM-4948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-4948: Resolution: Fixed Status: Resolved (was: Open) There have been a few upgrades. Will close and tooli

[jira] [Updated] (BEAM-10097) Migrate PCollection views to use both iterable and multimap materializations/access patterns

[ https://issues.apache.org/jira/browse/BEAM-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-10097: - Assignee: Luke Cwik Resolution: Fixed Status: Resolved (was: Open) > Migrate PCollection v

[jira] [Comment Edited] (BEAM-9543) BeamSQL Pattern Recognization Functionality

[ https://issues.apache.org/jira/browse/BEAM-9543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474217#comment-17474217 ] Qihang Zeng edited comment on BEAM-9543 at 1/12/22, 4:16 AM: -

[jira] [Commented] (BEAM-9543) BeamSQL Pattern Recognization Functionality

[ https://issues.apache.org/jira/browse/BEAM-9543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474217#comment-17474217 ] Qihang Zeng commented on BEAM-9543: --- This feature is only *partially* supported due to t

[jira] [Comment Edited] (BEAM-10283) BigtableIO doesn't support ValueProvider in withKeyRange and withRowFilter methods

[ https://issues.apache.org/jira/browse/BEAM-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474214#comment-17474214 ] Rafi Kamal edited comment on BEAM-10283 at 1/12/22, 4:13 AM: -

[jira] [Updated] (BEAM-11629) Optimize the cache storage for InteractiveRunner

[ https://issues.apache.org/jira/browse/BEAM-11629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Kozhevin updated BEAM-11629: --- Resolution: Won't Fix Status: Resolved (was: Open) It seems like this issue cannot q

[jira] [Updated] (BEAM-10283) BigtableIO doesn't support ValueProvider in withKeyRange and withRowFilter methods

[ https://issues.apache.org/jira/browse/BEAM-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafi Kamal updated BEAM-10283: -- Assignee: Rafi Kamal Resolution: Fixed Status: Resolved (was: Triage Needed) Fixed by th

[jira] [Updated] (BEAM-13626) Outdated Transform.Inputs values when chaining expanded transforms

[ https://issues.apache.org/jira/browse/BEAM-13626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tianyang Hu updated BEAM-13626: --- Resolution: Fixed Status: Resolved (was: Triage Needed) > Outdated Transform.Inputs values w

[jira] [Updated] (BEAM-5905) Beam Dependency Update Request: org.apache.qpid:qpid-broker-core

[ https://issues.apache.org/jira/browse/BEAM-5905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5905: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-4012) Suppress tracebacks on failure-catching tests

[ https://issues.apache.org/jira/browse/BEAM-4012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4012: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-9351) Upgrade Hive/HCatalog to version 2.3.8

[ https://issues.apache.org/jira/browse/BEAM-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9351: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-13193) Optional data embedding in Fn API control request and response

[ https://issues.apache.org/jira/browse/BEAM-13193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-13193: --- This Jira ticket has a pull request attached to it, but is still open. Did the pull request reso

[jira] [Updated] (BEAM-9689) Update wordcount webpage with Spark/Flink + Go

[ https://issues.apache.org/jira/browse/BEAM-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9689: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-1983) SDF should properly support windowed side inputs

[ https://issues.apache.org/jira/browse/BEAM-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1983: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-1263) Add Jenkins Suites for Performance Tests

[ https://issues.apache.org/jira/browse/BEAM-1263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1263: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-4855) Microbenchmarks for windowinto

[ https://issues.apache.org/jira/browse/BEAM-4855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4855: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-3606) Improve our relationship, or lack thereof, with Guava

[ https://issues.apache.org/jira/browse/BEAM-3606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3606: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-11663) Rework dependency structure of Spark job server jar

[ https://issues.apache.org/jira/browse/BEAM-11663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-11663: --- This Jira ticket has a pull request attached to it, but is still open. Did the pull request reso

[jira] [Updated] (BEAM-950) DoFn Setup and Teardown methods should have access to PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-950: - This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve th

[jira] [Updated] (BEAM-7490) TfIdfTest should not be marked ValidatesRunner

[ https://issues.apache.org/jira/browse/BEAM-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7490: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-12067) Beam Dependency Update Request: org.elasticsearch.client:elasticsearch-rest-high-level-client

[ https://issues.apache.org/jira/browse/BEAM-12067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-12067: --- This Jira ticket has a pull request attached to it, but is still open. Did the pull request reso

[jira] [Updated] (BEAM-9075) Join re-ordering doesn't work for ZetaSQL

[ https://issues.apache.org/jira/browse/BEAM-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9075: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-8191) Multiple Flatten.pCollections() transforms generate an overwhelming number of tasks

[ https://issues.apache.org/jira/browse/BEAM-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8191: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-12853) PubSubTableProvider tries to set windows after GroupByKey

[ https://issues.apache.org/jira/browse/BEAM-12853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-12853: --- This Jira ticket has a pull request attached to it, but is still open. Did the pull request reso

[jira] [Updated] (BEAM-10821) Add Python SDK typing changes to CHANGES.md

[ https://issues.apache.org/jira/browse/BEAM-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Saavan Nanavati updated BEAM-10821: --- Resolution: Fixed Status: Resolved (was: Open) > Add Python SDK typing changes to CH

[jira] [Updated] (BEAM-7072) SQL Delta JOIN

[ https://issues.apache.org/jira/browse/BEAM-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7072: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-2024) Python and Java SDKs differ on name of AfterCount

[ https://issues.apache.org/jira/browse/BEAM-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2024: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-3571) Validate Go SDK encodes values the same as other SDKs

[ https://issues.apache.org/jira/browse/BEAM-3571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3571: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-9371) Implement SideInput load test in Java

[ https://issues.apache.org/jira/browse/BEAM-9371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9371: -- This Jira ticket has a pull request attached to it, but is still open. Did the pull request resolve

[jira] [Updated] (BEAM-12811) [Website] Remove "They tried it out" block

[ https://issues.apache.org/jira/browse/BEAM-12811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-12811: --- This Jira ticket has a pull request attached to it, but is still open. Did the pull request reso

[jira] [Updated] (BEAM-13483) beam_PreCommit_Java_Examples_Dataflow is often timing out.

[ https://issues.apache.org/jira/browse/BEAM-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-13483: --- This Jira ticket has a pull request attached to it, but is still open. Did the pull request reso

[jira] [Updated] (BEAM-11358) Merge redundant metrics from nexmark monitors and remove unused monitor from endOfStreamMonitor

[ https://issues.apache.org/jira/browse/BEAM-11358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-11358: --- This Jira ticket has a pull request attached to it, but is still open. Did the pull request reso

[jira] [Updated] (BEAM-11818) A Beam transform that allows consuming change streams from Debezium without depending on Kafka

[ https://issues.apache.org/jira/browse/BEAM-11818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-11818: --- This Jira ticket has a pull request attached to it, but is still open. Did the pull request reso

[jira] [Updated] (BEAM-10940) Portable Flink runner should handle DelayedBundleApplication from ProcessBundleResponse.

[ https://issues.apache.org/jira/browse/BEAM-10940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10940: --- This Jira ticket has a pull request attached to it, but is still open. Did the pull request reso

  1   2   3   4   5   6   7   8   9   10   >