[jira] [Created] (BEAM-10848) Gauge metrics error when setting timers

2020-09-02 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10848: - Summary: Gauge metrics error when setting timers Key: BEAM-10848 URL: https://issues.apache.org/jira/browse/BEAM-10848 Project: Beam Issue Type: Bu

[jira] [Updated] (BEAM-10848) Gauge metrics error when setting timers

2020-09-02 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10848: -- Status: Open (was: Triage Needed) > Gauge metrics error when setting timers >

[jira] [Updated] (BEAM-10848) Gauge metrics error when setting timers

2020-09-02 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10848: -- Description: Gauges are affected by setting timers leading to {{None}} values: {noform

[jira] [Updated] (BEAM-10630) Include data from load tests in the release process

2020-09-07 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10630: -- Status: Resolved (was: Open) > Include data from load tests in the release process > -

[jira] [Updated] (BEAM-10760) Cleanup timers lead to unbounded state accumulation in global window

2020-09-08 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10760: -- Fix Version/s: 2.25.0 > Cleanup timers lead to unbounded state accumulation in global w

[jira] [Updated] (BEAM-10760) Cleanup timers lead to unbounded state accumulation in global window

2020-09-08 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10760: -- Status: Resolved (was: Open) > Cleanup timers lead to unbounded state accumulation in

[jira] [Commented] (BEAM-10760) Cleanup timers lead to unbounded state accumulation in global window

2020-09-08 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192247#comment-17192247 ] Maximilian Michels commented on BEAM-10760: --- Fixed via 5fd0010e52c5efee36760c30

[jira] [Updated] (BEAM-10819) Update Gradle to 6.1.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10819: -- Fix Version/s: (was: Not applicable) 2.24.0 > Update Gradle to 6

[jira] [Updated] (BEAM-10819) Update Gradle to 6.1.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10819: -- Status: Resolved (was: Open) > Update Gradle to 6.1.1 > -- > >

[jira] [Updated] (BEAM-10819) Update Gradle to 6.1.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10819: -- Fix Version/s: (was: 2.24.0) Not applicable > Update Gradle to 6

[jira] [Reopened] (BEAM-10819) Update Gradle to 6.1.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened BEAM-10819: --- > Update Gradle to 6.1.1 > -- > > Key: BEAM-10819 >

[jira] [Updated] (BEAM-10819) Update Gradle to 6.1.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10819: -- Status: Resolved (was: Resolved) > Update Gradle to 6.1.1 > -- > >

[jira] [Updated] (BEAM-10819) Update Gradle to 6.1.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10819: -- Status: Resolved (was: Open) > Update Gradle to 6.1.1 > -- > >

[jira] [Updated] (BEAM-10819) Update Gradle to 6.1.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10819: -- Status: Open (was: Triage Needed) > Update Gradle to 6.1.1 > -- >

[jira] [Commented] (BEAM-9456) Upgrade to gradle 6.6.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194090#comment-17194090 ] Maximilian Michels commented on BEAM-9456: -- Upgrade to 6.6.1 has been performed h

[jira] [Updated] (BEAM-9456) Upgrade to gradle 6.6.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9456: - Status: Resolved (was: Open) > Upgrade to gradle 6.6.1 > --- > >

[jira] [Updated] (BEAM-9456) Upgrade to gradle 6.6.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9456: - Fix Version/s: 2.24.0 > Upgrade to gradle 6.6.1 > --- > >

[jira] [Updated] (BEAM-9456) Upgrade to gradle 6.6.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9456: - Summary: Upgrade to gradle 6.6.1 (was: Upgrade to gradle 6.6.0) > Upgrade to gradle 6.6.1

[jira] [Updated] (BEAM-9456) Upgrade to gradle 6.6.1

2020-09-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9456: - Fix Version/s: (was: 2.24.0) 2.25.0 > Upgrade to gradle 6.6.1 > ---

[jira] [Assigned] (BEAM-10848) Gauge metrics error when setting timers

2020-10-05 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-10848: - Assignee: maghamravikiran > Gauge metrics error when setting timers > --

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

2020-10-06 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10940: -- Status: Open (was: Triage Needed) > Portable Flink runner should handle DelayedBundleA

[jira] [Reopened] (BEAM-9631) Flink 1.10 test execution is broken due to premature test cluster shutdown

2020-10-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened BEAM-9631: -- > Flink 1.10 test execution is broken due to premature test cluster shutdown > -

[jira] [Updated] (BEAM-9631) Flink 1.10 test execution is broken due to premature test cluster shutdown

2020-10-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9631: - Status: Resolved (was: Open) > Flink 1.10 test execution is broken due to premature test

[jira] [Updated] (BEAM-9631) Flink 1.10 test execution is broken due to premature test cluster shutdown

2020-10-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9631: - Status: Open (was: Triage Needed) > Flink 1.10 test execution is broken due to premature

[jira] [Updated] (BEAM-9631) Flink 1.10 test execution is broken due to premature test cluster shutdown

2020-10-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9631: - Fix Version/s: 2.21.0 > Flink 1.10 test execution is broken due to premature test cluster

[jira] [Updated] (BEAM-9631) Flink 1.10 test execution is broken due to premature test cluster shutdown

2020-10-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9631: - Status: Resolved (was: Open) > Flink 1.10 test execution is broken due to premature test

[jira] [Assigned] (BEAM-9855) Make it easier to configure a Flink state backend

2020-10-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-9855: Assignee: Maximilian Michels > Make it easier to configure a Flink state backend >

[jira] [Commented] (BEAM-8742) Add stateful processing to ParDo load test

2020-08-24 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183282#comment-17183282 ] Maximilian Michels commented on BEAM-8742: -- You're right, seems like this is now

[jira] [Updated] (BEAM-9855) Make it easier to configure a Flink state backend

2020-11-10 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9855: - Status: Resolved (was: Open) > Make it easier to configure a Flink state backend > --

[jira] [Updated] (BEAM-9855) Make it easier to configure a Flink state backend

2020-11-10 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9855: - Fix Version/s: 2.26.0 > Make it easier to configure a Flink state backend > --

[jira] [Commented] (BEAM-11210) ExecutableStageDoFnOperator should fire processing time timers properly instead of draining it directly when close() happens

2020-11-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229888#comment-17229888 ] Maximilian Michels commented on BEAM-11210: --- Processing timers have to be manua

[jira] [Commented] (BEAM-11251) Unfair lock/monitor in UnboundedSourceWrapper can starve checkpointing

2020-11-12 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230993#comment-17230993 ] Maximilian Michels commented on BEAM-11251: --- Good observation! I'd say disablin

[jira] [Commented] (BEAM-11251) Unfair lock/monitor in UnboundedSourceWrapper can starve checkpointing

2020-11-13 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231280#comment-17231280 ] Maximilian Michels commented on BEAM-11251: --- It will definitely increase the se

[jira] [Commented] (BEAM-11251) Unfair lock/monitor in UnboundedSourceWrapper can starve checkpointing

2020-11-13 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-11251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231282#comment-17231282 ] Maximilian Michels commented on BEAM-11251: --- In the meantime, do we have a Flin

[jira] [Commented] (BEAM-10385) Integrate SQL expansion into Flink job server

2020-07-20 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161026#comment-17161026 ] Maximilian Michels commented on BEAM-10385: --- That seems reasonable given that d

[jira] [Commented] (BEAM-6868) Flink runner supports Bundle Finalization

2020-07-21 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161936#comment-17161936 ] Maximilian Michels commented on BEAM-6868: -- Can this be configured via the consum

[jira] [Created] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-22 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10558: - Summary: Flushing of buffered elements during checkpoint can stall Key: BEAM-10558 URL: https://issues.apache.org/jira/browse/BEAM-10558 Project: Beam

[jira] [Commented] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-22 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163117#comment-17163117 ] Maximilian Michels commented on BEAM-10558: --- Could be causing BEAM-9976. > Flu

[jira] [Commented] (BEAM-9976) FlinkSavepointTest timeout flake

2020-07-22 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163118#comment-17163118 ] Maximilian Michels commented on BEAM-9976: -- Could be caused by BEAM-10558. We wil

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Resolved (was: Resolved) > Flushing of buffered elements during checkpoint can

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Resolved (was: Open) > Flushing of buffered elements during checkpoint can sta

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Fix Version/s: 2.24.0 > Flushing of buffered elements during checkpoint can stall > ---

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Closed (was: Resolved) > Flushing of buffered elements during checkpoint can s

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Resolved (was: Resolved) > Flushing of buffered elements during checkpoint can

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Resolved (was: Closed) > Flushing of buffered elements during checkpoint can s

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Resolved (was: Open) > Flushing of buffered elements during checkpoint can sta

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Open (was: Triage Needed) > Flushing of buffered elements during checkpoint ca

[jira] [Reopened] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened BEAM-10558: --- > Flushing of buffered elements during checkpoint can stall > ---

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Closed (was: Open) > Flushing of buffered elements during checkpoint can stall

[jira] [Reopened] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened BEAM-10558: --- > Flushing of buffered elements during checkpoint can stall > ---

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Open (was: Triage Needed) > Flushing of buffered elements during checkpoint ca

[jira] [Reopened] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened BEAM-10558: --- > Flushing of buffered elements during checkpoint can stall > ---

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Fix Version/s: (was: 2.24.0) > Flushing of buffered elements during checkpoint can

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Fix Version/s: 2.24.0 > Flushing of buffered elements during checkpoint can stall > ---

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Resolved (was: Open) > Flushing of buffered elements during checkpoint can sta

[jira] [Updated] (BEAM-10558) Flushing of buffered elements during checkpoint can stall

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10558: -- Status: Open (was: Triage Needed) > Flushing of buffered elements during checkpoint ca

[jira] [Commented] (BEAM-6868) Flink runner supports Bundle Finalization

2020-07-23 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163591#comment-17163591 ] Maximilian Michels commented on BEAM-6868: -- Just curious, how could users of the

[jira] [Updated] (BEAM-10306) Add latency measurement to Python benchmarks

2020-07-27 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10306: -- Status: Resolved (was: Open) > Add latency measurement to Python benchmarks >

[jira] [Updated] (BEAM-10306) Add latency measurement to Python benchmarks

2020-07-27 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10306: -- Fix Version/s: 2.24.0 > Add latency measurement to Python benchmarks >

[jira] [Commented] (BEAM-9976) FlinkSavepointTest timeout flake

2020-07-27 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165784#comment-17165784 ] Maximilian Michels commented on BEAM-9976: -- Doesn't seem to be the case because t

[jira] [Commented] (BEAM-9976) FlinkSavepointTest timeout flake

2020-07-27 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165896#comment-17165896 ] Maximilian Michels commented on BEAM-9976: -- This scan has the log: https://scans

[jira] [Commented] (BEAM-8742) Add stateful processing to ParDo load test

2020-07-28 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166436#comment-17166436 ] Maximilian Michels commented on BEAM-8742: -- [~kasiak] We wanted to have support f

[jira] [Commented] (BEAM-10542) Investigate a possible Nexmark performance regression around 06/16

2020-07-28 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166437#comment-17166437 ] Maximilian Michels commented on BEAM-10542: --- Thanks everyone for the investigat

[jira] [Commented] (BEAM-10542) Investigate a possible Nexmark performance regression around 06/16

2020-07-28 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166455#comment-17166455 ] Maximilian Michels commented on BEAM-10542: --- Awesome, thanks! Didn't see the ti

[jira] [Updated] (BEAM-10602) Display Python streaming metrics in Grafana dashboard

2020-07-29 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10602: -- Attachment: screenshot-1.png > Display Python streaming metrics in Grafana dashboard >

[jira] [Moved] (BEAM-10602) Display Python streaming metrics in Grafana dashboard

2020-07-29 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels moved FLINK-18754 to BEAM-10602: --- An error occurred whilst rendering this message. Please contact

[jira] [Updated] (BEAM-10602) Display Python streaming metrics in Grafana dashboard

2020-07-29 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10602: -- Description: The Grafana dashboard is currently missing Python load test metrics: http

[jira] [Created] (BEAM-10622) Prefix Gradle paths with a colon for user-facing output

2020-08-03 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10622: - Summary: Prefix Gradle paths with a colon for user-facing output Key: BEAM-10622 URL: https://issues.apache.org/jira/browse/BEAM-10622 Project: Beam

[jira] [Created] (BEAM-10630) Include data from load tests in the release process

2020-08-03 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10630: - Summary: Include data from load tests in the release process Key: BEAM-10630 URL: https://issues.apache.org/jira/browse/BEAM-10630 Project: Beam Is

[jira] [Commented] (BEAM-4228) The FlinkRunner shouldn't require all of the values for a key to fit in memory

2020-06-26 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146105#comment-17146105 ] Maximilian Michels commented on BEAM-4228: -- I think this has been resolved by [~d

[jira] [Commented] (BEAM-4228) The FlinkRunner shouldn't require all of the values for a key to fit in memory

2020-06-26 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146106#comment-17146106 ] Maximilian Michels commented on BEAM-4228: -- See BEAM-8848. > The FlinkRunner sho

[jira] [Created] (BEAM-10330) grpc.local_channel_credentials() may not be present in all environments

2020-06-26 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10330: - Summary: grpc.local_channel_credentials() may not be present in all environments Key: BEAM-10330 URL: https://issues.apache.org/jira/browse/BEAM-10330 Proje

[jira] [Commented] (BEAM-9976) FlinkSavepointTest timeout flake

2020-06-26 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146575#comment-17146575 ] Maximilian Michels commented on BEAM-9976: -- Good catch! Of course the tests run t

[jira] [Commented] (BEAM-9851) "DNS resolution failed"

2020-06-29 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147674#comment-17147674 ] Maximilian Michels commented on BEAM-9851: -- [~ibzib] Wasn't there a fix for this?

[jira] [Resolved] (BEAM-10330) grpc.local_channel_credentials() may not be present in all environments

2020-06-29 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-10330. --- Fix Version/s: 2.23.0 Resolution: Fixed > grpc.local_channel_credentials() may

[jira] [Created] (BEAM-10385) Integrate SQL expansion into Beam job server

2020-06-30 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10385: - Summary: Integrate SQL expansion into Beam job server Key: BEAM-10385 URL: https://issues.apache.org/jira/browse/BEAM-10385 Project: Beam Issue Typ

[jira] [Created] (BEAM-10386) Move Flink external transform dependencies into base job server project

2020-06-30 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10386: - Summary: Move Flink external transform dependencies into base job server project Key: BEAM-10386 URL: https://issues.apache.org/jira/browse/BEAM-10386 Proje

[jira] [Created] (BEAM-10387) Add expansion_server keyword parameter to SqlTransform

2020-06-30 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10387: - Summary: Add expansion_server keyword parameter to SqlTransform Key: BEAM-10387 URL: https://issues.apache.org/jira/browse/BEAM-10387 Project: Beam

[jira] [Commented] (BEAM-10270) beam_LoadTests_Python_ParDo_Flink_Batch times out

2020-06-30 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148811#comment-17148811 ] Maximilian Michels commented on BEAM-10270: --- Yes, it should be investigated. >

[jira] [Updated] (BEAM-10270) beam_LoadTests_Python_ParDo_Flink_Batch times out

2020-06-30 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10270: -- Priority: P0 (was: P2) > beam_LoadTests_Python_ParDo_Flink_Batch times out > -

[jira] [Updated] (BEAM-10270) Portable batch performance regression observed via beam_LoadTests_Python_ParDo_Flink_Batch timing out

2020-06-30 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10270: -- Summary: Portable batch performance regression observed via beam_LoadTests_Python_ParDo

[jira] [Updated] (BEAM-10389) SqlTransform only allows one registered RowCoder schema

2020-06-30 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10389: -- Status: Open (was: Triage Needed) > SqlTransform only allows one registered RowCoder s

[jira] [Created] (BEAM-10389) SqlTransform only allows one registered RowCoder schema

2020-06-30 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10389: - Summary: SqlTransform only allows one registered RowCoder schema Key: BEAM-10389 URL: https://issues.apache.org/jira/browse/BEAM-10389 Project: Beam

[jira] [Updated] (BEAM-10385) Integrate SQL expansion into Flink job server

2020-07-01 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10385: -- Summary: Integrate SQL expansion into Flink job server (was: Integrate SQL expansion i

[jira] [Updated] (BEAM-10385) Integrate SQL expansion into Flink job server

2020-07-01 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10385: -- Component/s: (was: sdk-py-core) (was: sdk-java-core) > Integra

[jira] [Created] (BEAM-10413) Change default SDK worker parallelism to use the number of cpu cores

2020-07-07 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10413: - Summary: Change default SDK worker parallelism to use the number of cpu cores Key: BEAM-10413 URL: https://issues.apache.org/jira/browse/BEAM-10413 Project:

[jira] [Created] (BEAM-10414) FlinkStreamingImpulseSource fails in from_runner_api

2020-07-07 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10414: - Summary: FlinkStreamingImpulseSource fails in from_runner_api Key: BEAM-10414 URL: https://issues.apache.org/jira/browse/BEAM-10414 Project: Beam I

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

2020-07-07 Thread Maximilian Michels (Jira)
Maximilian Michels created BEAM-10415: - Summary: Remove FlinkStreamingImpulseSource or replace it with a timer-based version Key: BEAM-10415 URL: https://issues.apache.org/jira/browse/BEAM-10415 P

[jira] [Updated] (BEAM-10414) FlinkStreamingImpulseSource fails in from_runner_api

2020-07-07 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10414: -- Description: The proprietary {{FlinkStreamingImpulse}} stopped working from 2.20.0 on.

[jira] [Resolved] (BEAM-10385) Integrate SQL expansion into Flink job server

2020-07-07 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-10385. --- Fix Version/s: 2.24.0 Resolution: Fixed Should we backport this to 2.23.0, [~t

[jira] [Resolved] (BEAM-10387) Add expansion_server keyword parameter to SqlTransform

2020-07-07 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-10387. --- Fix Version/s: 2.24.0 Resolution: Fixed > Add expansion_server keyword paramet

[jira] [Commented] (BEAM-10387) Add expansion_server keyword parameter to SqlTransform

2020-07-07 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152824#comment-17152824 ] Maximilian Michels commented on BEAM-10387: --- Fixed via https://github.com/apac

[jira] [Resolved] (BEAM-10414) FlinkStreamingImpulseSource fails in from_runner_api

2020-07-08 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-10414. --- Fix Version/s: 2.24.0 Resolution: Fixed > FlinkStreamingImpulseSource fails in

[jira] [Resolved] (BEAM-10392) :sdks:java:io:rabbitmq:test gets stuck regularly

2020-07-08 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-10392. --- Fix Version/s: 2.24.0 Resolution: Fixed > :sdks:java:io:rabbitmq:test gets stu

[jira] [Assigned] (BEAM-9996) Flink should not shadow FnApiRunnerTest.test_metrics

2020-07-09 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-9996: Assignee: Maximilian Michels > Flink should not shadow FnApiRunnerTest.test_metrics

[jira] [Commented] (BEAM-6868) Flink runner supports Bundle Finalization

2020-07-10 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155309#comment-17155309 ] Maximilian Michels commented on BEAM-6868: -- This became relevant for the external

[jira] [Updated] (BEAM-10622) Prefix Gradle paths with a colon for user-facing output

2020-08-04 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10622: -- Status: Resolved (was: Open) > Prefix Gradle paths with a colon for user-facing output

[jira] [Updated] (BEAM-10622) Prefix Gradle paths with a colon for user-facing output

2020-08-04 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-10622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10622: -- Fix Version/s: 2.24.0 > Prefix Gradle paths with a colon for user-facing output > -

[jira] [Commented] (BEAM-9976) FlinkSavepointTest timeout flake

2020-08-06 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172609#comment-17172609 ] Maximilian Michels commented on BEAM-9976: -- If we haven't seen any new failures,

[jira] [Commented] (BEAM-9976) FlinkSavepointTest timeout flake

2020-08-06 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172628#comment-17172628 ] Maximilian Michels commented on BEAM-9976: -- Oh that's neat. I didn't know this fe

  1   2   3   4   5   6   7   8   9   10   >