[jira] [Commented] (BEAM-10087) Flink 1.10 failing [Java 11]

[ https://issues.apache.org/jira/browse/BEAM-10087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125867#comment-17125867 ] Maximilian Michels commented on BEAM-10087: --- Do you know though how to ensure a the same Java

[jira] [Commented] (BEAM-10054) Direct Runner execution stalls with test pipeline

[ https://issues.apache.org/jira/browse/BEAM-10054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125773#comment-17125773 ] Maximilian Michels commented on BEAM-10054: --- Just saw that we already have a release candidate,

[jira] [Commented] (BEAM-10054) Direct Runner execution stalls with test pipeline

[ https://issues.apache.org/jira/browse/BEAM-10054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125769#comment-17125769 ] Maximilian Michels commented on BEAM-10054: --- I think we could consider backporting. > Direct

[jira] [Resolved] (BEAM-10054) Direct Runner execution stalls with test pipeline

[ https://issues.apache.org/jira/browse/BEAM-10054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-10054. --- Fix Version/s: 2.23.0 Resolution: Fixed > Direct Runner execution stalls with

[jira] [Commented] (BEAM-10087) Flink 1.10 failing [Java 11]

[ https://issues.apache.org/jira/browse/BEAM-10087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125695#comment-17125695 ] Maximilian Michels commented on BEAM-10087: --- Your analysis sounds correct. We could fix the

[jira] [Closed] (BEAM-10164) Flink: Memory efficient combine implementation for batch runner

[ https://issues.apache.org/jira/browse/BEAM-10164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-10164. - Fix Version/s: 2.22.0 Resolution: Fixed > Flink: Memory efficient combine

[jira] [Closed] (BEAM-10132) Remove reference to apachebeam/*

[ https://issues.apache.org/jira/browse/BEAM-10132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-10132. - Fix Version/s: Not applicable Resolution: Fixed > Remove reference to

[jira] [Commented] (BEAM-10143) ClassCastException in GROUP BY with non-global window

[ https://issues.apache.org/jira/browse/BEAM-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124075#comment-17124075 ] Maximilian Michels commented on BEAM-10143: --- Principally, I'd assume Java to have the same bug

[jira] [Commented] (BEAM-10143) ClassCastException in GROUP BY with non-global window

[ https://issues.apache.org/jira/browse/BEAM-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124047#comment-17124047 ] Maximilian Michels commented on BEAM-10143: --- I haven't tested this with pure Java, only as an

[jira] [Resolved] (BEAM-7973) Python doesn't shut down Flink job server properly

[ https://issues.apache.org/jira/browse/BEAM-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-7973. -- Fix Version/s: Not applicable Resolution: Not A Problem This has been fixed in

[jira] [Closed] (BEAM-4781) PTransforms that simply return their input cause portable Flink to crash.

[ https://issues.apache.org/jira/browse/BEAM-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-4781. Fix Version/s: Not applicable Resolution: Not A Problem Tried out the above and do

[jira] [Commented] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

[ https://issues.apache.org/jira/browse/BEAM-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120328#comment-17120328 ] Maximilian Michels commented on BEAM-9843: -- Thanks Kenn. I was assuming a recent change to the

[jira] [Commented] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

[ https://issues.apache.org/jira/browse/BEAM-7029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118970#comment-17118970 ] Maximilian Michels commented on BEAM-7029: -- Awesome. Thanks for the notice. If you have a PR,

[jira] [Updated] (BEAM-10143) ClassCastException in GROUP BY with non-global window

[ https://issues.apache.org/jira/browse/BEAM-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10143: -- Priority: P1 (was: P2) > ClassCastException in GROUP BY with non-global window >

[jira] [Updated] (BEAM-10143) ClassCastException in GROUP BY with non-global window

[ https://issues.apache.org/jira/browse/BEAM-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-10143: -- Status: Open (was: Triage Needed) > ClassCastException in GROUP BY with non-global

[jira] [Created] (BEAM-10143) ClassCastException in GROUP BY with non-global window

Maximilian Michels created BEAM-10143: - Summary: ClassCastException in GROUP BY with non-global window Key: BEAM-10143 URL: https://issues.apache.org/jira/browse/BEAM-10143 Project: Beam

[jira] [Commented] (BEAM-10016) Flink postcommits failing testFlattenWithDifferentInputAndOutputCoders2

[ https://issues.apache.org/jira/browse/BEAM-10016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113380#comment-17113380 ] Maximilian Michels commented on BEAM-10016: --- Just to clarify, since this is only failing for

[jira] [Commented] (BEAM-10016) Flink postcommits failing testFlattenWithDifferentInputAndOutputCoders2

[ https://issues.apache.org/jira/browse/BEAM-10016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113351#comment-17113351 ] Maximilian Michels commented on BEAM-10016: --- I think yes, if someone wants to have a look,

[jira] [Created] (BEAM-10054) Direct Runner execution stalls with test pipeline

Maximilian Michels created BEAM-10054: - Summary: Direct Runner execution stalls with test pipeline Key: BEAM-10054 URL: https://issues.apache.org/jira/browse/BEAM-10054 Project: Beam

[jira] [Resolved] (BEAM-9966) Investigate variance in checkpoint duration of ParDo streaming tests

[ https://issues.apache.org/jira/browse/BEAM-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9966. -- Fix Version/s: Not applicable Resolution: Fixed The load test had a bug which

[jira] [Commented] (BEAM-8239) Docker options in --environment_config

[ https://issues.apache.org/jira/browse/BEAM-8239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108991#comment-17108991 ] Maximilian Michels commented on BEAM-8239: -- To this date there is no option to mount a volume

[jira] [Commented] (BEAM-9966) Investigate variance in checkpoint duration of ParDo streaming tests

[ https://issues.apache.org/jira/browse/BEAM-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106442#comment-17106442 ] Maximilian Michels commented on BEAM-9966: -- It seems to have been caused because the test used

[jira] [Created] (BEAM-9981) Use FlinkRunner instead of PortableRunner for load tests

Maximilian Michels created BEAM-9981: Summary: Use FlinkRunner instead of PortableRunner for load tests Key: BEAM-9981 URL: https://issues.apache.org/jira/browse/BEAM-9981 Project: Beam

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

[ https://issues.apache.org/jira/browse/BEAM-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106196#comment-17106196 ] Maximilian Michels commented on BEAM-9976: -- Do you have a link to the full log? >

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

[ https://issues.apache.org/jira/browse/BEAM-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9976: - Status: Open (was: Triage Needed) > FlinkSavepointTest timeout flake >

[jira] [Commented] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

[ https://issues.apache.org/jira/browse/BEAM-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105723#comment-17105723 ] Maximilian Michels commented on BEAM-9843: -- Thanks for reporting this. This should be fixed. Feel

[jira] [Resolved] (BEAM-9164) [PreCommit_Java] [Flake] UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest

[ https://issues.apache.org/jira/browse/BEAM-9164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9164. -- Fix Version/s: Not applicable Resolution: Fixed This should be fixed but feel

[jira] [Created] (BEAM-9966) Investigate variance in checkpoint duration of ParDo streaming tests

Maximilian Michels created BEAM-9966: Summary: Investigate variance in checkpoint duration of ParDo streaming tests Key: BEAM-9966 URL: https://issues.apache.org/jira/browse/BEAM-9966 Project:

[jira] [Commented] (BEAM-9900) Remove the need for shutdownSourcesOnFinalWatermark flag

[ https://issues.apache.org/jira/browse/BEAM-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105620#comment-17105620 ] Maximilian Michels commented on BEAM-9900: -- For context:

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

[ https://issues.apache.org/jira/browse/BEAM-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8742: - Description: So far, the ParDo load test is not stateful. We should add a basic counter

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

[ https://issues.apache.org/jira/browse/BEAM-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105339#comment-17105339 ] Maximilian Michels commented on BEAM-8742: -- Cron:

[jira] [Resolved] (BEAM-9963) Flink streaming load tests fail with TypeError

[ https://issues.apache.org/jira/browse/BEAM-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9963. -- Fix Version/s: Not applicable Resolution: Fixed > Flink streaming load tests

[jira] [Updated] (BEAM-9963) Flink streaming load tests fail with TypeError

[ https://issues.apache.org/jira/browse/BEAM-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9963: - Description: The newly added load tests now fail on the latest master.

[jira] [Created] (BEAM-9963) Flink streaming load tests fail with TypeError

Maximilian Michels created BEAM-9963: Summary: Flink streaming load tests fail with TypeError Key: BEAM-9963 URL: https://issues.apache.org/jira/browse/BEAM-9963 Project: Beam Issue

[jira] [Resolved] (BEAM-9947) Timer coder contains a faulty key coder leading to a corrupted encoding

[ https://issues.apache.org/jira/browse/BEAM-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9947. -- Resolution: Fixed > Timer coder contains a faulty key coder leading to a corrupted

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

[ https://issues.apache.org/jira/browse/BEAM-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105273#comment-17105273 ] Maximilian Michels commented on BEAM-8742: -- I just saw your comment here. Thank you. I added

[jira] [Commented] (BEAM-9164) [PreCommit_Java] [Flake] UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest

[ https://issues.apache.org/jira/browse/BEAM-9164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105184#comment-17105184 ] Maximilian Michels commented on BEAM-9164: -- I was not aware that tests had been disabled. I'm a

[jira] [Updated] (BEAM-9947) Timer coder contains a faulty key coder leading to a corrupted encoding

[ https://issues.apache.org/jira/browse/BEAM-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9947: - Affects Version/s: (was: 2.20.0) 2.21.0 > Timer coder contains

[jira] [Updated] (BEAM-9947) Timer coder contains a faulty key coder leading to a corrupted encoding

[ https://issues.apache.org/jira/browse/BEAM-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9947: - Affects Version/s: 2.20.0 > Timer coder contains a faulty key coder leading to a

[jira] [Created] (BEAM-9947) Timer coder contains a faulty key coder leading to a corrupted encoding

Maximilian Michels created BEAM-9947: Summary: Timer coder contains a faulty key coder leading to a corrupted encoding Key: BEAM-9947 URL: https://issues.apache.org/jira/browse/BEAM-9947 Project:

[jira] [Updated] (BEAM-9947) Timer coder contains a faulty key coder leading to a corrupted encoding

[ https://issues.apache.org/jira/browse/BEAM-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9947: - Description: The coder for timers contains a key coder which may have to be

[jira] [Resolved] (BEAM-9930) Add announcement for Beam Summit Digital 2020 to the blog

[ https://issues.apache.org/jira/browse/BEAM-9930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9930. -- Fix Version/s: Not applicable Resolution: Fixed > Add announcement for Beam

[jira] [Created] (BEAM-9930) Add announcement for Beam Summit Digital 2020 to the blog

Maximilian Michels created BEAM-9930: Summary: Add announcement for Beam Summit Digital 2020 to the blog Key: BEAM-9930 URL: https://issues.apache.org/jira/browse/BEAM-9930 Project: Beam

[jira] [Commented] (BEAM-9900) Remove the need for shutdownSourcesOnFinalWatermark flag

[ https://issues.apache.org/jira/browse/BEAM-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101838#comment-17101838 ] Maximilian Michels commented on BEAM-9900: -- Fixed via d106f263e625e5d7c4f3848f16da301871f65142.

[jira] [Resolved] (BEAM-9900) Remove the need for shutdownSourcesOnFinalWatermark flag

[ https://issues.apache.org/jira/browse/BEAM-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9900. -- Fix Version/s: 2.22.0 Resolution: Fixed > Remove the need for

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

[ https://issues.apache.org/jira/browse/BEAM-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8742. -- Fix Version/s: 2.22.0 Resolution: Fixed > Add stateful processing to ParDo load

[jira] [Updated] (BEAM-9853) Remove spurious or irrelevant error messages from portable runner log output.

[ https://issues.apache.org/jira/browse/BEAM-9853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9853: - Status: Open (was: Triage Needed) > Remove spurious or irrelevant error messages from

[jira] [Created] (BEAM-9900) Remove the need for shutdownSourcesOnFinalWatermark flag

Maximilian Michels created BEAM-9900: Summary: Remove the need for shutdownSourcesOnFinalWatermark flag Key: BEAM-9900 URL: https://issues.apache.org/jira/browse/BEAM-9900 Project: Beam

[jira] [Resolved] (BEAM-1819) Key should be available in @OnTimer methods (Java)

[ https://issues.apache.org/jira/browse/BEAM-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-1819. -- Resolution: Fixed > Key should be available in @OnTimer methods (Java) >

[jira] [Commented] (BEAM-1819) Key should be available in @OnTimer methods

[ https://issues.apache.org/jira/browse/BEAM-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099771#comment-17099771 ] Maximilian Michels commented on BEAM-1819: -- It looks like Python already passes the key. So good

[jira] [Updated] (BEAM-1819) Key should be available in @OnTimer methods (Java)

[ https://issues.apache.org/jira/browse/BEAM-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-1819: - Summary: Key should be available in @OnTimer methods (Java) (was: Key should be

[jira] [Resolved] (BEAM-9841) PortableRunner does not support wait_until_finish(duration=...)

[ https://issues.apache.org/jira/browse/BEAM-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9841. -- Fix Version/s: 2.22.0 Resolution: Fixed > PortableRunner does not support

[jira] [Updated] (BEAM-9874) Portable timers can't be cleared in batch mode

[ https://issues.apache.org/jira/browse/BEAM-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9874: - Description: After BEAM-9801, the {{test_pardo_timers_clear}} test fails. The test was

[jira] [Resolved] (BEAM-9874) Portable timers can't be cleared in batch mode

[ https://issues.apache.org/jira/browse/BEAM-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9874. -- Resolution: Fixed > Portable timers can't be cleared in batch mode >

[jira] [Assigned] (BEAM-9801) Setting a timer from a timer callback fails

[ https://issues.apache.org/jira/browse/BEAM-9801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-9801: Assignee: Maximilian Michels > Setting a timer from a timer callback fails >

[jira] [Resolved] (BEAM-9801) Setting a timer from a timer callback fails

[ https://issues.apache.org/jira/browse/BEAM-9801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9801. -- Resolution: Fixed > Setting a timer from a timer callback fails >

[jira] [Updated] (BEAM-9874) Portable timers can't be cleared in batch mode

[ https://issues.apache.org/jira/browse/BEAM-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9874: - Fix Version/s: 2.21.0 > Portable timers can't be cleared in batch mode >

[jira] [Updated] (BEAM-9874) Portable timers can't be cleared in batch mode

[ https://issues.apache.org/jira/browse/BEAM-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9874: - Description: After BEAM-9801, the {{test_pardo_timers_clear}} test fails. The test was

[jira] [Created] (BEAM-9874) Portable timers can't be cleared in batch mode

Maximilian Michels created BEAM-9874: Summary: Portable timers can't be cleared in batch mode Key: BEAM-9874 URL: https://issues.apache.org/jira/browse/BEAM-9874 Project: Beam Issue

[jira] [Commented] (BEAM-8944) Python SDK harness performance degradation with UnboundedThreadPoolExecutor

[ https://issues.apache.org/jira/browse/BEAM-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097302#comment-17097302 ] Maximilian Michels commented on BEAM-8944: -- [~lcwik] For the time being, do you think we could

[jira] [Commented] (BEAM-9854) Docker container build fails (:sdks:python:container:py37:docker)

[ https://issues.apache.org/jira/browse/BEAM-9854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096596#comment-17096596 ] Maximilian Michels commented on BEAM-9854: -- Apparently caused by missing disk space on the

[jira] [Resolved] (BEAM-6661) FnApi gRPC setup/teardown glitch

[ https://issues.apache.org/jira/browse/BEAM-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-6661. -- Fix Version/s: (was: 2.22.0) 2.21.0 Resolution: Fixed >

[jira] [Updated] (BEAM-6661) FnApi gRPC setup/teardown glitch

[ https://issues.apache.org/jira/browse/BEAM-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6661: - Status: Open (was: Triage Needed) > FnApi gRPC setup/teardown glitch >

[jira] [Reopened] (BEAM-6661) FnApi gRPC setup/teardown glitch

[ https://issues.apache.org/jira/browse/BEAM-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened BEAM-6661: -- > FnApi gRPC setup/teardown glitch > > >

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

Maximilian Michels created BEAM-9855: Summary: Make it easier to configure a Flink state backend Key: BEAM-9855 URL: https://issues.apache.org/jira/browse/BEAM-9855 Project: Beam Issue

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

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

[jira] [Updated] (BEAM-9854) Docker container build fails (:sdks:python:container:py37:docker)

[ https://issues.apache.org/jira/browse/BEAM-9854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9854: - Status: Open (was: Triage Needed) > Docker container build fails

[jira] [Created] (BEAM-9854) Docker container build fails (:sdks:python:container:py37:docker)

Maximilian Michels created BEAM-9854: Summary: Docker container build fails (:sdks:python:container:py37:docker) Key: BEAM-9854 URL: https://issues.apache.org/jira/browse/BEAM-9854 Project: Beam

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

[ https://issues.apache.org/jira/browse/BEAM-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9851: - Status: Open (was: Triage Needed) > "DNS resolution failed" > --- >

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

Maximilian Michels created BEAM-9851: Summary: "DNS resolution failed" Key: BEAM-9851 URL: https://issues.apache.org/jira/browse/BEAM-9851 Project: Beam Issue Type: Bug

[jira] [Resolved] (BEAM-6661) FnApi gRPC setup/teardown glitch

[ https://issues.apache.org/jira/browse/BEAM-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-6661. -- Fix Version/s: 2.22.0 Assignee: (was: Heejong Lee) Resolution: Fixed

[jira] [Commented] (BEAM-9801) Setting a timer from a timer callback fails

[ https://issues.apache.org/jira/browse/BEAM-9801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094864#comment-17094864 ] Maximilian Michels commented on BEAM-9801: -- I'm not sure if it was working at some point and

[jira] [Commented] (BEAM-2535) Allow explicit output time independent of firing specification for all timers

[ https://issues.apache.org/jira/browse/BEAM-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094581#comment-17094581 ] Maximilian Michels commented on BEAM-2535: -- I think this still needs API support on the Python

[jira] [Created] (BEAM-9841) PortableRunner does not support wait_until_finish(duration=...)

Maximilian Michels created BEAM-9841: Summary: PortableRunner does not support wait_until_finish(duration=...) Key: BEAM-9841 URL: https://issues.apache.org/jira/browse/BEAM-9841 Project: Beam

[jira] [Updated] (BEAM-9841) PortableRunner does not support wait_until_finish(duration=...)

[ https://issues.apache.org/jira/browse/BEAM-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9841: - Status: Open (was: Triage Needed) > PortableRunner does not support

[jira] [Assigned] (BEAM-2535) Allow explicit output time independent of firing specification for all timers

[ https://issues.apache.org/jira/browse/BEAM-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-2535: Assignee: Reuven Lax (was: Rehman Murad Ali) > Allow explicit output time

[jira] [Resolved] (BEAM-9827) Test SplittableDoFnTest#testPairWithIndexBasicBounded is flaky

[ https://issues.apache.org/jira/browse/BEAM-9827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9827. -- Resolution: Fixed > Test SplittableDoFnTest#testPairWithIndexBasicBounded is flaky >

[jira] [Resolved] (BEAM-3956) Stacktraces from exceptions in user code should be preserved in the Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-3956. -- Fix Version/s: Not applicable Resolution: Fixed To me best knowledge this has

[jira] [Updated] (BEAM-9827) Test SplittableDoFnTest#testPairWithIndexBasicBounded is flaky

[ https://issues.apache.org/jira/browse/BEAM-9827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9827: - Priority: Critical (was: Major) > Test SplittableDoFnTest#testPairWithIndexBasicBounded

[jira] [Updated] (BEAM-9827) Test SplittableDoFnTest#testPairWithIndexBasicBounded is flaky

[ https://issues.apache.org/jira/browse/BEAM-9827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9827: - Fix Version/s: 2.21.0 > Test SplittableDoFnTest#testPairWithIndexBasicBounded is flaky >

[jira] [Updated] (BEAM-9827) Test SplittableDoFnTest#testPairWithIndexBasicBounded is flaky

[ https://issues.apache.org/jira/browse/BEAM-9827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9827: - Status: Open (was: Triage Needed) > Test

[jira] [Created] (BEAM-9827) Test SplittableDoFnTest#testPairWithIndexBasicBounded is flaky

Maximilian Michels created BEAM-9827: Summary: Test SplittableDoFnTest#testPairWithIndexBasicBounded is flaky Key: BEAM-9827 URL: https://issues.apache.org/jira/browse/BEAM-9827 Project: Beam

[jira] [Commented] (BEAM-5440) Add option to mount a directory inside SDK harness containers

[ https://issues.apache.org/jira/browse/BEAM-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091848#comment-17091848 ] Maximilian Michels commented on BEAM-5440: -- I think we got sidetracked but this is still useful,

[jira] [Updated] (BEAM-9801) Setting a timer from a timer callback fails

[ https://issues.apache.org/jira/browse/BEAM-9801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9801: - Fix Version/s: 2.21.0 > Setting a timer from a timer callback fails >

[jira] [Commented] (BEAM-9801) Setting a timer from a timer callback fails

[ https://issues.apache.org/jira/browse/BEAM-9801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091513#comment-17091513 ] Maximilian Michels commented on BEAM-9801: -- I'm also putting it up for debate whether to hold the

[jira] [Resolved] (BEAM-9794) Flink pipeline with RequiresStableInput fails after Short.MAX_VALUE checkpoints.

[ https://issues.apache.org/jira/browse/BEAM-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9794. -- Resolution: Fixed > Flink pipeline with RequiresStableInput fails after Short.MAX_VALUE

[jira] [Commented] (BEAM-9801) Setting a timer from a timer callback fails

[ https://issues.apache.org/jira/browse/BEAM-9801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091373#comment-17091373 ] Maximilian Michels commented on BEAM-9801: -- Yes, I agree that this earns the "critical" badge. >

[jira] [Updated] (BEAM-9794) Flink pipeline with RequiresStableInput fails after Short.MAX_VALUE checkpoints.

[ https://issues.apache.org/jira/browse/BEAM-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9794: - Fix Version/s: 2.21.0 > Flink pipeline with RequiresStableInput fails after

[jira] [Created] (BEAM-9801) Setting a timer from a timer callback fails

Maximilian Michels created BEAM-9801: Summary: Setting a timer from a timer callback fails Key: BEAM-9801 URL: https://issues.apache.org/jira/browse/BEAM-9801 Project: Beam Issue Type:

[jira] [Commented] (BEAM-9794) Flink pipeline with RequiresStableInput fails after Short.MAX_VALUE checkpoints.

[ https://issues.apache.org/jira/browse/BEAM-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088812#comment-17088812 ] Maximilian Michels commented on BEAM-9794: -- That's also what I found when I started working on

[jira] [Commented] (BEAM-9794) Flink pipeline with RequiresStableInput fails after Short.MAX_VALUE checkpoints.

[ https://issues.apache.org/jira/browse/BEAM-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088752#comment-17088752 ] Maximilian Michels commented on BEAM-9794: -- Taking this one after I synced with [~dmvk]. > Flink

[jira] [Assigned] (BEAM-9794) Flink pipeline with RequiresStableInput fails after Short.MAX_VALUE checkpoints.

[ https://issues.apache.org/jira/browse/BEAM-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-9794: Assignee: Maximilian Michels (was: David Morávek) > Flink pipeline with

[jira] [Commented] (BEAM-9794) Flink pipeline with RequiresStableInput fails after Short.MAX_VALUE checkpoints.

[ https://issues.apache.org/jira/browse/BEAM-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088401#comment-17088401 ] Maximilian Michels commented on BEAM-9794: -- Good catch! I think we have to resort to only using a

[jira] [Commented] (BEAM-9655) Stateful Dataflow runner?

[ https://issues.apache.org/jira/browse/BEAM-9655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083447#comment-17083447 ] Maximilian Michels commented on BEAM-9655: -- I thought Dataflow supported state and timers. Is the

[jira] [Resolved] (BEAM-9534) Flink testParDoRequiresStableInput timed out

[ https://issues.apache.org/jira/browse/BEAM-9534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-9534. -- Fix Version/s: Not applicable Resolution: Fixed > Flink

[jira] [Commented] (BEAM-9656) Reading from pubsub in portable FlinkRunner (ambigious ReadFromPubSub transform)

[ https://issues.apache.org/jira/browse/BEAM-9656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079185#comment-17079185 ] Maximilian Michels commented on BEAM-9656: -- I'm sorry you are experiencing problems. I think we

[jira] [Updated] (BEAM-9733) ImpulseSourceFunction does not emit a final watermark

[ https://issues.apache.org/jira/browse/BEAM-9733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9733: - Fix Version/s: 2.21.0 > ImpulseSourceFunction does not emit a final watermark >

[jira] [Updated] (BEAM-9733) ImpulseSourceFunction does not emit a final watermark

[ https://issues.apache.org/jira/browse/BEAM-9733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-9733: - Status: Open (was: Triage Needed) > ImpulseSourceFunction does not emit a final

[jira] [Created] (BEAM-9733) ImpulseSourceFunction does not emit a final watermark

Maximilian Michels created BEAM-9733: Summary: ImpulseSourceFunction does not emit a final watermark Key: BEAM-9733 URL: https://issues.apache.org/jira/browse/BEAM-9733 Project: Beam

[jira] [Commented] (BEAM-9656) Reading from pubsub in portable FlinkRunner (ambigious ReadFromPubSub transform)

[ https://issues.apache.org/jira/browse/BEAM-9656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079027#comment-17079027 ] Maximilian Michels commented on BEAM-9656: -- Hey [~leopold.boudard]! I'm glad you got it to work.

  1   2   3   4   5   6   7   8   9   10   >