[jira] [Work logged] (BEAM-7554) datetime and decimal should be logical types

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

[jira] [Work logged] (BEAM-8647) Remove .mailmap from the sources

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

[jira] [Work logged] (BEAM-8376) Add FirestoreIO connector to Java SDK

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

[jira] [Work logged] (BEAM-8376) Add FirestoreIO connector to Java SDK

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

[jira] [Work logged] (BEAM-8647) Remove .mailmap from the sources

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

[jira] [Commented] (BEAM-3926) Support MetricsPusher in Dataflow Runner

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

[jira] [Commented] (BEAM-10304) Cannot connect to dynalite

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

[jira] [Updated] (BEAM-3926) Support MetricsPusher in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3926: Labels: (was: stale-P2) > Support MetricsPusher in Dataflow Runner > -

[jira] [Updated] (BEAM-10299) sdk_worker_main needlessly warns about missing main session file

[ https://issues.apache.org/jira/browse/BEAM-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10299: - Labels: (was: stale-P2) > sdk_worker_main needlessly warns about missing main session file > --

[jira] [Updated] (BEAM-10415) Remove FlinkStreamingImpulseSource or replace it with a timer-based version

[ https://issues.apache.org/jira/browse/BEAM-10415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10415: - Labels: stale-P2 (was: ) > Remove FlinkStreamingImpulseSource or replace it with a timer-based v

[jira] [Commented] (BEAM-10299) sdk_worker_main needlessly warns about missing main session file

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

[jira] [Updated] (BEAM-10301) Ignore negative estimate sizes when creating Dataflow split responses

[ https://issues.apache.org/jira/browse/BEAM-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10301: - Labels: (was: stale-P2) > Ignore negative estimate sizes when creating Dataflow split responses

[jira] [Commented] (BEAM-10641) Add Combiner Packing to Dataflow

[ https://issues.apache.org/jira/browse/BEAM-10641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191101#comment-17191101 ] Beam JIRA Bot commented on BEAM-10641: -- This issue is assigned but has not received

[jira] [Updated] (BEAM-10304) Cannot connect to dynalite

[ https://issues.apache.org/jira/browse/BEAM-10304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10304: - Priority: P3 (was: P2) > Cannot connect to dynalite > -- > >

[jira] [Updated] (BEAM-10299) sdk_worker_main needlessly warns about missing main session file

[ https://issues.apache.org/jira/browse/BEAM-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10299: - Priority: P3 (was: P2) > sdk_worker_main needlessly warns about missing main session file >

[jira] [Updated] (BEAM-10301) Ignore negative estimate sizes when creating Dataflow split responses

[ https://issues.apache.org/jira/browse/BEAM-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10301: - Priority: P3 (was: P2) > Ignore negative estimate sizes when creating Dataflow split responses >

[jira] [Updated] (BEAM-10304) Cannot connect to dynalite

[ https://issues.apache.org/jira/browse/BEAM-10304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10304: - Labels: (was: stale-P2) > Cannot connect to dynalite > -- > >

[jira] [Commented] (BEAM-10416) Getting error "message" : "The KMS key does not contain a location." while using withKmsKey() option at runtime in dataflow job

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

[jira] [Updated] (BEAM-3926) Support MetricsPusher in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3926: Priority: P3 (was: P2) > Support MetricsPusher in Dataflow Runner > ---

[jira] [Commented] (BEAM-10412) Add readAll transform for pubsub

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

[jira] [Commented] (BEAM-10123) Create CommitOffsetTransform to commit Kafka record offset

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

[jira] [Updated] (BEAM-10416) Getting error "message" : "The KMS key does not contain a location." while using withKmsKey() option at runtime in dataflow job

[ https://issues.apache.org/jira/browse/BEAM-10416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10416: - Labels: GCP stale-P2 (was: GCP) > Getting error "message" : "The KMS key does not contain a loca

[jira] [Commented] (BEAM-10223) AvroCoder has references to the encoded/decoded class

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

[jira] [Updated] (BEAM-10123) Create CommitOffsetTransform to commit Kafka record offset

[ https://issues.apache.org/jira/browse/BEAM-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10123: - Priority: P3 (was: P2) > Create CommitOffsetTransform to commit Kafka record offset > --

[jira] [Commented] (BEAM-10415) Remove FlinkStreamingImpulseSource or replace it with a timer-based version

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

[jira] [Updated] (BEAM-10123) Create CommitOffsetTransform to commit Kafka record offset

[ https://issues.apache.org/jira/browse/BEAM-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10123: - Labels: (was: stale-P2) > Create CommitOffsetTransform to commit Kafka record offset >

[jira] [Updated] (BEAM-9997) Improve step names in portable runners

[ https://issues.apache.org/jira/browse/BEAM-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9997: Priority: P3 (was: P2) > Improve step names in portable runners > -

[jira] [Updated] (BEAM-10641) Add Combiner Packing to Dataflow

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

[jira] [Updated] (BEAM-9997) Improve step names in portable runners

[ https://issues.apache.org/jira/browse/BEAM-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9997: Labels: portability-spark (was: portability-spark stale-P2) > Improve step names in portable runner

[jira] [Commented] (BEAM-10301) Ignore negative estimate sizes when creating Dataflow split responses

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

[jira] [Updated] (BEAM-10412) Add readAll transform for pubsub

[ https://issues.apache.org/jira/browse/BEAM-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10412: - Labels: stale-P2 (was: ) > Add readAll transform for pubsub > >

[jira] [Updated] (BEAM-10223) AvroCoder has references to the encoded/decoded class

[ https://issues.apache.org/jira/browse/BEAM-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10223: - Labels: (was: stale-P2) > AvroCoder has references to the encoded/decoded class > -

[jira] [Commented] (BEAM-9997) Improve step names in portable runners

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

[jira] [Updated] (BEAM-10223) AvroCoder has references to the encoded/decoded class

[ https://issues.apache.org/jira/browse/BEAM-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10223: - Priority: P3 (was: P2) > AvroCoder has references to the encoded/decoded class > ---

[jira] [Commented] (BEAM-10833) Error inferring type of tuple output

[ https://issues.apache.org/jira/browse/BEAM-10833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191080#comment-17191080 ] Jayendra commented on BEAM-10833: - With some pycharm debugging I was able to detect that

[jira] [Assigned] (BEAM-10379) Some problems when implementing BIT_AND aggregation function in BeamSQL

[ https://issues.apache.org/jira/browse/BEAM-10379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rehman Murad Ali reassigned BEAM-10379: --- Assignee: Shehzaad Nakhoda (was: Rehman Murad Ali) > Some problems when implementin

[jira] [Assigned] (BEAM-10817) Implement COUNT for Beam SQL ZetaSQL dialect as CombineFn

[ https://issues.apache.org/jira/browse/BEAM-10817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rehman Murad Ali reassigned BEAM-10817: --- Assignee: Shehzaad Nakhoda (was: Rehman Murad Ali) > Implement COUNT for Beam SQL Z

[jira] [Assigned] (BEAM-10613) Implement BIT_AND for Beam SQL ZetaSQL dialect as CombineFn

[ https://issues.apache.org/jira/browse/BEAM-10613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rehman Murad Ali reassigned BEAM-10613: --- Assignee: Shehzaad Nakhoda (was: Rehman Murad Ali) > Implement BIT_AND for Beam SQL

[jira] [Assigned] (BEAM-10810) Implement VARIANCE, VAR_POP, VAR_SAMP for Beam SQL ZetaSQL dialect as CombineFn

[ https://issues.apache.org/jira/browse/BEAM-10810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rehman Murad Ali reassigned BEAM-10810: --- Assignee: Shehzaad Nakhoda (was: Rehman Murad Ali) > Implement VARIANCE, VAR_POP, V

[jira] [Assigned] (BEAM-10809) Implement STDDEV, STDDEV_POP, STDDEV_SAMP for Beam SQL ZetaSQL dialect as CombineFn

[ https://issues.apache.org/jira/browse/BEAM-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rehman Murad Ali reassigned BEAM-10809: --- Assignee: Shehzaad Nakhoda (was: Rehman Murad Ali) > Implement STDDEV, STDDEV_POP,

[jira] [Comment Edited] (BEAM-9093) Pipeline options which with different underlying store variable does not get over written

[ https://issues.apache.org/jira/browse/BEAM-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191064#comment-17191064 ] Suzen Fylke edited comment on BEAM-9093 at 9/5/20, 3:21 PM: I'

[jira] [Comment Edited] (BEAM-9093) Pipeline options which with different underlying store variable does not get over written

[ https://issues.apache.org/jira/browse/BEAM-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191064#comment-17191064 ] Suzen Fylke edited comment on BEAM-9093 at 9/5/20, 3:21 PM: I'

[jira] [Commented] (BEAM-9093) Pipeline options which with different underlying store variable does not get over written

[ https://issues.apache.org/jira/browse/BEAM-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191064#comment-17191064 ] Suzen Fylke commented on BEAM-9093: --- I'm a bit confused about how this is supposed to wo