[jira] [Commented] (BEAM-7515) Support TestStream on the fn_api_runner

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

[jira] [Assigned] (BEAM-7189) Remove FieldType metadata

[ https://issues.apache.org/jira/browse/BEAM-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7189: --- Assignee: (was: Reuven Lax) > Remove FieldType metadata > - > >

[jira] [Updated] (BEAM-7242) Update release process to add support for pushing RCs to PyPI for testing.

[ https://issues.apache.org/jira/browse/BEAM-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7242: Labels: (was: stale-assigned) > Update release process to add support for pushing RCs to PyPI for

[jira] [Updated] (BEAM-7395) Check immutability violations in Dataflow Runner (as an option)

[ https://issues.apache.org/jira/browse/BEAM-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7395: Labels: newbie starter (was: newbie stale-assigned starter) > Check immutability violations in Data

[jira] [Updated] (BEAM-7702) Colab examples for element-wise transforms (Java)

[ https://issues.apache.org/jira/browse/BEAM-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7702: Labels: (was: stale-assigned) > Colab examples for element-wise transforms (Java) > --

[jira] [Updated] (BEAM-7374) Add usage documentation for vet runner

[ https://issues.apache.org/jira/browse/BEAM-7374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7374: Labels: (was: stale-assigned) > Add usage documentation for vet runner > -

[jira] [Commented] (BEAM-7686) Erroneous Beam Deprecation warnings are confusing Bigquery IO users.

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

[jira] [Updated] (BEAM-7410) Explore possibilities to lower in-use IP address quota footprint.

[ https://issues.apache.org/jira/browse/BEAM-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7410: Labels: (was: stale-assigned) > Explore possibilities to lower in-use IP address quota footprint.

[jira] [Commented] (BEAM-7410) Explore possibilities to lower in-use IP address quota footprint.

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

[jira] [Updated] (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 ] Beam JIRA Bot updated BEAM-7246: Labels: (was: stale-assigned) > Add Google Spanner IO on Python SDK > ---

[jira] [Commented] (BEAM-7697) Provide a way to run tests from Gradle in a unified and reusable way

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

[jira] [Assigned] (BEAM-7242) Update release process to add support for pushing RCs to PyPI for testing.

[ https://issues.apache.org/jira/browse/BEAM-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7242: --- Assignee: (was: Ahmet Altay) > Update release process to add support for pushing RCs to P

[jira] [Commented] (BEAM-7120) Turn `WindowedValue` into `T` for all the interfaces of Data Plane

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

[jira] [Commented] (BEAM-7668) Add ability to query a pipeline from a gRPC JobService

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

[jira] [Updated] (BEAM-7668) Add ability to query a pipeline from a gRPC JobService

[ https://issues.apache.org/jira/browse/BEAM-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7668: Labels: portability (was: portability stale-assigned) > Add ability to query a pipeline from a gRPC

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

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

[jira] [Updated] (BEAM-7559) Add an Integration Test for DynamoDBIO

[ https://issues.apache.org/jira/browse/BEAM-7559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7559: Labels: (was: stale-assigned) > Add an Integration Test for DynamoDBIO > -

[jira] [Updated] (BEAM-7222) Spark portable runner: support SDF

[ https://issues.apache.org/jira/browse/BEAM-7222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7222: Labels: portability-spark (was: portability-spark stale-assigned) > Spark portable runner: support

[jira] [Assigned] (BEAM-7605) Provide a way for user code to read dataflow runner stats

[ https://issues.apache.org/jira/browse/BEAM-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7605: --- Assignee: (was: Steve Niemitz) > Provide a way for user code to read dataflow runner stat

[jira] [Assigned] (BEAM-7686) Erroneous Beam Deprecation warnings are confusing Bigquery IO users.

[ https://issues.apache.org/jira/browse/BEAM-7686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7686: --- Assignee: (was: Pablo Estrada) > Erroneous Beam Deprecation warnings are confusing Bigque

[jira] [Assigned] (BEAM-7701) Update Python dependencies page for 2.14.0

[ https://issues.apache.org/jira/browse/BEAM-7701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7701: --- Assignee: (was: Rose Nguyen) > Update Python dependencies page for 2.14.0 > -

[jira] [Commented] (BEAM-7395) Check immutability violations in Dataflow Runner (as an option)

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

[jira] [Assigned] (BEAM-7462) Add Sampled Byte Count Metric to the Java SDK

[ https://issues.apache.org/jira/browse/BEAM-7462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7462: --- Assignee: (was: Luke Cwik) > Add Sampled Byte Count Metric to the Java SDK >

[jira] [Assigned] (BEAM-7375) Handle dynamic functions in vet runner.

[ https://issues.apache.org/jira/browse/BEAM-7375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7375: --- Assignee: (was: Robert Burke) > Handle dynamic functions in vet runner. > ---

[jira] [Assigned] (BEAM-7433) RabbitMQMessage coder can't be registered when using Google Cloud Dataflow

[ https://issues.apache.org/jira/browse/BEAM-7433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7433: --- Assignee: (was: Kenneth Knowles) > RabbitMQMessage coder can't be registered when using G

[jira] [Updated] (BEAM-7701) Update Python dependencies page for 2.14.0

[ https://issues.apache.org/jira/browse/BEAM-7701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7701: Labels: (was: stale-assigned) > Update Python dependencies page for 2.14.0 > -

[jira] [Commented] (BEAM-7386) Add Utility BiTemporalStreamJoin

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

[jira] [Updated] (BEAM-7631) Remove experimental annotation from stable transforms in Java BigTableIO connector

[ https://issues.apache.org/jira/browse/BEAM-7631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7631: Labels: (was: stale-assigned) > Remove experimental annotation from stable transforms in Java BigT

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

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

[jira] [Assigned] (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 ] Beam JIRA Bot reassigned BEAM-7490: --- Assignee: (was: Kenneth Knowles) > TfIdfTest should not be marked ValidatesRunner > -

[jira] [Assigned] (BEAM-7677) Create a CLI to convert a pipeline to graphviz dot format

[ https://issues.apache.org/jira/browse/BEAM-7677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7677: --- Assignee: (was: Chad Dombrova) > Create a CLI to convert a pipeline to graphviz dot forma

[jira] [Commented] (BEAM-7058) Python SDK: Collect metrics in non-cython environment

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

[jira] [Updated] (BEAM-7064) Conversion of timestamp from BigQuery row to Beam row loses precision

[ https://issues.apache.org/jira/browse/BEAM-7064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7064: Labels: (was: stale-assigned) > Conversion of timestamp from BigQuery row to Beam row loses precis

[jira] [Commented] (BEAM-7478) Remote cluster submission from Flink Runner broken due to staging issues

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

[jira] [Assigned] (BEAM-7666) Pipe memory thrashing signal to Dataflow

[ https://issues.apache.org/jira/browse/BEAM-7666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7666: --- Assignee: (was: Dustin Rhodes) > Pipe memory thrashing signal to Dataflow > -

[jira] [Updated] (BEAM-7555) Migrate AWS IOs to AWS SDK for Java 2

[ https://issues.apache.org/jira/browse/BEAM-7555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7555: Labels: (was: stale-assigned) > Migrate AWS IOs to AWS SDK for Java 2 > --

[jira] [Updated] (BEAM-7633) Remove experimental annotation from stable transforms in Java HBaseIO connector

[ https://issues.apache.org/jira/browse/BEAM-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7633: Labels: (was: stale-assigned) > Remove experimental annotation from stable transforms in Java HBas

[jira] [Updated] (BEAM-7495) Add support for dynamic worker re-balancing when reading BigQuery data using Cloud Dataflow

[ https://issues.apache.org/jira/browse/BEAM-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7495: Labels: (was: stale-assigned) > Add support for dynamic worker re-balancing when reading BigQuery

[jira] [Assigned] (BEAM-7564) feature complete for ParDo in Samza Portable Runner

[ https://issues.apache.org/jira/browse/BEAM-7564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7564: --- Assignee: (was: Hai Lu) > feature complete for ParDo in Samza Portable Runner > -

[jira] [Assigned] (BEAM-7258) Nit: Go Postcommit Github PR command hint is incorrect

[ https://issues.apache.org/jira/browse/BEAM-7258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7258: --- Assignee: (was: Kyle Weaver) > Nit: Go Postcommit Github PR command hint is incorrect > -

[jira] [Updated] (BEAM-7084) Support custom environment types when expanding external transforms

[ https://issues.apache.org/jira/browse/BEAM-7084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7084: Labels: portability (was: portability stale-assigned) > Support custom environment types when expan

[jira] [Commented] (BEAM-7233) Spark portable runner: support Bundle Finalization

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

[jira] [Updated] (BEAM-7247) DoFnSignatures analysis of @ProcessElement with @Element fails when Java SDK is used from Kotlin

[ https://issues.apache.org/jira/browse/BEAM-7247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7247: Labels: (was: stale-assigned) > DoFnSignatures analysis of @ProcessElement with @Element fails whe

[jira] [Updated] (BEAM-7161) filter.Distinct should accept a KV type

[ https://issues.apache.org/jira/browse/BEAM-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7161: Labels: (was: stale-assigned) > filter.Distinct should accept a KV type >

[jira] [Commented] (BEAM-7390) Colab examples for aggregation transforms (Python)

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

[jira] [Assigned] (BEAM-7555) Migrate AWS IOs to AWS SDK for Java 2

[ https://issues.apache.org/jira/browse/BEAM-7555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7555: --- Assignee: (was: Cam Mach) > Migrate AWS IOs to AWS SDK for Java 2 > -

[jira] [Assigned] (BEAM-7124) adding kafkaio test in Python validateCrossLanguageRunner

[ https://issues.apache.org/jira/browse/BEAM-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7124: --- Assignee: (was: Heejong Lee) > adding kafkaio test in Python validateCrossLanguageRunner

[jira] [Updated] (BEAM-7666) Pipe memory thrashing signal to Dataflow

[ https://issues.apache.org/jira/browse/BEAM-7666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7666: Labels: (was: stale-assigned) > Pipe memory thrashing signal to Dataflow > ---

[jira] [Commented] (BEAM-7247) DoFnSignatures analysis of @ProcessElement with @Element fails when Java SDK is used from Kotlin

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

[jira] [Commented] (BEAM-7059) SamzaRunner: fix the job.id inconsistency in the new Samza version

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

[jira] [Assigned] (BEAM-7559) Add an Integration Test for DynamoDBIO

[ https://issues.apache.org/jira/browse/BEAM-7559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7559: --- Assignee: (was: Cam Mach) > Add an Integration Test for DynamoDBIO >

[jira] [Commented] (BEAM-7666) Pipe memory thrashing signal to Dataflow

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

[jira] [Assigned] (BEAM-7699) Remove duplicated null checks in Row.equals

[ https://issues.apache.org/jira/browse/BEAM-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7699: --- Assignee: (was: Nicholas Got) > Remove duplicated null checks in Row.equals > ---

[jira] [Assigned] (BEAM-7471) DirectRunner GameStats fails, ValueError: PCollection of size 2 with more than one element accessed as a singleton view. First two elements encountered are "181.611538462

[ https://issues.apache.org/jira/browse/BEAM-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7471: --- Assignee: (was: Ankur Goenka) > DirectRunner GameStats fails, ValueError: PCollection of

[jira] [Updated] (BEAM-7428) ReadAllViaFileBasedSource does not output the timestamps of the read elements

[ https://issues.apache.org/jira/browse/BEAM-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7428: Labels: (was: stale-assigned) > ReadAllViaFileBasedSource does not output the timestamps of the re

[jira] [Commented] (BEAM-6992) Implement KinesisIO.Write using AWS SDK

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

[jira] [Assigned] (BEAM-7247) DoFnSignatures analysis of @ProcessElement with @Element fails when Java SDK is used from Kotlin

[ https://issues.apache.org/jira/browse/BEAM-7247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7247: --- Assignee: (was: Reuven Lax) > DoFnSignatures analysis of @ProcessElement with @Element fa

[jira] [Assigned] (BEAM-7014) Flake in gcsio.py / filesystemio.py - NotImplementedError: offset: 0, whence: 0

[ https://issues.apache.org/jira/browse/BEAM-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7014: --- Assignee: (was: Chamikara Madhusanka Jayalath) > Flake in gcsio.py / filesystemio.py - No

[jira] [Updated] (BEAM-7120) Turn `WindowedValue` into `T` for all the interfaces of Data Plane

[ https://issues.apache.org/jira/browse/BEAM-7120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7120: Labels: (was: stale-assigned) > Turn `WindowedValue` into `T` for all the interfaces of Data Plane

[jira] [Commented] (BEAM-6856) Support dynamic MapState on Dataflow

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

[jira] [Assigned] (BEAM-7215) Wordcount example page does not tell the user to create the maven project using archetype

[ https://issues.apache.org/jira/browse/BEAM-7215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7215: --- Assignee: (was: Melissa Pashniak) > Wordcount example page does not tell the user to crea

[jira] [Updated] (BEAM-7540) deadlock using save_main_session and logging caused by threading.RLock pickling

[ https://issues.apache.org/jira/browse/BEAM-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7540: Labels: (was: stale-assigned) > deadlock using save_main_session and logging caused by threading.R

[jira] [Commented] (BEAM-7222) Spark portable runner: support SDF

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

[jira] [Updated] (BEAM-7386) Add Utility BiTemporalStreamJoin

[ https://issues.apache.org/jira/browse/BEAM-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7386: Labels: (was: stale-assigned) > Add Utility BiTemporalStreamJoin > ---

[jira] [Updated] (BEAM-7632) Update Python quickstart guide for Flink and Spark

[ https://issues.apache.org/jira/browse/BEAM-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7632: Labels: (was: stale-assigned) > Update Python quickstart guide for Flink and Spark > -

[jira] [Updated] (BEAM-7014) Flake in gcsio.py / filesystemio.py - NotImplementedError: offset: 0, whence: 0

[ https://issues.apache.org/jira/browse/BEAM-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7014: Labels: beam-fixit flake (was: beam-fixit flake stale-assigned) > Flake in gcsio.py / filesystemio.

[jira] [Updated] (BEAM-7560) Python local filesystem match does not work without directory separator.

[ https://issues.apache.org/jira/browse/BEAM-7560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7560: Labels: ccoss2019 starter (was: ccoss2019 stale-assigned starter) > Python local filesystem match d

[jira] [Commented] (BEAM-6949) Python Gcp tests stalling on machine without credentials

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

[jira] [Commented] (BEAM-7701) Update Python dependencies page for 2.14.0

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

[jira] [Commented] (BEAM-7189) Remove FieldType metadata

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

[jira] [Assigned] (BEAM-7064) Conversion of timestamp from BigQuery row to Beam row loses precision

[ https://issues.apache.org/jira/browse/BEAM-7064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7064: --- Assignee: (was: Kenneth Knowles) > Conversion of timestamp from BigQuery row to Beam row

[jira] [Commented] (BEAM-7705) Colab examples for connector transforms (Java)

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

[jira] [Assigned] (BEAM-7418) Install google-cloud-storage on py worker container

[ https://issues.apache.org/jira/browse/BEAM-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7418: --- Assignee: (was: Rafal Wojdyla) > Install google-cloud-storage on py worker container > --

[jira] [Commented] (BEAM-7418) Install google-cloud-storage on py worker container

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

[jira] [Assigned] (BEAM-7382) Bigquery IO: schema autodetection failing

[ https://issues.apache.org/jira/browse/BEAM-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7382: --- Assignee: (was: Pablo Estrada) > Bigquery IO: schema autodetection failing >

[jira] [Commented] (BEAM-7033) Document that query results can be read with the BigQuery storage API

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

[jira] [Assigned] (BEAM-7410) Explore possibilities to lower in-use IP address quota footprint.

[ https://issues.apache.org/jira/browse/BEAM-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7410: --- Assignee: (was: Alan Myrvold) > Explore possibilities to lower in-use IP address quota fo

[jira] [Updated] (BEAM-7638) Migrate KinesisIO to AWS SDK for Java 2

[ https://issues.apache.org/jira/browse/BEAM-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7638: Labels: (was: stale-assigned) > Migrate KinesisIO to AWS SDK for Java 2 >

[jira] [Updated] (BEAM-7516) Add a watermark manager for the fn_api_runner

[ https://issues.apache.org/jira/browse/BEAM-7516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7516: Labels: (was: stale-assigned) > Add a watermark manager for the fn_api_runner > --

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

[ https://issues.apache.org/jira/browse/BEAM-7303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7303: --- Assignee: (was: Ankur Goenka) > Move Portable Runner and other of reference runner. > ---

[jira] [Assigned] (BEAM-7399) Publishing a blog post about looping timers.

[ https://issues.apache.org/jira/browse/BEAM-7399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7399: --- Assignee: (was: Reza ardeshir rokni) > Publishing a blog post about looping timers. > --

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

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

[jira] [Updated] (BEAM-7155) Provide access to within DoFn.OnTimerContext

[ https://issues.apache.org/jira/browse/BEAM-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7155: Labels: (was: stale-assigned) > Provide access to within DoFn.OnTimerContext > -

[jira] [Updated] (BEAM-7704) Colab examples for other transforms (Java)

[ https://issues.apache.org/jira/browse/BEAM-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7704: Labels: (was: stale-assigned) > Colab examples for other transforms (Java) > -

[jira] [Commented] (BEAM-7195) BigQuery - 404 errors for 'table not found' when using dynamic destinations - sometimes, new table fails to get created

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

[jira] [Commented] (BEAM-7560) Python local filesystem match does not work without directory separator.

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

[jira] [Assigned] (BEAM-7562) Remove/Replace Sns's Writer turn type PCollectionTuple

[ https://issues.apache.org/jira/browse/BEAM-7562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7562: --- Assignee: (was: Cam Mach) > Remove/Replace Sns's Writer turn type PCollectionTuple >

[jira] [Commented] (BEAM-7516) Add a watermark manager for the fn_api_runner

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

[jira] [Assigned] (BEAM-7034) Add sample code for reading query results with the BigQuery storage API

[ https://issues.apache.org/jira/browse/BEAM-7034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7034: --- Assignee: (was: David Cavazos) > Add sample code for reading query results with the BigQu

[jira] [Updated] (BEAM-7167) Unable to cancel a DoFn Timer

[ https://issues.apache.org/jira/browse/BEAM-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7167: Labels: (was: stale-assigned) > Unable to cancel a DoFn Timer > - > >

[jira] [Updated] (BEAM-7686) Erroneous Beam Deprecation warnings are confusing Bigquery IO users.

[ https://issues.apache.org/jira/browse/BEAM-7686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7686: Labels: (was: stale-assigned) > Erroneous Beam Deprecation warnings are confusing Bigquery IO user

[jira] [Assigned] (BEAM-7392) Colab examples for connector transforms (Python)

[ https://issues.apache.org/jira/browse/BEAM-7392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7392: --- Assignee: (was: David Cavazos) > Colab examples for connector transforms (Python) > -

[jira] [Assigned] (BEAM-7222) Spark portable runner: support SDF

[ https://issues.apache.org/jira/browse/BEAM-7222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7222: --- Assignee: (was: Kyle Weaver) > Spark portable runner: support SDF > -

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17131363#comment-17131363 ] Beam JIRA Bot commented on BEAM-7336: - This issue was marked "stale-assigned" and has

[jira] [Updated] (BEAM-7534) add --mountTempDir option for easier data sharing with Docker container

[ https://issues.apache.org/jira/browse/BEAM-7534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7534: Labels: (was: stale-assigned) > add --mountTempDir option for easier data sharing with Docker cont

[jira] [Updated] (BEAM-7195) BigQuery - 404 errors for 'table not found' when using dynamic destinations - sometimes, new table fails to get created

[ https://issues.apache.org/jira/browse/BEAM-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7195: Labels: (was: stale-assigned) > BigQuery - 404 errors for 'table not found' when using dynamic des

[jira] [Assigned] (BEAM-7046) fix http_proxy warnings from grpc in tests

[ https://issues.apache.org/jira/browse/BEAM-7046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7046: --- Assignee: (was: Udi Meiri) > fix http_proxy warnings from grpc in tests > ---

[jira] [Updated] (BEAM-7478) Remote cluster submission from Flink Runner broken due to staging issues

[ https://issues.apache.org/jira/browse/BEAM-7478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7478: Labels: (was: stale-assigned) > Remote cluster submission from Flink Runner broken due to staging

[jira] [Assigned] (BEAM-7468) Add Python global window side input pattern

[ https://issues.apache.org/jira/browse/BEAM-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7468: --- Assignee: (was: Reza ardeshir rokni) > Add Python global window side input pattern >

[jira] [Assigned] (BEAM-7632) Update Python quickstart guide for Flink and Spark

[ https://issues.apache.org/jira/browse/BEAM-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7632: --- Assignee: (was: Kyle Weaver) > Update Python quickstart guide for Flink and Spark > -

<    5   6   7   8   9   10   11   12   13   14   >