Robert Burke
Robert Burke
### What would you like to happen? There's been a quiet request to have windows also be providable to CombineFn methods. Very similar to key aware CombineFns in issue #22211...
### What needs to happen? This issue is to track and refer to other issues/prs for various prism features. This issue shouldn't generally be commented on, but have this top...
Sharded out this batch of ProcesssingTime features to complete simultaneously, once TestStream #29917 and to allow #29772 to be closed. After TestStream is in, there's a very clear hook for...
### What happened? Action has never succeeded. https://github.com/apache/beam/actions/workflows/beam_PostCommit_TransformService_Direct.yml?query=is%3Afailure Locally: ``` ./gradlew :sdks:python:test-suites:direct:xlang:transformServicePythonUsingJava --max-workers=8 --continue \ -Dorg.gradle.jvmargs=-Xms2g -Dorg.gradle.jvmargs=-Xmx6g -Dorg.gradle.vfs.watch=false -Pdocker-pull-licenses \ -PtestJavaVersion=11 \ -Pjava11Home=$JAVA_HOME_11_X64 \ -PuseWheelDistribution \ -PpythonVersion=3.11 ``` Failure isn't...
Tests run on GHA should be queued shortly.
### What happened? Action suite has never succeeded. https://github.com/apache/beam/actions/workflows/beam_PostCommit_Java_Sickbay.yml?query=is%3Asuccess Seems to be flink related at present, but this could just be a poorly formulated "sickbay suite" since those are typically...
### What happened? Dataflow is making DataSampling FnAPI requests even when DataSampling is disabled. But since the feature wasn't enabled, the Go SDK isn't initialzing the datasampler, leading to nil...
Add a ProcessingTime queue to Prism's element manager, that can be appropriately controlled by the TestStream notion of time. Basic design is that the queue doesn't contain the elements, but...
Eventually we should publish OS + Architecture specific binaries for Prism in order to make it easier to use with released versions, and avoid requiring users compile it locally with...
Add additional state tests for different coders. There's been a report of byte buffers becoming truncated or corrupted after being written to state. ------------------------ Thank you for your contribution! Follow...